データを読み取るための SimpleDataSourceStreamReader インスタンスを返します。
構文
simpleStreamReader(schema: StructType)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
schema |
StructType | 読み取るデータのスキーマ。 |
返品
SimpleDataSourceStreamReader
このデータ ソースのリーダー インスタンス。
メモ
読み取り可能なストリーミング データ ソースには、 simpleStreamReader() と streamReader() のいずれかを実装する必要があります。 Spark は、 streamReader() が最初に実装されているかどうかを確認し、その場合はデータを読み取る DataSourceStreamReader を作成します。
simpleStreamReader() は、 streamReader() が実装されていない場合にのみ呼び出されます。