工作实践|flink window窗口函数 源码分析
概述:
流式数据处理中,很多操作要依赖于时间属性进行,因此时间属性也是流式引擎能够保证准确处理数据的基石,window提供了一种处理无界数据的一种手段。
window组件:
flink的windows包含了很多的组件: 例如出发器trigger,触发器上下文triggerContext,内部状态windowState。窗口分配器windowassigner,内部时间服务器internalTimerService。其中每个组件都是winows 完成功能不可缺失的一部分。具体每个组件的作用。
【工作实践|flink window窗口函数 源码分析】源码:todo 总结
推荐阅读
- 7.9号工作总结~司硕
- 高天天工作室|溧清的剧本4
- 如果你是一名工作乐之者,996的工作又算得了什么()
- 为什么985/211的学生能胜任工作获得老板的青睐。
- 不废话,代码实践带你掌握|不废话,代码实践带你掌握 强缓存、协商缓存!
- 2019-10-24工作感悟
- 高大上还是路边摊
- 六项精进20180530
- 疲困,却仍得继续
- 2018复盘-2019展望