在spark结构化流处理中,输出模式有哪些?

提问者:帅平 问题分类:大数据

在spark结构化流处理中,输出模式有哪些?

1 个回答
命里最重要的人
命里最重要的人

在spark结构化流处理过程中,输出模式有:

1、complete
2、update
3、append

complete 输出模式意味着每次都要写入全部的结果表

update 输出模式写入从上批处理中已更改的行

append 输出模式仅写入新行

发布于:3个月前 (12-15)
走过的路
走过的路

备注:

1、complete不适用发送到kafka的场景。

2、complete和update输出模式适合有状态的流处理。

3、append适合无状态的流处理。

发布于:3个月前 (12-15)
我来回答