KeyedSteam可以调用process方法, 该方法可以接受一个KeyedProcessFunction类型的参数.
KeyedProcessFunction类型的上层父类是RichFunction, 对分流后每一个元素调用一次KeyedProcessFunction中的elementProcess方法，可以通过Context调用timeServier, 注册定时器, 获得当前水位线, 处理时间, 等信息.
flink底层API:KeyedProcessFunction
原文：https://www.cnblogs.com/bitbitbyte/p/13184124.html
