runId (StreamingQuery)

Zwraca unikatowy identyfikator tego zapytania, który nie jest utrwalany podczas ponownych uruchomień. Każde uruchomione zapytanie (lub ponownie uruchomione z punktu kontrolnego) będzie miało inną runIdwartość .

Zwroty

str

Examples

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