流计算处理系统主要分为两种类型:原生流处理和微批处理。

原生流处理系统对每条抵达的记录进行实时处理,实现真正的逐条处理。

微批处理系统则将数据按照预设的时间间隔(通常为秒级)进行分批,然后以批量的方式进行处理。