pyspark.sql.streaming.DataStreamWriter.format

DataStreamWriter.format(source: str) → pyspark.sql.streaming.readwriter.DataStreamWriter

Specifies the underlying output data source.

Parameters
sourcestr

string, name of the data source, which for now can be ‘parquet’.

Notes

This API is evolving.

Examples

>>> writer = sdf.writeStream.format('json')