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

Class ProgressTrackerGroup<T>

java.lang.Object

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

Type Parameters:

T - the type of elements being tracked

public abstract class ProgressTrackerGroup<T>
extends Object

Implements a group of linked ProgressTrackers that collectively track how far a processing loop has gotten through the elements it's processing. Individual ProgressTracker instances may be copied, capturing an independent view of the progress of the system; this turns out to be useful for some non-trivial processing loops. The furthest point reached by any ProgressTracker is the one reported.

This class is abstract. Its single extension point is report(T), which should be overriden to provide a function that handles the reporting of the supplied element, as appropriate.

Constructor Summary

Constructors

Constructor and Description
ProgressTrackerGroup()

Method Summary

Modifier and Type	Method and Description
protected abstract void	report(T element) Reports the indicated element.
ProgressTracker<T>	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProgressTrackerGroup

public ProgressTrackerGroup()

Method Detail

start

public final ProgressTracker<T> start()

report

protected abstract void report(T element)

Reports the indicated element.