com.google.cloud.dataflow.sdk.util.common

Class ElementByteSizeObservableIterator<V>

java.lang.Object

java.util.Observable

com.google.cloud.dataflow.sdk.util.common.ElementByteSizeObservableIterator<V>

Type Parameters:

V - value type

All Implemented Interfaces:

Iterator<V>

public abstract class ElementByteSizeObservableIterator<V>
extends Observable
implements Iterator<V>

An abstract class used for iterators that notify observers about size in bytes of their elements, as they are being iterated over. The subclasses need to implement the standard Iterator interface and call method notifyValueReturned() for each element read and/or iterated over.

Constructor Summary

Constructors

Constructor and Description
ElementByteSizeObservableIterator()

Method Summary

Modifier and Type	Method and Description
protected void	notifyValueReturned(long byteSize)

Methods inherited from class java.util.Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Constructor Detail

ElementByteSizeObservableIterator

public ElementByteSizeObservableIterator()

Method Detail

notifyValueReturned

protected final void notifyValueReturned(long byteSize)