20200603——Flink运行架构

Flink运行架构 flink程序结构 flink程序的基本构建是流和转换。底层无论是批处理还是流处理都当作是流处理。 source 数据源,flink在流处理和批处理上的source大概有4类，基于本地集合的source 基于文件的source 基于网络套接字的source 自定义的source。 自定义的source常见的有kafka，mq等，当然也可以定义自己的source transfor

>>阅读原文<<