Lưu ý
Cần có ủy quyền mới truy nhập được vào trang này. Bạn có thể thử đăng nhập hoặc thay đổi thư mục.
Cần có ủy quyền mới truy nhập được vào trang này. Bạn có thể thử thay đổi thư mục.
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.