table (DataStreamReader)

Определяет кадр данных потоковой передачи в таблице. Источник данных, соответствующий таблице, должен поддерживать режим потоковой передачи.

Синтаксис

table(tableName)

Параметры

Параметр	Тип	Описание
tableName	str	Название таблицы.

Возвраты

DataFrame

Примеры

Загрузите поток данных из таблицы:

import tempfile
import time
_ = spark.sql("DROP TABLE IF EXISTS my_table")
with tempfile.TemporaryDirectory(prefix="table") as d:
    q1 = spark.readStream.format("rate").load().writeStream.toTable(
        "my_table", checkpointLocation=d)
    q2 = spark.readStream.table("my_table").writeStream.format("console").start()
    time.sleep(3)
    q1.stop()
    q2.stop()
    _ = spark.sql("DROP TABLE my_table")