Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
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.