TaskMetrics¶

recordLatenessSensor¶

Sensor recordLatenessSensor(
  String threadId,
  String taskId,
  StreamsMetricsImpl streamsMetrics)

recordLatenessSensor creates avg and max metric sensors (to measure record lateness) with the following:

Metric Name	Avg Description	Max Description	RecordingLevel
`record-lateness`	The observed average lateness of records in milliseconds, measured by comparing the record timestamp with the current stream time	The observed maximum lateness of records in milliseconds, measured by comparing the record timestamp with the current stream time	`DEBUG`

recordLatenessSensor is used when:

StreamTask is created (and creates a PartitionGroup)

avgAndMaxSensor¶

Sensor avgAndMaxSensor(
  String threadId,
  String taskId,
  String metricName,
  String descriptionOfAvg,
  String descriptionOfMax,
  RecordingLevel recordingLevel,
  StreamsMetricsImpl streamsMetrics,
  Sensor... parentSensors)

avgAndMaxSensor requests the given StreamsMetricsImpl to create a taskLevelSensor and a taskLevelTagMap.

avgAndMaxSensor addAvgAndMaxToSensor.

avgAndMaxSensor is used when:

TaskMetrics is requested for processLatency and recordLateness sensors

addAvgAndMaxToSensor¶

void addAvgAndMaxToSensor(
  Sensor sensor,
  String group,
  Map<String, String> tags,
  String operation,
  String descriptionOfAvg,
  String descriptionOfMax)

addAvgAndMaxToSensor...FIXME

addAvgAndMaxToSensor is used when:

StreamsMetricsImpl is requested to addLatencyRateTotalSensor and addAvgAndMinAndMaxToSensor
TaskMetrics is requested to avgAndMaxSensor and invocationRateAndCountAndAvgAndMaxLatencySensor
ThreadMetrics is requested to processLatencySensor, pollRecordsSensor, processRecordsSensor, invocationRateAndCountAndAvgAndMaxLatencySensor
StateStoreMetrics is requested to prefixScanSensor, sizeOrCountSensor, throughputAndLatencySensor