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

Class MapTaskExecutorFactory.ElementByteSizeObservableCoder<T>

java.lang.Object

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

All Implemented Interfaces:

ElementByteSizeObservable<T>

Enclosing class:

MapTaskExecutorFactory

public static class MapTaskExecutorFactory.ElementByteSizeObservableCoder<T>
extends Object
implements ElementByteSizeObservable<T>

Adapts a Coder to the ElementByteSizeObservable interface.

Constructor Summary

Constructors

Constructor and Description
ElementByteSizeObservableCoder(Coder<T> coder)

Method Summary

Modifier and Type	Method and Description
boolean	isRegisterByteSizeObserverCheap(T value) Returns whether ElementByteSizeObservable.registerByteSizeObserver(T, com.google.cloud.dataflow.sdk.util.common.ElementByteSizeObserver) is cheap enough to call for every element, that is, if this ElementByteSizeObservable can calculate the byte size of the element to be coded in roughly constant time (or lazily).
void	registerByteSizeObserver(T value, ElementByteSizeObserver observer) Notifies the ElementByteSizeObserver about the byte size of the encoded value using this ElementByteSizeObservable.

Methods inherited from class java.lang.Object

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

Constructor Detail

ElementByteSizeObservableCoder

public ElementByteSizeObservableCoder(Coder<T> coder)

Method Detail

isRegisterByteSizeObserverCheap

public boolean isRegisterByteSizeObserverCheap(T value)

Description copied from interface: ElementByteSizeObservable

Returns whether ElementByteSizeObservable.registerByteSizeObserver(T, com.google.cloud.dataflow.sdk.util.common.ElementByteSizeObserver) is cheap enough to call for every element, that is, if this ElementByteSizeObservable can calculate the byte size of the element to be coded in roughly constant time (or lazily).

Specified by:

isRegisterByteSizeObserverCheap in interface ElementByteSizeObservable<T>

registerByteSizeObserver

public void registerByteSizeObserver(T value,
                                     ElementByteSizeObserver observer)
                              throws Exception

Description copied from interface: ElementByteSizeObservable

Notifies the ElementByteSizeObserver about the byte size of the encoded value using this ElementByteSizeObservable.

Specified by:

registerByteSizeObserver in interface ElementByteSizeObservable<T>

Throws:

Exception