Nóta
Teastaíonn údarú chun rochtain a fháil ar an leathanach seo. Is féidir leat triail a bhaint as shíniú isteach nó eolairí a athrú.
Teastaíonn údarú chun rochtain a fháil ar an leathanach seo. Is féidir leat triail a bhaint as eolairí a athrú.
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.