ストリームライター
ストリーミングシンクにデータを書き込むためのDataSourceStreamWriterインスタンスを返します。
書き込み可能なストリーミングデータソースには、この実装が必要です。
構文
streamWriter(schema: StructType, overwrite: bool)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| StructType | 書き込むデータのスキーマ。 |
| bool | 現在のマイクロバッチを書き込む際に、既存のデータを上書きするかどうかを示すフラグ。 |
戻り値
DataSourceStreamWriter
ストリーミングシンクにデータを書き込むためのライターインスタンス。