pyspark.sql.SQLContext.readStream#

property SQLContext.readStream#

Returns a DataStreamReader that can be used to read data streams as a streaming DataFrame.

Added in version 2.0.0.

Returns:

>>> text_sdf = sqlContext.readStream.text(tempfile.mkdtemp())
    ..

>>> text_sdf.isStreaming
    ..

Notes

This API is evolving.