内置流式计算算子

计算的状态和流式处理中的状态是相对应的,流式处理可以分为无状态流处理和有状态流处理,计算也可以分为无状态计算和有状态计算。

无状态计算是指对输入数据的流式计算不会涉及到历史数据或历史状态,只与当前最新需要处理的这条数据有关。

有状态计算是指对输入数据的流式计算与其历史数据和历史状态有关,涉及到状态保存、增量计算优化、避免相同状态重复计算等问题。