Skip to content

StreamingQueryProgress

StreamingQueryProgress is information about a single micro-batch (progress) of a StreamingQuery:

StreamingQueryProgress is created when StreamExecution is requested to finish a trigger.

Last and Recent Progresses

Use lastProgress property of a StreamingQuery to access the most recent StreamingQueryProgress update.

val sq: StreamingQuery = ...
sq.lastProgress

Use recentProgress property of a StreamingQuery to access the most recent StreamingQueryProgress updates.

val sq: StreamingQuery = ...
sq.recentProgress

StreamingQueryListener

Use StreamingQueryListener to be notified about StreamingQueryProgress updates while a streaming query is executed.


Last update: 2020-09-25