回傳 SimpleDataSourceStreamReader 一個用於讀取資料的實例。
語法
simpleStreamReader(schema: StructType)
參數
| 參數 | 類型 | 說明 |
|---|---|---|
schema |
結構類型 | 要讀取的資料架構。 |
退貨
SimpleDataSourceStreamReader
此資料來源的讀取器實例。
Notes
其中之一 simpleStreamReader() 必須 streamReader() 實作以提供可讀的串流資料來源。 Spark 會先檢查是否 streamReader() 實作，若是則建立 DataSourceStreamReader 一個讀取資料。
simpleStreamReader() 只有在未實作時 streamReader() 才會被調用。