로 시작할 start()수 있는 StreamingQuery의 이름을 지정합니다. 이 이름은 연결된 SparkSession에서 현재 활성 상태인 모든 쿼리 중에서 고유해야 합니다.
문법
queryName(queryName)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
queryName |
str | 쿼리의 고유 이름입니다. |
Returns
DataStreamWriter
예제
import time
df = spark.readStream.format("rate").load()
q = df.writeStream.queryName("streaming_query").format("console").start()
q.stop()
q.name
# 'streaming_query'