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:

Observer

Enclosing class:

CoderProperties

public static class CoderProperties.TestElementByteSizeObserver
extends org.apache.beam.sdk.util.common.ElementByteSizeObserver

An ElementByteSizeObserver that records the observed element sizes for testing purposes.

Constructor Summary

Constructors

Constructor	Description
TestElementByteSizeObserver()

Method Summary

Modifier and Type	Method	Description
long	getCount()
double	getMean()
long	getSum()
long	getSumAndReset()
protected void	reportElementSize(long elementByteSize)
void	reset()

Methods inherited from class org.apache.beam.sdk.util.common.ElementByteSizeObserver

advance, getIsLazy, setLazy, setScalingFactor, update, update

Methods inherited from class java.lang.Object

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

Constructor Details

TestElementByteSizeObserver

public TestElementByteSizeObserver()

Method Details

reportElementSize

protected void reportElementSize(long elementByteSize)

Specified by:

reportElementSize in class org.apache.beam.sdk.util.common.ElementByteSizeObserver

getMean

public double getMean()

getSum

public long getSum()

getCount

public long getCount()

reset

public void reset()

getSumAndReset

public long getSumAndReset()