Package org.apache.beam.sdk.testing
Class CoderProperties.TestElementByteSizeObserver
- java.lang.Object
-
- org.apache.beam.sdk.util.common.ElementByteSizeObserver
-
- org.apache.beam.sdk.testing.CoderProperties.TestElementByteSizeObserver
-
- All Implemented Interfaces:
java.util.Observer
- Enclosing class:
- CoderProperties
public static class CoderProperties.TestElementByteSizeObserver extends ElementByteSizeObserver
AnElementByteSizeObserver
that records the observed element sizes for testing purposes.
-
-
Constructor Summary
Constructors Constructor Description TestElementByteSizeObserver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getCount()
double
getMean()
long
getSum()
long
getSumAndReset()
protected void
reportElementSize(long elementByteSize)
Called to report element byte size.void
reset()
-
Methods inherited from class org.apache.beam.sdk.util.common.ElementByteSizeObserver
advance, getIsLazy, setLazy, setScalingFactor, update, update
-
-
-
-
Method Detail
-
reportElementSize
protected void reportElementSize(long elementByteSize)
Description copied from class:ElementByteSizeObserver
Called to report element byte size.- Specified by:
reportElementSize
in classElementByteSizeObserver
-
getMean
public double getMean()
-
getSum
public long getSum()
-
getCount
public long getCount()
-
reset
public void reset()
-
getSumAndReset
public long getSumAndReset()
-
-