simpleStreamReader
Renvoie une instance SimpleDataSourceStreamReader pour la lecture des données.
Syntaxe
simpleStreamReader(schema: StructType)
parameter
parameter | Type | Description |
|---|---|---|
| StructType | Le schéma des données à lire. |
Renvoie
SimpleDataSourceStreamReader
Une instance de lecteur pour cette source de données.
Notes
L'un de simpleStreamReader() et streamReader() doit être implémenté pour une source de données de streaming lisible. Spark vérifie si streamReader() est implémenté en premier et crée un DataSourceStreamReader pour lire les données le cas échéant. simpleStreamReader() n'est invoquée que lorsque streamReader() n'est pas implémentée.