table (DataStreamReader)

Definisce un dataframe di streaming in una tabella. L'origine dati corrispondente alla tabella deve supportare la modalità di streaming.

Sintassi

table(tableName)

Parametri

Restituzioni

DataFrame

Examples

Caricare un flusso di dati da una tabella:

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