options(DataStreamReader)

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

문법

options(**options)

매개 변수

매개 변수	유형	설명
**options	사전	옵션의 키-값 쌍입니다.

Returns

DataStreamReader

예제

spark.readStream.options(x="1", y=2)
# <...streaming.readwriter.DataStreamReader object ...>

옵션을 사전으로 지정합니다.

spark.readStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamReader object ...>

속도 원본을 사용하여 10개의 파티션으로 초당 10개의 행을 생성합니다.

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