赞
踩
目录
Flink中的事件时间(Event Time)和处理时间(Processing Time)有什么区别?
Flink中的窗口函数(Window Function)是什么?
Flink的DataStream API和Table API有何区别?
Flink支持哪些数据源(Source)和数据汇(Sink)?
Flink的UCR(Unbounded Continuous Rows)是什么?
Flink的广播变量(Broadcast Variable)是什么?
Flink中的流水线并行执行(Pipeline Parallelism)是什么?
Flink的前后台压力(Front and Back Pressure)是什么?
Flink中的时间特征(Time Characteristics)有哪些选项?
Flink如何处理事件时间(Event Time)处理中的乱序事件?
Flink的连续处理(Continuous Processing)和迭代处理(Iterative Processing)有何区别?
概念 | 定义 | 特点 |
---|---|---|
事件时间(Event Time) | 数据产生的时间,通常由数据源附加。 | 保证全局时间一致性,适合乱序事件和延迟数据的处理。 |
处理时间(Processing Time) | 数据被Flink处理的时间。 | 与事件实际产生时间不一定一致,受处理速度和系统性能影响。 |
概念 | 定义 | 作用 |
---|---|---|
水位线 | 表示事件时间的进度,用于处理乱序数据和延迟数据。 | 控制时间驱动的数据处理,允许系统知道何时可以处理某事件。 |
类型 | 定义 | 特点 |
---|---|---|
滚动窗口(Tumbling Window) | 固定大小的窗口,每个窗口不重叠。 | 简单,适用于每个事件只需要被计算一次的场景。 |
滑动窗口(Sliding Windowÿ |
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。