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 of the window will not be considered anymore.
The bytes of the records will be estimated using the configured
|Constructor and Description
|Modifier and Type
|Method and Description
Returns the estimated throughput bytes for now.
Returns the estimated throughput bytes for a specified time.
Updates the estimator with the bytes of records.
public void update(com.google.cloud.Timestamp timeOfRecords, T element)
public double get()