(7)Foreach详解
Foreach详解Foreach操作允许我们对输出数据做任何操作。使用该操作必须要实现ForeachWriter接口,该接口的方法会在每次触发有结果数据输出的时候调用。后面会给出详细的说明。这里先说一下注意事项。writer必须是可序列化的,因为他会被序列化然后发送到executor执行。 open,process,close这三个方法都会在executor端调用。 仅当open函数被...