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