streamWriter

返回将数据 DataSourceStreamWriter 写入流式处理接收器的实例。

可写流式处理数据源需要实现。

Syntax

streamWriter(schema: StructType, overwrite: bool)

参数

参数	类型	说明
schema	结构类型	要写入的数据的架构。
overwrite	布尔	一个标志，指示在写入当前微包时是否覆盖现有数据。

退货

DataSourceStreamWriter

用于将数据写入流式处理接收器的编写器实例。