From 3cd52e46b20f8c632fdd26800ca6aecba82cd365 Mon Sep 17 00:00:00 2001 From: Vamsi-klu Date: Fri, 19 Jun 2026 20:43:04 +0000 Subject: [PATCH 1/2] [FLINK-23140][docs] Fix SourceFunction documentation link --- docs/content.zh/docs/dev/datastream/overview.md | 2 +- docs/content/docs/dev/datastream/overview.md | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/docs/content.zh/docs/dev/datastream/overview.md b/docs/content.zh/docs/dev/datastream/overview.md index fbca9cf0b89a1..e68537bc5563b 100644 --- a/docs/content.zh/docs/dev/datastream/overview.md +++ b/docs/content.zh/docs/dev/datastream/overview.md @@ -213,7 +213,7 @@ Data Sources {{< tabs "8104e62c-db79-40b0-8519-0063e9be791f" >}} {{< tab "Java" >}} -Source 是你的程序从中读取其输入的地方。你可以用 `StreamExecutionEnvironment.addSource(sourceFunction)` 将一个 source 关联到你的程序。Flink 自带了许多预先实现的 source functions，不过你仍然可以通过实现 `SourceFunction` 接口编写自定义的非并行 source，也可以通过实现 `ParallelSourceFunction` 接口或者继承 `RichParallelSourceFunction` 类编写自定义的并行 sources。 +Source 是你的程序从中读取其输入的地方。你可以用 `StreamExecutionEnvironment.addSource(sourceFunction)` 将一个 source 关联到你的程序。Flink 自带了许多预先实现的 source functions，不过你仍然可以通过实现 {{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/SourceFunction.java" name="SourceFunction" >}} 接口编写自定义的非并行 source，也可以通过实现 `ParallelSourceFunction` 接口或者继承 `RichParallelSourceFunction` 类编写自定义的并行 sources。 通过 `StreamExecutionEnvironment` 可以访问多种预定义的 stream source： diff --git a/docs/content/docs/dev/datastream/overview.md b/docs/content/docs/dev/datastream/overview.md index 8090804616e1c..4ec995197147d 100644 --- a/docs/content/docs/dev/datastream/overview.md +++ b/docs/content/docs/dev/datastream/overview.md @@ -261,7 +261,8 @@ Data Sources Sources are where your program reads its input from. You can attach a source to your program by using `StreamExecutionEnvironment.addSource(sourceFunction)`. Flink comes with a number of pre-implemented -source functions, but you can always write your own custom sources by implementing the `SourceFunction` +source functions, but you can always write your own custom sources by implementing the +{{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/SourceFunction.java" name="SourceFunction" >}} for non-parallel sources, or by implementing the `ParallelSourceFunction` interface or extending the `RichParallelSourceFunction` for parallel sources. From f0e62060900d8b84186349e7a77b5ee83712bb39 Mon Sep 17 00:00:00 2001 From: Ramachandra Nalam Date: Sat, 20 Jun 2026 12:51:57 -0700 Subject: [PATCH 2/2] [FLINK-23140][docs] Link legacy source function docs --- docs/content.zh/docs/dev/datastream/overview.md | 2 +- docs/content/docs/dev/datastream/overview.md | 7 +++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/docs/content.zh/docs/dev/datastream/overview.md b/docs/content.zh/docs/dev/datastream/overview.md index e68537bc5563b..5cd8ed24d0042 100644 --- a/docs/content.zh/docs/dev/datastream/overview.md +++ b/docs/content.zh/docs/dev/datastream/overview.md @@ -213,7 +213,7 @@ Data Sources {{< tabs "8104e62c-db79-40b0-8519-0063e9be791f" >}} {{< tab "Java" >}} -Source 是你的程序从中读取其输入的地方。你可以用 `StreamExecutionEnvironment.addSource(sourceFunction)` 将一个 source 关联到你的程序。Flink 自带了许多预先实现的 source functions，不过你仍然可以通过实现 {{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/SourceFunction.java" name="SourceFunction" >}} 接口编写自定义的非并行 source，也可以通过实现 `ParallelSourceFunction` 接口或者继承 `RichParallelSourceFunction` 类编写自定义的并行 sources。 +Source 是你的程序从中读取其输入的地方。你可以用 `StreamExecutionEnvironment.addSource(sourceFunction)` 将一个 source 关联到你的程序。Flink 自带了许多预先实现的 source functions，不过你仍然可以通过实现 {{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/SourceFunction.java" name="SourceFunction" >}} 接口编写自定义的非并行 source，也可以通过实现 {{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/ParallelSourceFunction.java" name="ParallelSourceFunction" >}} 接口或者继承 {{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/RichParallelSourceFunction.java" name="RichParallelSourceFunction" >}} 类编写自定义的并行 sources。 通过 `StreamExecutionEnvironment` 可以访问多种预定义的 stream source： diff --git a/docs/content/docs/dev/datastream/overview.md b/docs/content/docs/dev/datastream/overview.md index 4ec995197147d..744535b35f7b7 100644 --- a/docs/content/docs/dev/datastream/overview.md +++ b/docs/content/docs/dev/datastream/overview.md @@ -263,8 +263,11 @@ Sources are where your program reads its input from. You can attach a source to using `StreamExecutionEnvironment.addSource(sourceFunction)`. Flink comes with a number of pre-implemented source functions, but you can always write your own custom sources by implementing the {{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/SourceFunction.java" name="SourceFunction" >}} -for non-parallel sources, or by implementing the `ParallelSourceFunction` interface or extending the -`RichParallelSourceFunction` for parallel sources. +interface for non-parallel sources, or by implementing the +{{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/ParallelSourceFunction.java" name="ParallelSourceFunction" >}} +interface or extending the +{{< gh_link file="flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/RichParallelSourceFunction.java" name="RichParallelSourceFunction" >}} +class for parallel sources. There are several predefined stream sources accessible from the `StreamExecutionEnvironment`: