@Internal public class ShardConsumerMetricsReporter extends Object
ShardConsumer
s to report metric values.Constructor and Description |
---|
ShardConsumerMetricsReporter(MetricGroup metricGroup) |
Modifier and Type | Method and Description |
---|---|
long |
getAverageRecordSizeBytes() |
long |
getMillisBehindLatest() |
int |
getNumberOfAggregatedRecords() |
int |
getNumberOfDeaggregatedRecords() |
void |
setAverageRecordSizeBytes(long averageRecordSizeBytes) |
void |
setMillisBehindLatest(long millisBehindLatest) |
void |
setNumberOfAggregatedRecords(int numberOfAggregatedRecords) |
void |
setNumberOfDeaggregatedRecords(int numberOfDeaggregatedRecords) |
void |
unregister() |
public ShardConsumerMetricsReporter(MetricGroup metricGroup)
public long getMillisBehindLatest()
public void setMillisBehindLatest(long millisBehindLatest)
public long getAverageRecordSizeBytes()
public void setAverageRecordSizeBytes(long averageRecordSizeBytes)
public int getNumberOfAggregatedRecords()
public void setNumberOfAggregatedRecords(int numberOfAggregatedRecords)
public int getNumberOfDeaggregatedRecords()
public void setNumberOfDeaggregatedRecords(int numberOfDeaggregatedRecords)
public void unregister()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.