文章目录

持续批处理

实现方式
Trigger.ProcessingTime(时间间隔)
适用场景:流式数据的批处理作业,如果不设置,默认适用该类型,间隔为0,表示尽可能处理每一个批次的数据,即Trigger.ProcessingTime(0),如果无数据,处于阻塞状态,等待数据流入

一次性批处理

实现方式
Trigger.Once()
场景
非实时数据分析,执行完毕后程序退出,一般需要配合定时调度框架周期性启动程序,处理之前数据

连续处理

实现方式
Trigger.Continuous(CheckPoint间隔)
场景:
超低延迟处理数据

Logo
永洪数据分析社区

永洪科技，致力于打造全球领先的数据技术厂商，具备从数据应用方案咨询、BI、AIGC智能分析、数字孪生、数据资产、数据治理、数据实施的端到端大数据价值服务能力。

更多推荐

cover

物联网大数据时代：时序数据库选型深度指南，为何IoTDB脱颖而出？

avatar 永洪数据分析社区
cover

时序数据库选型指南：工业大数据场景下基于Apache IoTDB技术价值与实践路径

avatar 永洪数据分析社区
cover

统计与大数据分析与数学金融课程解析

avatar 永洪数据分析社区