天火燎原_e548

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

天火燎原_e548

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

天火燎原_e548

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

天火燎原_e548

1.概念 低阶API process function，越底层越丰富复杂，提供了对状态的管理中阶API DataStream API，一般都是使用这个高级API ...

天火燎原_e548

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

天火燎原_e548

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

天火燎原_e548

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

天火燎原_e548

1.git 下载源码 git clonehttps://github.com/apache/flink.git 公司目前使用的是1.5.0版本，所以切换到release-1....

天火燎原_e548

一.Flink Runtime 1.运行时架构 Client JobManager（master节点） TaskManager（Salve节点） 角色通信（Akka） 数据传...