1 个回答
![命里最重要的人 命里最重要的人](https://www.80wz.com/zb_users/avatar/0.png)
在spark结构化流处理过程中,输出模式有:
complete 输出模式意味着每次都要写入全部的结果表
update 输出模式写入从上批处理中已更改的行
append 输出模式仅写入新行
1、complete
2、update
3、append
complete 输出模式意味着每次都要写入全部的结果表
update 输出模式写入从上批处理中已更改的行
append 输出模式仅写入新行
发布于:2年前 (2022-12-15) IP属地:四川省
![走过的路 走过的路](https://www.80wz.com/zb_users/avatar/0.png)
备注:
1、complete不适用发送到kafka的场景。
2、complete和update输出模式适合有状态的流处理。
3、append适合无状态的流处理。
1、complete不适用发送到kafka的场景。
2、complete和update输出模式适合有状态的流处理。
3、append适合无状态的流处理。
发布于:2年前 (2022-12-15) IP属地:四川省
我来回答
您需要 登录 后回答此问题!