处理函数(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，数据）

获取侧输出流

Stream.getSideOutput(outputTag)