options(DataStreamWriter)

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

사용 가능한 옵션은 DataStreamWriter 옵션을 참조하세요.

문법

options(**options)

매개 변수

Returns

DataStreamWriter

예제

df = spark.readStream.format("rate").load()
df.writeStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamWriter object ...>

잘림 없이 일괄 처리당 3개 행 인쇄:

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