Flink-*流和有界流

任何类型的数据都是作为事件流产生的。信用卡交易,传感器测量,机器日志或网站或移动应用程序上的用户交互,所有这些数据都作为流生成。

数据可以作为*或有界流处理。

1、*流有一个开始但没有定义的结束。它们不会在生成时终止并提供数据。必须持续处理*流,即必须在摄取事件后立即处理事件。无法等待所有输入数据到达,因为输入是*的,并且在任何时间点都不会完成。处理*数据通常要求以特定顺序(例如事件发生的顺序)摄取事件,以便能够推断结果完整性。

2、有界流具有定义的开始和结束。可以在执行任何计算之前通过摄取所有数据来处理有界流。处理有界流不需要有序摄取,因为可以始终对有界数据集进行排序。有界流的处理也称为批处理。