一.理解状态 1.什么是状态 其实是某一个时刻，计算的结果，一般是operator/task，保存在内存，由于Flink分布式的运行，所以根据体...

1.Connector是什么 2.Connector渠道 3.基于文件的预定义Source 4.基于Socket的预定于Source 5.基于E...

1.什么是异步IO ，当请求外部系统或者耗时操作，需要异步IO 2.AsyncDataStream 3.实现原理 有序 processing t...

1.概念 低阶API process function，越底层越丰富复杂，提供了对状态的管理中阶API DataStream API，...

1.join对比 cogroup相等于 left join,join 相等于 inner join，connect可以不不相关的2个流连接起来i...

一.Time 1.DataStream支持3种Time env.setStreamTimeCharacteristic(TimeCharacte...

DataStream是Flink API中最核心的数据结构，代表一个运行在多个分区上的并行流。 1.map&flatMap 2.filter 3...

1.git 下载源码 git clonehttps://github.com/apache/flink.git 公司目前使用的是1.5.0版本，...