simpleStreamReader

Retorna uma instância SimpleDataSourceStreamReader para leitura de dados.

Sintaxe

simpleStreamReader(schema: StructType)

Parâmetros

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

Devoluções

SimpleDataSourceStreamReader

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

Notas

Um de simpleStreamReader() e streamReader() deve ser implementado para uma transmissão de dados legível. O Spark verifica primeiro se streamReader() está implementado e cria um DataSourceStreamReader para ler os dados, se estiver. simpleStreamReader() só é invocado quando streamReader() não é implementado.