1、Flink DataStreamAPI
Ⅰ、DataStream API 之 Data Sources部分详解
source是程序的数据源输入,你可以通过StreamExecutionEnvironment.addSource(sourceFunction)来为你的程序添加一个source。
flink提供了大量的已经实现好的source方法,你也可以自定义source
通过实现sourceFunction接口来自定义无并行度的source,或者你也可以通过实现ParallelSourceFunction 接口 or 继承RichParallelSourceFunction 来自定义有并行度的source。
Ⅱ、DataStream API 之 Transformations部分详解
Ⅲ、DataStream API之Data Sink部分详解
2、Flink DataSetAPI
Ⅰ、DataSet API之Data Sources部分详解
Ⅱ、DataSet API之Transformations部分详解
Ⅲ、DataSet API之Data sinks部分详解
3、Flink Table API & SQL
Flink针对流处理和批处理提供了相关的API-Table API和SQL。
注意:当前版本Table API和SQL功能尚未全部完成,官方正在积极开发中。
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/