【Spark】Structured Streaming之outputMode
我们学习了Structured Streaming之后知道outputMode有三种模式,如下????
那么这三种模式有什么区别呢?我大致总结了一下????
1.Append mode:
输出新增的行,默认模式。每次更新结果集时,只将新添加到结果集的结果行输出到接收器。仅支持添加到结果表中的行永远不会更改的查询。因此,此模式保证每行仅输出一次。例如,仅查询select,where,map,flatMap,filter,join等会支持追加模式。不支持聚合2.Complete mode:
所有内容都输出,每次触发后,整个结果表将输出到接收器。聚合查询支持此功能。仅适用于包含聚合操作的查询3.Update mode:
输出更新的行,每次更新结果集时,仅将被更新的结果行输出到接收器(自Spark 2.1.1起可用),不支持排序