Flink 常用的 Source 和 Sink Connectors 介绍_flink sink connector

通过前面我们可以知道 Flink Job 的大致结构就是 Source ——> Transformation ——> Sink。

那么这个 Source 是什么意思呢？我们下面来看看。

Data Source 介绍

Data Source 是什么呢？就字面意思其实就可以知道：数据来源。

Flink 做为一款流式计算框架，它可用来做批处理，即处理静态的数据集、历史的数据集；也可以用来做流处理，即处理实时的数据流（做计算操作），然后将处理后的数据实时下发，只要数据源源不断过来，Flink 就能够一直计算下去。

Flink 中你可以使用 StreamExecutionEnvironment.addSource(sourceFunction) 来为你的程序添加数据来源。

Flink 已经提供了若干实现好了的 source function，当然你也可以通过实现 SourceFunction 来自定义非并行的 source 或者实现 ParallelSourceFunction 接口或者扩展 RichParallelSourceFunction 来自定义并行的 source。

那么常用的 Data Source 有哪些呢？

常用的 Data Source

StreamExecutionEnvironment 中可以使用以下这些已实现的 stream source。