org.apache.beam.sdk.transforms.splittabledofn

Class RestrictionTracker.Progress

java.lang.Object

org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker.Progress

Enclosing class:

RestrictionTracker<RestrictionT,PositionT>

public abstract static class RestrictionTracker.Progress
extends java.lang.Object

A representation for the amount of known completed and remaining work. See RestrictionTracker.HasProgress.getProgress() for details.

Constructor Summary

Constructors

Constructor and Description
Progress()

Method Summary

Modifier and Type	Method and Description
static RestrictionTracker.Progress	from(double workCompleted, double workRemaining) A representation for the amount of known completed and remaining work.
abstract double	getWorkCompleted() The known amount of completed work.
abstract double	getWorkRemaining() The known amount of work remaining.

Methods inherited from class java.lang.Object

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

Constructor Detail

Progress

public Progress()

Method Detail

from

public static RestrictionTracker.Progress from(double workCompleted,
                                               double workRemaining)

A representation for the amount of known completed and remaining work. See RestrictionTracker.HasProgress.getProgress() for details.

Parameters:

workCompleted - Must be >= 0.

workRemaining - Must be >= 0.

getWorkCompleted

public abstract double getWorkCompleted()

The known amount of completed work.

getWorkRemaining

public abstract double getWorkRemaining()

The known amount of work remaining.