酷炫金毛

文章
7
资源
0
加入时间
2年10月17天

StructuredStreaming中的ForeachSink的用法(一)

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