water

Class Job

java.lang.Object

water.Iced

water.api.Constants

water.api.RequestStatics

water.api.RequestArguments

water.api.RequestQueries

water.api.RequestBuilders

water.api.Request

water.Request2

water.Func

water.Job

All Implemented Interfaces:

java.lang.Cloneable, Freezable

Direct Known Subclasses:

GLM2.GLMGridSearch, GridSearch, Job.ChunkProgressJob, Job.FrameJob, Job.JobHandle, ParseDataset2

public abstract class Job
extends Func

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Job.ChunkProgress
static class	Job.ChunkProgressJob
static class	Job.ColumnsJob A job which has an input represented by a frame and frame column filter.
static class	Job.ColumnsResJob A columns job that requires a response.
static class	Job.Fail
static class	Job.FrameJob A job which operates with a frame.
static class	Job.JobCancelledException
static class	Job.JobHandle Almost lightweight job handle containing the same content as pure Job class.
static class	Job.JobState Possible job states.
static class	Job.List
static class	Job.ModelJob A job producing a model.
static class	Job.ModelJobWithoutClassificationField A job producing a model that has no notion of Classification or Regression.
static interface	Job.Progress
static interface	Job.ProgressMonitor
static class	Job.ValidatedJob Job which produces model and validate it on a given dataset.

Nested classes/interfaces inherited from class water.Request2

Request2.ColumnSelect, Request2.Dependent, Request2.DoClassBoolean, Request2.DRFCopyDataBoolean, Request2.MultiVecSelect, Request2.MultiVecSelectType, Request2.TypeaheadKey, Request2.VecClassSelect, Request2.VecSelect

Nested classes/interfaces inherited from class water.api.Request

Request.API, Request.Default, Request.Filter, Request.Validator<V>

Nested classes/interfaces inherited from class water.api.RequestBuilders

RequestBuilders.ArrayBuilder, RequestBuilders.ArrayHeaderRowBuilder, RequestBuilders.ArrayRowBuilder, RequestBuilders.ArrayRowElementBuilder, RequestBuilders.ArrayRowSingleColBuilder, RequestBuilders.BooleanStringBuilder, RequestBuilders.Builder, RequestBuilders.ElementBuilder, RequestBuilders.HideBuilder, RequestBuilders.KeyCellBuilder, RequestBuilders.KeyElementBuilder, RequestBuilders.KeyLinkElementBuilder, RequestBuilders.KeyMinAvgMaxBuilder, RequestBuilders.NoCaptionObjectBuilder, RequestBuilders.ObjectBuilder, RequestBuilders.PaginatedTable, RequestBuilders.PreFormattedBuilder, RequestBuilders.Response, RequestBuilders.ResponseInfo, RequestBuilders.WarningCellBuilder

Nested classes/interfaces inherited from class water.api.RequestArguments

RequestArguments.Argument<T>, RequestArguments.Bool, RequestArguments.ClassifyBool, RequestArguments.DRFCopyDataBool, RequestArguments.EnumArgument<T extends java.lang.Enum<T>>, RequestArguments.ExistingFile, RequestArguments.FrameClassVec, RequestArguments.FrameKeyMultiVec, RequestArguments.FrameKeyVec, RequestArguments.GeneralFile, RequestArguments.H2OExistingKey, RequestArguments.H2OIllegalArgumentException, RequestArguments.H2OKey, RequestArguments.H2OKey2, RequestArguments.InputCheckBox, RequestArguments.InputSelect<T>, RequestArguments.InputText<T>, RequestArguments.Int, RequestArguments.LongInt, RequestArguments.MultipleSelect<T>, RequestArguments.MultipleText<T>, RequestArguments.NumberSequence, RequestArguments.NumberSequenceFloat, RequestArguments.Real, RequestArguments.Record<T>, RequestArguments.RSeq, RequestArguments.RSeqFloat, RequestArguments.Str, RequestArguments.StringList, RequestArguments.TypeaheadInputText<T>

Nested classes/interfaces inherited from class water.api.RequestStatics

RequestStatics.RequestType

Nested classes/interfaces inherited from class water.api.Constants

Constants.Extensions, Constants.Schemes, Constants.Suffixes

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	_cv
H2O.H2OCountedCompleter	_fjtask
java.lang.String	description
Key	destination_key
static DocGen.FieldDoc[]	DOC_FIELDS
long	end_time
java.lang.String	exception
Key	job_key
static Key	LIST A system key for global list of Job keys.
long	start_time
Job.JobState	state

Fields inherited from class water.Request2

_parms, response_info

Fields inherited from class water.api.Request

_requestHelp, SUPPORTS_ONLY_V1, SUPPORTS_ONLY_V2, SUPPORTS_V1_V2

Fields inherited from class water.api.RequestBuilders

ARRAY_BUILDER, ARRAY_HEADER_ROW_BUILDER, ARRAY_ROW_BUILDER, ARRAY_ROW_ELEMENT_BUILDER, ARRAY_ROW_SINGLECOL_BUILDER, ELEMENT_BUILDER, GSON_BUILDER, OBJECT_BUILDER, ROOT_OBJECT

Fields inherited from class water.api.RequestQueries

_queryHtml

Fields inherited from class water.api.RequestArguments

_arguments

Fields inherited from class water.api.Constants

ALPHA, ARGUMENTS, AUC, BASE, BEST_THRESHOLD, BETA_EPS, BIN_LIMIT, BROWSE, BUCKET, BUILT_IN_KEY_JOBS, CANCELLED, CARDINALITY, CASE, CASE_MODE, CHUNK, CLASS, CLOUD_HEALTH, CLOUD_NAME, CLOUD_SIZE, CLOUD_UPTIME_MILLIS, CLUSTERS, COEFFICIENTS, COL_INDEX, COLS, COLUMN_NAME, COLUMNS_DISPLAY, CONSENSUS, CONTENTS, COUNT, DATA_KEY, DEPTH, DESCRIPTION, DEST_KEY, DTHRESHOLDS, ELAPSED, END_TIME, ENUM_DOMAIN_SIZE, ERROR, ESCAPE_NAN, EXCLUSIVE_SPLIT_LIMIT, EXPRESSION, FAILED, FAMILY, FEATURES, FILE, FILES, FILTER, FIRST_CHUNK, FJ_QUEUE_HI, FJ_QUEUE_LO, FJ_THREADS_HI, FJ_THREADS_LO, FREE_DISK, FREE_MEM, GFLOPS, HEADER, HEIGHT, HELP, IGNORE, ITEMS, ITERATIVE_CM, JOB, JOB_KEY, JOBS, JSON_H2O, KEY, KEYS, LAMBDA, LAST_CONTACT, LIMIT, LINK, LOCKED, MAX, MAX_DISK, MAX_ITER, MAX_MEM, MAX_ROWS, MEAN, MEM_BW, MIN, MODEL_KEY, MODELS, MORE, MTRY, MTRY_NODES, NAME, NEG_X, NO_CM, NODE, NODE_HEALTH, NODE_NAME, NODES, NORMALIZE, NUM_COLS, NUM_CPUS, NUM_FAILED, NUM_KEYS, NUM_MISSING_VALUES, NUM_ROWS, NUM_SUCCEEDED, NUM_TREES, OBJECT, OFFSET, OOBEE, PARALLEL, PARSER_TYPE, PATH, PREVIEW, PREVIOUS_MODEL_KEY, PRIOR, PROGRESS, PROGRESS_KEY, PROGRESS_TOTAL, REDIRECT, REDIRECT_ARGS, REPLICATION_FACTOR, REQUEST_TIME, RESPONSE, RHO, ROW, ROW_SIZE, ROWS, RPCS, SAMPLE, SAMPLING_STRATEGY, SCALE, SEED, SENT_ROWS, SEPARATOR, SIZE, SOURCE_KEY, STACK_TRACES, START_TIME, STAT_TYPE, STATUS, STEP, STRATA_SAMPLES, SUCCEEDED, SYSTEM_LOAD, TASK_KEY, TCPS_ACTIVE, TCPS_DUTY, TIME, TO_ENUM, TOT_MEM, TREE_COUNT, TREE_DEPTH, TREE_LEAVES, TREE_NUM, TREES, TWEEDIE_POWER, TYPE, URL, USE_NON_LOCAL_DATA, VALUE, VALUE_SIZE, VALUE_TYPE, VARIANCE, VERSION, VIEW, WARNINGS, WEIGHT, WEIGHTS, WIDTH, X, XVAL, Y

Constructor Summary

Constructors

Constructor and Description
Job()
Job(Key jobKey, Key dstKey)

Method Summary

Methods

Modifier and Type	Method and Description
static Job[]	all() Returns a list of all jobs in a system.
void	cancel() Signal cancellation of this job.
void	cancel(java.lang.String msg) Signal exceptional cancellation of this job.
void	cancel(java.lang.Throwable ex) Signal exceptional cancellation of this job.
static boolean	checkIdx(Frame source, int[] idx)
protected Key	defaultDestKey()
protected Key	defaultJobKey()
Key	dest()
static Job	findJob(Key jobkey) Finds a job with given key or returns null.
static Job	findJobByDest(Key destKey) Finds a job with given dest key or returns null
Job	fork() Forks computation of this job.
<T> T	get() Blocks and get result of this job.
Job.JobState	getState()
int	gridParallelism()
static <T extends Job.FrameJob> T	hygiene(T job) Hygienic method to prevent accidental capture of non desired values.
static <T extends Job.ValidatedJob> T	hygiene(T job)
protected void	init() Invoked before job runs.
void	invoke() Invoke this function in blocking way.
boolean	isCancelledOrCrashed() Returns true if the job was cancelled by the user or crashed.
boolean	isCrashed() Returns true if the job was terminated by unexpected exception.
boolean	isDone() Returns true if this job is correctly finished.
static boolean	isEnded(Key jobkey) Returns true if job is not running.
boolean	isRunning() Returns true if this job is running
static boolean	isRunning(Key job_key) Check if given job is running.
protected void	onCancelled() Callback which is called after job cancellation (by user, by exception).
float	progress() Return progress of this job.
protected RequestBuilders.Response	redirect()
void	remove() Marks job as finished and records job end time.
long	runTimeMs() Returns job execution time in milliseconds.
Key	self()
protected RequestBuilders.Response	serve() Implements UI call.
java.lang.String	speedDescription() Description of a speed criteria: msecs/frob
long	speedValue() Value of the described speed criteria: msecs/frob
Job	start(H2O.H2OCountedCompleter fjtask) Start this task based on given top-level fork-join task representing job computation.
static void	waitUntilJobEnded(Key jobkey) Block synchronously waiting for a job to end, success or not.
static void	waitUntilJobEnded(Key jobkey, int pollingIntervalMillis) Block synchronously waiting for a job to end, success or not.

Methods inherited from class water.Func

cleanup, emptyLTrash, exec, execImpl, gtrash, gtrash, ltrash, ltrash

Methods inherited from class water.Request2

create, fillResponseInfo, filterNaCols, input, logStart, makeJsonBox, registered, serveGrid, servePublic, set, split, superServeGrid, supportedVersions, toJSON, toJSON, toString

Methods inherited from class water.api.Request

addToNavbar, addToNavbar, addToNavbar, DocExampleFail, DocExampleSucc, href, href, hrefType, HTMLHelp, htmlTemplate, initializeNavBar, log, mapTypeahead, ReSTHelp, serve, serveJava, serveResponse, toDocGET, toHTML, toJava, wrap, wrap, wrap, writeJSONFields

Methods inherited from class water.api.RequestBuilders

build, buildJSONResponseBox, buildResponseHeader, name

Methods inherited from class water.api.RequestQueries

buildQuery, checkArguments, queryArgumentValueSet

Methods inherited from class water.api.RequestArguments

arguments, argumentsToJson, frameColumnNameToIndex

Methods inherited from class water.api.RequestStatics

checkJsonName, encodeRedirectArgs, JSON2HTML, jsonError, requestName, Str2JSON

Methods inherited from class water.Iced

clone, frozenType, init, newInstance, read, toDocField, write, writeJSON

Methods inherited from class java.lang.Object

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

Field Detail

DOC_FIELDS

public static DocGen.FieldDoc[] DOC_FIELDS

LIST

public static final Key LIST

A system key for global list of Job keys.

job_key

@Request.API(help="Job key")
public Key job_key

destination_key

@Request.API(help="Destination key",
             filter=Request.Default.class,
             json=true,
             validator=water.Job.DestKeyValidator.class)
public Key destination_key

description

@Request.API(help="Job description")
public java.lang.String description

start_time

@Request.API(help="Job start time")
public long start_time

end_time

@Request.API(help="Job end time")
public long end_time

exception

@Request.API(help="Exception")
public java.lang.String exception

state

@Request.API(help="Job state")
public Job.JobState state

_fjtask

public transient H2O.H2OCountedCompleter _fjtask

_cv

protected transient boolean _cv

Constructor Detail

Job

public Job(Key jobKey,
   Key dstKey)

Job

public Job()

Method Detail

self

public Key self()

dest

public Key dest()

gridParallelism

public int gridParallelism()

defaultJobKey

protected Key defaultJobKey()

defaultDestKey

protected Key defaultDestKey()

start

public Job start(H2O.H2OCountedCompleter fjtask)

Start this task based on given top-level fork-join task representing job computation.

Parameters:

fjtask - top-level job computation task.

Returns:

this job in Job.JobState.RUNNING state

See Also:

Job.JobState, H2O.H2OCountedCompleter

progress

public float progress()

Return progress of this job.

Returns:

the value in interval <0,1> representing job progress.

get

public <T> T get()

Blocks and get result of this job.

The call blocks on working task which was passed via #start(H2OCountedCompleter) method and returns the result which is fetched from UKV based on job destination key.

Returns:

result of this job fetched from UKV by destination key.

See Also:

#start(H2OCountedCompleter), UKV

cancel

public void cancel()

Signal cancellation of this job.

The job will be switched to state Job.JobState.CANCELLED which signals that the job was cancelled by a user.

cancel

public void cancel(java.lang.Throwable ex)

Signal exceptional cancellation of this job.

Parameters:

ex - exception causing the termination of job.

cancel

public void cancel(java.lang.String msg)

Signal exceptional cancellation of this job.

Parameters:

msg - cancellation message explaining reason for cancelation

onCancelled

protected void onCancelled()

Callback which is called after job cancellation (by user, by exception).

isCancelledOrCrashed

public boolean isCancelledOrCrashed()

Returns true if the job was cancelled by the user or crashed.

Returns:

true if the job is in state Job.JobState.CANCELLED or Job.JobState.FAILED

isCrashed

public boolean isCrashed()

Returns true if the job was terminated by unexpected exception.

Returns:

true, if the job was terminated by unexpected exception.

isDone

public boolean isDone()

Returns true if this job is correctly finished.

Returns:

returns true if the job finished and it was not cancelled or crashed by an exception.

isRunning

public boolean isRunning()

Returns true if this job is running

Returns:

returns true only if this job is in running state.

getState

public Job.JobState getState()

all

public static Job[] all()

Returns a list of all jobs in a system.

Returns:

list of all jobs including running, done, cancelled, crashed jobs.

isRunning

public static boolean isRunning(Key job_key)

Check if given job is running.

Parameters:

job_key - job key

Returns:

true if job is still running else returns false.

isEnded

public static boolean isEnded(Key jobkey)

Returns true if job is not running. The job can be cancelled, crashed, or already done.

Parameters:

jobkey - job identification key

Returns:

true if job is done, cancelled, or crashed, else false

remove

public void remove()

Marks job as finished and records job end time.

findJob

public static Job findJob(Key jobkey)

Finds a job with given key or returns null.

Parameters:

jobkey - job key

Returns:

returns a job with given job key or null if a job is not found.

findJobByDest

public static Job findJobByDest(Key destKey)

Finds a job with given dest key or returns null

runTimeMs

public final long runTimeMs()

Returns job execution time in milliseconds. If job is not running then returns job execution time.

speedDescription

public java.lang.String speedDescription()

Description of a speed criteria: msecs/frob

speedValue

public long speedValue()

Value of the described speed criteria: msecs/frob

serve

protected RequestBuilders.Response serve()

Description copied from class: Request

Implements UI call.

This should be call only from UI layer - i.e., RequestServer.

Overrides:

serve in class Func

See Also:

RequestServer

redirect

protected RequestBuilders.Response redirect()

fork

public Job fork()

Forks computation of this job.

The call does not block.

Returns:

always returns this job.

invoke

public void invoke()

Description copied from class: Func

Invoke this function in blocking way.

Overrides:

invoke in class Func

init

protected void init()
             throws java.lang.IllegalArgumentException

Invoked before job runs. This is the place to checks arguments are valid or throw IllegalArgumentException. It will get invoked both from the Web and Java APIs.

Overrides:

init in class Func

Throws:

java.lang.IllegalArgumentException - throws the exception if initialization fails to ensure correct job runtime environment.

waitUntilJobEnded

public static void waitUntilJobEnded(Key jobkey,
                     int pollingIntervalMillis)

Block synchronously waiting for a job to end, success or not.

Parameters:

jobkey - Job to wait for.

pollingIntervalMillis - Polling interval sleep time.

waitUntilJobEnded

public static void waitUntilJobEnded(Key jobkey)

Block synchronously waiting for a job to end, success or not.

Parameters:

jobkey - Job to wait for.

checkIdx

public static boolean checkIdx(Frame source,
               int[] idx)

hygiene

public static <T extends Job.FrameJob> T hygiene(T job)

Hygienic method to prevent accidental capture of non desired values.

hygiene

public static <T extends Job.ValidatedJob> T hygiene(T job)