id(StreamingQuery)

검사점 데이터에서 다시 시작하는 동안 유지되는 이 쿼리의 고유 ID를 반환합니다. ID는 쿼리가 처음으로 시작될 때 생성되며 검사점 데이터에서 다시 시작될 때마다 동일합니다. Spark 클러스터에서 동일한 ID가 활성 상태인 쿼리는 하나만 있을 수 있습니다.

Returns

str

예제

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.id
# '...'
sq.stop()