alluxio.job

Class AbstractVoidJobDefinition<T extends JobConfig,P extends Serializable>

java.lang.Object

alluxio.job.AbstractVoidJobDefinition<T,P>

Type Parameters:

T - the job configuration type

P - the argument type

All Implemented Interfaces:

JobDefinition<T,P,SerializableVoid>

Direct Known Subclasses:

CompactDefinition, CompositeDefinition, EvictDefinition, LoadDefinition, MigrateDefinition, MoveDefinition, PersistDefinition, ReplicateDefinition

public abstract class AbstractVoidJobDefinition<T extends JobConfig,P extends Serializable>
extends Object
implements JobDefinition<T,P,SerializableVoid>

An abstract job definition where the run task method does not return a value.

Constructor Summary

Constructors

Constructor and Description
AbstractVoidJobDefinition()

Method Summary

Modifier and Type	Method and Description
String	join(T config, Map<WorkerInfo,SerializableVoid> taskResults) Joins the task results on the master.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.job.JobDefinition

getJobConfigClass, runTask, selectExecutors

Constructor Detail

AbstractVoidJobDefinition

public AbstractVoidJobDefinition()

Method Detail

join

public String join(T config,
                   Map<WorkerInfo,SerializableVoid> taskResults)
            throws Exception

Description copied from interface: JobDefinition

Joins the task results on the master.

Specified by:

join in interface JobDefinition<T extends JobConfig,P extends Serializable,SerializableVoid>

Parameters:

config - the job configuration

taskResults - the task results

Returns:

the joined results

Throws:

Exception - if any error occurs