runId (StreamingQuery)

返回此查询的唯一 ID,该查询不会在重启时保留。 启动的每个查询(或从检查点重启)将有不同的 runId

退货

str

示例

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