tabela (DataStreamReader)

Define um DataFrame de transmissão em uma tabela. A fonte de dados correspondente à tabela deve suportar o modo transmissão.

Sintaxe

table(tableName)

Parâmetros

Parâmetro	Tipo	Descrição
tableName	str	Nome da tabela.

Parâmetro	Tipo	Descrição
tableName	str	Nome da tabela.

Devoluções

DataFrame

Exemplos

Carregue uma transmissão de dados de uma tabela:

Python

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