pyspark.sql.streaming.DataStreamReader.table

DataStreamReader.table(tableName)[source]

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')