SimpleDataSourceStreamReader 데이터를 읽기 위한 인스턴스를 반환합니다.
문법
simpleStreamReader(schema: StructType)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
schema |
구조형 타입 | 읽을 데이터의 스키마입니다. |
Returns
SimpleDataSourceStreamReader
이 데이터 원본에 대한 판독기 인스턴스입니다.
Notes
simpleStreamReader()
streamReader() 읽기 가능한 스트리밍 데이터 원본에 대해 구현해야 합니다. Spark는 먼저 구현되는지 여부를 streamReader() 확인하고 있는 경우 데이터를 읽을 수 있도록 만듭니다 DataSourceStreamReader .
simpleStreamReader() 는 구현되지 streamReader() 않은 경우에만 호출됩니다.