pyspark.sql.streaming.DataStreamReader.format

DataStreamReader.format(source)

Specifies the input data source format.

New in version 2.0.0.

Parameters:

sourcestr

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

Notes

This API is evolving.

Examples

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

pyspark.sql.streaming.DataStreamReader.csv pyspark.sql.streaming.DataStreamReader.json