Streamwriter

Retourne une instance permettant d’écrire DataSourceStreamWriter des données dans un récepteur de streaming.

L’implémentation est requise pour les sources de données de diffusion en continu accessibles en écriture.

Syntaxe

streamWriter(schema: StructType, overwrite: bool)

Paramètres

Paramètre Type Description
schema Type de Structure Schéma des données à écrire.
overwrite bool Indicateur indiquant s’il faut remplacer les données existantes lors de l’écriture du microbatch actuel.

Retours

DataSourceStreamWriter

Instance d’enregistreur pour l’écriture de données dans un récepteur de streaming.