water

Class Job.ProgressUpdate

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.Atomic<TAtomic<T>>

water.TAtomic<Job.Progress>

water.Job.ProgressUpdate

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, Freezable

Enclosing class:

Job<T extends Keyed>

public static class Job.ProgressUpdate
extends TAtomic<Job.Progress>

Helper class to atomically update the job progress in the DKV

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.DTask

DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall

Field Summary

Fields inherited from class water.Atomic

_key

Fields inherited from class water.DTask

_ex, _modifiesInputs

Constructor Summary

Constructors

Constructor and Description
Job.ProgressUpdate(long newwork, java.lang.String progress_msg)
Job.ProgressUpdate(java.lang.String progress_msg)

Method Summary

Methods

Modifier and Type	Method and Description
Job.Progress	atomic(Job.Progress old) Update progress with new work & message

Methods inherited from class water.TAtomic

atomic, onSuccess, onSuccess

Methods inherited from class water.Atomic

compute2, fork, invoke, priority

Methods inherited from class water.DTask

copyOver, dinvoke, getDException, hasException, logVerbose, onAck, onAckAck, setException

Methods inherited from class water.H2O.H2OCountedCompleter

clone, compute, frozenType, icer, nextThrPriority, onExceptionalCompletion, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON

Methods inherited from class jsr166y.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Constructor Detail

Job.ProgressUpdate

public Job.ProgressUpdate(long newwork,
                  java.lang.String progress_msg)

Job.ProgressUpdate

public Job.ProgressUpdate(java.lang.String progress_msg)

Method Detail

atomic

public Job.Progress atomic(Job.Progress old)

Update progress with new work & message

Specified by:

atomic in class TAtomic<Job.Progress>

Parameters:

old - The old value, it may be null. It is a defensive copy.

Returns:

The new value; if null if this atomic update no longer needs to be run