simpleStreamReader

Devuelve una SimpleDataSourceStreamReader instancia de para leer datos.

Sintaxis

simpleStreamReader(schema: StructType)

Parámetros

Parámetro	Tipo	Descripción
schema	StructType	Esquema de los datos que se van a leer.

Devoluciones

SimpleDataSourceStreamReader

Una instancia de lector para este origen de datos.

Notas

Uno de y simpleStreamReader() debe implementarse para un origen de datos de streamReader() streaming legible. Spark comprueba si streamReader() se implementa primero y crea un DataSourceStreamReader para leer datos si es así. simpleStreamReader() solo se invoca cuando streamReader() no se implementa.