@Internal public class BytesThroughputEstimator<T> extends java.lang.Object implements ThroughputEstimator<T>
This estimator will keep track of the bytes of reported records within a sliding window. The
window consists of the configured number of seconds and each record's bytes will fall into
exactly one given second bucket. When more than window size seconds have passed from the current
time, the bytes reported for the seconds that fall outside of the window will not be considered
anymore. The bytes of the records will be estimated using the configured Coder
.
The estimator will sample only 2% of records to save the cost of doing sizeEstimation for every element
Constructor and Description |
---|
BytesThroughputEstimator(int windowSizeSeconds,
SizeEstimator<T> sizeEstimator) |
BytesThroughputEstimator(int windowSizeSeconds,
SizeEstimator<T> sizeEstimator,
int sampleRate) |
Modifier and Type | Method and Description |
---|---|
double |
get()
Returns the estimated throughput bytes for now.
|
double |
getFrom(Instant time)
Returns the estimated throughput bytes for a specified time.
|
void |
update(Instant timeOfRecords,
T element)
Updates the estimator with the bytes of records if it is selected to be sampled.
|
public BytesThroughputEstimator(int windowSizeSeconds, SizeEstimator<T> sizeEstimator)
public BytesThroughputEstimator(int windowSizeSeconds, SizeEstimator<T> sizeEstimator, int sampleRate)
public void update(Instant timeOfRecords, T element)
update
in interface ThroughputEstimator<T>
timeOfRecords
- the committed timestamp of the recordselement
- the element to estimate the byte size ofpublic double get()
get
in interface ThroughputEstimator<T>
public double getFrom(Instant time)
getFrom
in interface ThroughputEstimator<T>
time
- the specified timestamp to check throughput