StructuredStreaming中的ForeachSink的用法(一)
Spark2.3中,StructuredStreaming目前支持的sink只有FileSink、KafkaSink、ConsoleSink、MemorySink和ForeachSink,如果有其他的需求我们只有通过ForeachSink自定义sink,这篇文件主要以写入到Redis和Mysql为例。 要使用ForeachSink自定义sink,必须实现ForeachWrite...