simpleStreamReader

SimpleDataSourceStreamReader Возвращает экземпляр для чтения данных.

Синтаксис

simpleStreamReader(schema: StructType)

Параметры

Параметр	Тип	Описание
schema	ТипСтруктуры	Схема считываемых данных.

Возвраты

SimpleDataSourceStreamReader

Экземпляр средства чтения для этого источника данных.

Примечания

Одна из simpleStreamReader() них streamReader() должна быть реализована для удобочитаемого источника данных потоковой передачи. Spark проверяет, реализована ли streamReader() первая реализация и создает DataSourceStreamReader ли данные для чтения данных, если это так. simpleStreamReader() вызывается только в том случае, если streamReader() он не реализован.