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)
我来回答
您需要 登录 后回答此问题!