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