Merk
Tilgang til denne siden krever autorisasjon. Du kan prøve å logge på eller endre kataloger.
Tilgang til denne siden krever autorisasjon. Du kan prøve å endre kataloger.
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.