pyspark.sql.streaming.DataStreamReader.format¶

DataStreamReader.format(source: str) → pyspark.sql.streaming.DataStreamReader [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