id （StreamingQuery）

返回此查询的唯一 ID，该 ID 在检查点数据重启时保留。 首次启动查询时会生成 ID，每次从检查点数据重启查询时都相同。 Spark 群集中只能有一个具有相同 ID 的查询。

退货

str

示例

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