pyspark.sql.streaming.DataStreamReader.format

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

Specifies the input data source format.

Parameters
sourcestr

name of the data source, e.g. ‘json’, ‘parquet’.

Notes

This API is evolving.

Examples

>>> s = spark.readStream.format("text")