Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
Retourne une SimpleDataSourceStreamReader instance pour lire des données.
Syntaxe
simpleStreamReader(schema: StructType)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
schema |
Type de Structure | Schéma des données à lire. |
Retours
SimpleDataSourceStreamReader
Instance de lecteur pour cette source de données.
Remarques
L’une des sources simpleStreamReader() de streamReader() données de streaming lisibles doit être implémentée. Spark vérifie si streamReader() elle est implémentée en premier et crée une DataSourceStreamReader pour lire les données le cas échéant.
simpleStreamReader() est appelé uniquement lorsqu’il streamReader() n’est pas implémenté.