alluxio.job.plan

Class AbstractVoidPlanDefinition<T extends JobConfig,P extends Serializable>

java.lang.Object

alluxio.job.plan.AbstractVoidPlanDefinition<T,P>

Type Parameters:

T - the job configuration type

P - the argument type

All Implemented Interfaces:

PlanDefinition<T,P,SerializableVoid>

Direct Known Subclasses:

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

public abstract class AbstractVoidPlanDefinition<T extends JobConfig,P extends Serializable>
extends Object
implements PlanDefinition<T,P,SerializableVoid>

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

Constructor Summary

Constructors

Constructor and Description
AbstractVoidPlanDefinition()

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.plan.PlanDefinition

getJobConfigClass, runTask, selectExecutors

Constructor Detail

AbstractVoidPlanDefinition

public AbstractVoidPlanDefinition()

Method Detail

join

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

Description copied from interface: PlanDefinition

Joins the task results on the master.

Specified by:

join in interface PlanDefinition<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