Skip to content

MetricsReporter

MetricsReporter is a Metrics Source for streaming queries.

MetricsReporter uses the last StreamingQueryProgress (of the StreamExecution) if available or simply defaults to a "zero" value.

Creating Instance

MetricsReporter takes the following to be created:

MetricsReporter is created for stream execution engines.

Gauges

inputRate-total

Reports inputRowsPerSecond (across all streaming sources)

processingRate-total

Reports processedRowsPerSecond (across all streaming sources)

latency

Reports triggerExecution duration of the last StreamingQueryProgress

eventTime-watermark

Reports watermark of the last StreamingQueryProgress

Format: yyyy-MM-dd'T'HH:mm:ss.SSS'Z'

states-rowsTotal

Reports the total of numRowsTotal of all StateOperatorProgresses of the last StreamingQueryProgress

states-usedBytes

Reports the total of memoryUsedBytes of all StateOperatorProgresses of the last StreamingQueryProgress


Last update: 2020-09-25