option(DataStreamWriter)

기본 데이터 원본에 대한 출력 옵션을 추가합니다.

문법

option(key, value)

매개 변수

매개 변수 유형 설명
key str 옵션 키입니다.
value str, int, float 또는 bool 옵션 값입니다.

Returns

DataStreamWriter

예제

df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>

일괄 처리당 3개의 행을 콘솔에 인쇄합니다.

import time
q = spark.readStream.format(
    "rate").option("rowsPerSecond", 10).load().writeStream.format(
        "console").option("numRows", 3).start()
time.sleep(3)
q.stop()