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