pyspark.sql.streaming.DataStreamReader.format

DataStreamReader.format(source)[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")

previous

pyspark.sql.streaming.DataStreamReader.csv

next

pyspark.sql.streaming.DataStreamReader.json