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

Class ProgressTrackingReiterator<T>

java.lang.Object

com.google.cloud.dataflow.sdk.util.common.ForwardingReiterator<T>

com.google.cloud.dataflow.sdk.util.common.worker.ProgressTrackingReiterator<T>

Type Parameters:

T - the type of the elements of this iterator

All Implemented Interfaces:

Reiterator<T>, Cloneable, Iterator<T>

public final class ProgressTrackingReiterator<T>
extends ForwardingReiterator<T>

Implements a Reiterator that uses a ProgressTracker to track how far it's gotten through some base Reiterator. ForwardingReiterator.copy() copies the ProgressTracker, allowing for an independent progress state.

Constructor Summary

Constructors

Constructor and Description
ProgressTrackingReiterator(Reiterator<T> base, ProgressTracker<T> tracker)

Method Summary

Modifier and Type	Method and Description
protected ProgressTrackingReiterator<T>	clone()
T	next()

Methods inherited from class com.google.cloud.dataflow.sdk.util.common.ForwardingReiterator

copy, hasNext, remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

ProgressTrackingReiterator

public ProgressTrackingReiterator(Reiterator<T> base,
                                  ProgressTracker<T> tracker)

Method Detail

next

public T next()

Specified by:

next in interface Iterator<T>

Overrides:

next in class ForwardingReiterator<T>

clone

protected ProgressTrackingReiterator<T> clone()

Overrides:

clone in class ForwardingReiterator<T>