Muistiinpano
Tämän sivun käyttö edellyttää valtuutusta. Voit yrittää kirjautua sisään tai vaihtaa hakemistoa.
Tämän sivun käyttö edellyttää valtuutusta. Voit yrittää vaihtaa hakemistoa.
Returns a SimpleDataSourceStreamReader instance for reading data.
Syntax
simpleStreamReader(schema: StructType)
Parameters
| Parameter | Type | Description |
|---|---|---|
schema |
StructType | The schema of the data to be read. |
Returns
SimpleDataSourceStreamReader
A reader instance for this data source.
Notes
One of simpleStreamReader() and streamReader() must be implemented for a readable streaming data source. Spark checks whether streamReader() is implemented first and creates a DataSourceStreamReader to read data if so. simpleStreamReader() is only invoked when streamReader() is not implemented.