기본 데이터 원본에 대한 출력 옵션을 추가합니다.
사용 가능한 옵션은 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()