streamWriter
Renvoie une instance DataSourceStreamWriter pour l'écriture de données dans un stockage de données en streaming.
L'implémentation est requise pour les sources de données de streaming accessibles en écriture.
Syntaxe
streamWriter(schema: StructType, overwrite: bool)
parameter
parameter | Type | Description |
|---|---|---|
| StructType | Le schéma des données à écrire. |
| booléen | Un indicateur spécifiant s'il faut remplacer les données existantes lors de l'écriture du microbatch actuel. |
Renvoie
DataSourceStreamWriter
Une instance d'écriture pour écrire des données dans un récepteur de streaming.