simpleStreamReader

データ読み取り用のインスタンスSimpleDataSourceStreamReaderを返します。

構文

simpleStreamReader(schema: StructType)

パラメーター

パラメーター	Type	説明
schema	StructType	読み込むデータのスキーマ。

戻り値

SimpleDataSourceStreamReader

このデータソースのリーダーインスタンス。

注意

読み取り可能なストリーミングデータソースには、 simpleStreamReader()とstreamReader()のいずれかを実装する必要があります。Sparkは、まずstreamReader()が実装されているかどうかを確認し、実装されている場合はデータを読み取るためのDataSourceStreamReaderを作成します。simpleStreamReader()はstreamReader()が実装されていない場合にのみ呼び出されます。