Skip to content

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:

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:

addAvgAndMaxToSensor

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

addAvgAndMaxToSensor...FIXME

addAvgAndMaxToSensor is used when:

Back to top