Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Restituisce un'istanza DataSourceStreamWriter per la scrittura di dati in un sink di streaming.
L'implementazione è necessaria per le origini dati di streaming scrivibili.
Sintassi
streamWriter(schema: StructType, overwrite: bool)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
schema |
StructType (tipo di struttura) | Schema dei dati da scrivere. |
overwrite |
bool | Flag che indica se sovrascrivere i dati esistenti durante la scrittura del microbatch corrente. |
Restituzioni
DataSourceStreamWriter
Istanza del writer per la scrittura di dati in un sink di streaming.