com.google.cloud.dataflow.sdk.runners.worker

Class MapTaskExecutorFactory.CoderSizeEstimator<T>

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.MapTaskExecutorFactory.CoderSizeEstimator<T>

All Implemented Interfaces:

PartialGroupByKeyOperation.SizeEstimator<T>

Enclosing class:

MapTaskExecutorFactory

public static class MapTaskExecutorFactory.CoderSizeEstimator<T>
extends Object
implements PartialGroupByKeyOperation.SizeEstimator<T>

Implements PGBKOp.SizeEstimator via Coder.

Constructor Summary

Constructors

Constructor and Description
CoderSizeEstimator(Coder<T> coder)

Method Summary

Modifier and Type	Method and Description
long	estimateSize(T value)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoderSizeEstimator

public CoderSizeEstimator(Coder<T> coder)

Method Detail

estimateSize

public long estimateSize(T value)
                  throws Exception

Specified by:

estimateSize in interface PartialGroupByKeyOperation.SizeEstimator<T>

Throws:

Exception