Flink学习笔记(3) -- Flink API解析

1、Flink DataStreamAPI Ⅰ、DataStream API 之 Data Sources部分详解   source是程序的数据源输入,你可以通过StreamExecutionEnvironment.addSource(sourceFunction)来为你的程序添加一个source。   flink提供了大量的已经实现好的source方法,你也可以自定义source   通过实现s
相关文章
相关标签/搜索