返回将数据 DataSourceStreamWriter 写入流式处理接收器的实例。
可写流式处理数据源需要实现。
Syntax
streamWriter(schema: StructType, overwrite: bool)
参数
| 参数 | 类型 | Description |
|---|---|---|
schema |
StructType | 要写入的数据的架构。 |
overwrite |
布尔 | 一个标志,指示在写入当前微包时是否覆盖现有数据。 |
退货
DataSourceStreamWriter
用于将数据写入流式处理接收器的编写器实例。