处理函数(process funtion)
处理函数位于底层,操作麻烦,但是使用更加灵活,是flink的“核武器”,轻易不用,但是一定行。
在处理函数中,我们直面的就是数据流中最基本的元素:数据事件(event)、状态 state
以及时间( time)。
https://blog.51cto.com/u_15349018/3698518
1 分类
8种不同的处理函数
每个处理函数使得的时候注意两个关键函数
1 processElement
必须
元素基本处理
2 onTimer()
非必须
就是设置定时器,然后触发操作
2 侧输出流( Side Output)
1 主流
collect
2 分流
处理函数的processElement或者onTimer中使用.output (outputTag,数据)
获取侧输出流
1 | Stream.getSideOutput(outputTag) |