table(DataStreamReader)

테이블의 스트리밍 데이터 프레임을 정의합니다. 테이블에 해당하는 데이터 원본은 스트리밍 모드를 지원해야 합니다.

문법

table(tableName)

매개 변수

매개 변수	유형	설명
tableName	str	테이블 이름.

Returns

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