Skip to content

Commit

Permalink
[FLINK-36336][docs] Remove dataset and scala example in documents
Browse files Browse the repository at this point in the history
  • Loading branch information
codenohup authored and reswqa committed Oct 3, 2024
1 parent 8931ce4 commit 2cac884
Show file tree
Hide file tree
Showing 15 changed files with 9 additions and 2,667 deletions.
4 changes: 2 additions & 2 deletions docs/content.zh/docs/concepts/overview.md
Original file line number Diff line number Diff line change
Expand Up @@ -41,10 +41,10 @@ Flink 为流式/批式处理应用程序的开发提供了不同级别的抽象

- Flink API 第二层抽象是 **Core APIs**。实际上,许多应用程序不需要使用到上述最底层抽象的 API,而是可以使用 **Core APIs** 进行编程:其中包含 [DataStream API]({{< ref "docs/dev/datastream/overview" >}})(应用于有界/无界数据流场景)。Core APIs 提供的流式 API(Fluent API)为数据处理提供了通用的模块组件,例如各种形式的用户自定义转换(transformations)、联接(joins)、聚合(aggregations)、窗口(windows)和状态(state)操作等。此层 API 中处理的数据类型在每种编程语言中都有其对应的类。

*Process Function* 这类底层抽象和 *DataStream API* 的相互集成使得用户可以选择使用更底层的抽象 API 来实现自己的需求。*DataSet API* 还额外提供了一些原语,比如循环/迭代(loop/iteration)操作。
*Process Function* 这类底层抽象和 *DataStream API* 的相互集成使得用户可以选择使用更底层的抽象 API 来实现自己的需求。

- Flink API 第三层抽象是 **Table API****Table API** 是以表(Table)为中心的声明式编程(DSL)API,例如在流式数据场景下,它可以表示一张正在动态改变的表。[Table API]({{< ref "docs/dev/table/overview" >}}) 遵循(扩展)关系模型:即表拥有 schema(类似于关系型数据库中的 schema),并且 Table API 也提供了类似于关系模型中的操作,比如 select、project、join、group-by 和 aggregate 等。Table API 程序是以声明的方式定义*应执行的逻辑操作*,而不是确切地指定程序*应该执行的代码*。尽管 Table API 使用起来很简洁并且可以由各种类型的用户自定义函数扩展功能,但还是比 Core API 的表达能力差。此外,Table API 程序在执行之前还会使用优化器中的优化规则对用户编写的表达式进行优化。

表和 *DataStream*/*DataSet* 可以进行无缝切换,Flink 允许用户在编写应用程序时将 *Table API**DataStream*/*DataSet* API 混合使用。
表和 *DataStream* 可以进行无缝切换,Flink 允许用户在编写应用程序时将 *Table API**DataStream API* 混合使用。

- Flink API 最顶层抽象是 **SQL**。这层抽象在语义和程序表达式上都类似于 *Table API*,但是其程序实现都是 SQL 查询表达式。[SQL]({{< ref "docs/dev/table/overview" >}}#sql) 抽象与 Table API 抽象之间的关联是非常紧密的,并且 SQL 查询语句可以在 *Table API* 中定义的表上执行。
3 changes: 1 addition & 2 deletions docs/content.zh/docs/dev/configuration/overview.md
Original file line number Diff line number Diff line change
Expand Up @@ -216,8 +216,7 @@ Flink提供了两大 API:[Datastream API]({{< ref "docs/dev/datastream/overvie

| 你要使用的 API | 你需要添加的依赖项 |
|-----------------------------------------------------------------------------------|-----------------------------------------------------|
| [DataStream]({{< ref "docs/dev/datastream/overview" >}}) | `flink-streaming-java` |
| [DataStream Scala 版]({{< ref "docs/dev/datastream/scala_api_extensions" >}}) | `flink-streaming-scala{{< scala_version >}}` |
| [DataStream]({{< ref "docs/dev/datastream/overview" >}}) | `flink-streaming-java` |
| [Table API]({{< ref "docs/dev/table/common" >}}) | `flink-table-api-java` |
| [Table API Scala 版]({{< ref "docs/dev/table/common" >}}) | `flink-table-api-scala{{< scala_version >}}` |
| [Table API + DataStream]({{< ref "docs/dev/table/data_stream_api" >}}) | `flink-table-api-java-bridge` |
Expand Down
Loading

0 comments on commit 2cac884

Please sign in to comment.