pyspark.sql.streaming.DataStreamReader.table

DataStreamReader.table(tableName: str) → DataFrame

Define a Streaming DataFrame on a Table. The DataSource corresponding to the table should support streaming mode.

New in version 3.1.0.

Parameters

tableNamestr

string, for the name of the table.

Returns

DataFrame

Notes

This API is evolving.

Examples

>>> spark.readStream.table('input_table') 

pyspark.sql.streaming.DataStreamReader.schema pyspark.sql.streaming.DataStreamReader.text