flink底层API:KeyedProcessFunction

KeyedSteam可以调用process方法, 该方法可以接受一个KeyedProcessFunction类型的参数. 

KeyedProcessFunction类型的上层父类是RichFunction, 对分流后每一个元素调用一次KeyedProcessFunction中的elementProcess方法，可以通过Context调用timeServier, 注册定时器, 获得当前水位线, 处理时间, 等信息.