AbstractJob |
A job is a unit of execution.
|
AbstractJobRunner<T extends Job> |
Ancestor for jobrunner classes.
|
AbstractMetaJobRunner |
Ancestor for meta-jobrunners, that wrap around a base jobrunner.
|
CallableWithResult<T> |
Callable that stores the result for future use.
|
JobList<T extends Job> |
A container for jobs to execute.
|
JobResult |
The result of Job Execution.
|
LocalJobRunner<T extends Job> |
Executes the jobs on the local machine.
|
PausableFixedThreadPoolExecutor |
|
RemoteCommandJobRunner |
Utilizes the remote command framework for sending jobs to a remote machine.
|
RemoteCommandJobRunner.RemoteCommandGrabber |
Handles the job response.
|
ScpJobRunner |
Wraps another jobrunner and serializes it, scp's it to the specified remote file and then waits for the specified import file (containing the serialized, executed jobs) to appear.
Requires a adams.flow.standalone.SSHConnection standalone for defining the SSH connection.
|
ScpJobRunner.RemoteJobRunner |
|
SerializingJobRunner |
Wraps another jobrunner and serializes it to the specified export file and then waits for the specified import file (containing the serialized, executed jobs) to appear.
|
WekaCrossValidationExecution |
Performs cross-validation, either single or multi-threaded.
|
WekaCrossValidationJob |
For evaluation of a single train/test fold in parallel.
|