Observação
O acesso a essa página exige autorização. Você pode tentar entrar ou alterar diretórios.
O acesso a essa página exige autorização. Você pode tentar alterar os diretórios.
Retorna uma SimpleDataSourceStreamReader instância para ler dados.
Sintaxe
simpleStreamReader(schema: StructType)
Parâmetros
| Parâmetro | Tipo | Descrição |
|---|---|---|
schema |
TipoDeEstrutura | O esquema dos dados a serem lidos. |
Devoluções
SimpleDataSourceStreamReader
Uma instância de leitor para essa fonte de dados.
Observações
Um deles e streamReader() deve ser implementado para uma fonte de simpleStreamReader() dados de streaming legível. O Spark verifica se streamReader() é implementado primeiro e cria um DataSourceStreamReader para ler dados se sim.
simpleStreamReader() é invocado somente quando streamReader() não é implementado.