org.apache.flink.streaming.connectors.kinesis.metrics

Class ShardMetricsReporter

java.lang.Object

org.apache.flink.streaming.connectors.kinesis.metrics.ShardMetricsReporter

@Internal
public class ShardMetricsReporter
extends Object

A container for ShardConsumers to report metric values.

Constructor Summary

Constructors

Constructor and Description
ShardMetricsReporter()

Method Summary

Modifier and Type	Method and Description
long	getAverageRecordSizeBytes()
double	getBytesPerRead()
double	getLoopFrequencyHz()
int	getMaxNumberOfRecordsPerFetch()
long	getMillisBehindLatest()
int	getNumberOfAggregatedRecords()
int	getNumberOfDeaggregatedRecords()
long	getRunLoopTimeNanos()
long	getSleepTimeMillis()
void	setAverageRecordSizeBytes(long averageRecordSizeBytes)
void	setBytesPerRead(double bytesPerRead)
void	setLoopFrequencyHz(double loopFrequencyHz)
void	setMaxNumberOfRecordsPerFetch(int maxNumberOfRecordsPerFetch)
void	setMillisBehindLatest(long millisBehindLatest)
void	setNumberOfAggregatedRecords(int numberOfAggregatedRecords)
void	setNumberOfDeaggregatedRecords(int numberOfDeaggregatedRecords)
void	setRunLoopTimeNanos(long runLoopTimeNanos)
void	setSleepTimeMillis(long sleepTimeMillis)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ShardMetricsReporter

public ShardMetricsReporter()

Method Detail

getMillisBehindLatest

public long getMillisBehindLatest()

setMillisBehindLatest

public void setMillisBehindLatest(long millisBehindLatest)

getLoopFrequencyHz

public double getLoopFrequencyHz()

setLoopFrequencyHz

public void setLoopFrequencyHz(double loopFrequencyHz)

getBytesPerRead

public double getBytesPerRead()

setBytesPerRead

public void setBytesPerRead(double bytesPerRead)

getRunLoopTimeNanos

public long getRunLoopTimeNanos()

setRunLoopTimeNanos

public void setRunLoopTimeNanos(long runLoopTimeNanos)

getAverageRecordSizeBytes

public long getAverageRecordSizeBytes()

setAverageRecordSizeBytes

public void setAverageRecordSizeBytes(long averageRecordSizeBytes)

getSleepTimeMillis

public long getSleepTimeMillis()

setSleepTimeMillis

public void setSleepTimeMillis(long sleepTimeMillis)

getNumberOfAggregatedRecords

public int getNumberOfAggregatedRecords()

setNumberOfAggregatedRecords

public void setNumberOfAggregatedRecords(int numberOfAggregatedRecords)

getNumberOfDeaggregatedRecords

public int getNumberOfDeaggregatedRecords()

setNumberOfDeaggregatedRecords

public void setNumberOfDeaggregatedRecords(int numberOfDeaggregatedRecords)

getMaxNumberOfRecordsPerFetch

public int getMaxNumberOfRecordsPerFetch()

setMaxNumberOfRecordsPerFetch

public void setMaxNumberOfRecordsPerFetch(int maxNumberOfRecordsPerFetch)