streamWriter

Returns a DataSourceStreamWriter instance for writing data into a streaming sink.

The implementation is required for writable streaming data sources.

Syntax

streamWriter(schema: StructType, overwrite: bool)

Parameters

Parameter	Type	Description
schema	StructType	The schema of the data to be written.
overwrite	bool	A flag indicating whether to overwrite existing data when writing the current microbatch.

Returns

DataSourceStreamWriter

A writer instance for writing data into a streaming sink.