table (DataStreamReader)

Définit un DataFrame de streaming sur une table. La source de données correspondant à la table doit prendre en charge le mode streaming.

Syntaxe

table(tableName)

parameter

parameter	Type	Description
tableName	str	Nom de la table.

parameter	Type	Description
tableName	str	Nom de la table.

Renvoie

DataFrame

Exemples

Chargez un data Stream à partir d'une table :

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