simpleStreamReader

Devolve uma SimpleDataSourceStreamReader instância para leitura de dados.

Sintaxe

simpleStreamReader(schema: StructType)

Parâmetros

Parâmetro Tipo Descrição
schema Tipo de estrutura O esquema dos dados a ler.

Devoluções

SimpleDataSourceStreamReader

Uma instância de leitor para esta fonte de dados.

Notes

Um dos simpleStreamReader() e streamReader() deve ser implementado para uma fonte de dados em streaming legível. O Spark verifica primeiro se streamReader() está implementado e cria um DataSourceStreamReader dado para leitura, caso sim. simpleStreamReader() só é invocado quando streamReader() não é implementado.