Package org.apache.beam.sdk.util.common
Class ElementByteSizeObservableIterator<V>
- java.lang.Object
-
- java.util.Observable
-
- org.apache.beam.sdk.util.common.ElementByteSizeObservableIterator<V>
-
- Type Parameters:
V
- value type
- All Implemented Interfaces:
java.util.Iterator<V>
@Internal public abstract class ElementByteSizeObservableIterator<V> extends java.util.Observable implements java.util.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 Description ElementByteSizeObservableIterator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
notifyValueReturned(long byteSize)
-
Methods inherited from class java.util.Observable
addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged
-
-