alluxio.job.plan

Class NoopPlanDefinition

java.lang.Object

alluxio.job.plan.AbstractVoidPlanDefinition<NoopPlanConfig,SerializableVoid>

alluxio.job.plan.NoopPlanDefinition

All Implemented Interfaces:

PlanDefinition<NoopPlanConfig,SerializableVoid,SerializableVoid>

public class NoopPlanDefinition
extends AbstractVoidPlanDefinition<NoopPlanConfig,SerializableVoid>

This definition of a plan that does nothing.

Constructor Summary

Constructors

Constructor and Description
NoopPlanDefinition() Constructs a new instance.

Method Summary

Modifier and Type	Method and Description
Class<NoopPlanConfig>	getJobConfigClass()
SerializableVoid	runTask(NoopPlanConfig config, SerializableVoid args, RunTaskContext runTaskContext) Runs the task in the executor.
Set<Pair<WorkerInfo,SerializableVoid>>	selectExecutors(NoopPlanConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext selectExecutorsContext) Selects the workers to run the task.

Methods inherited from class alluxio.job.plan.AbstractVoidPlanDefinition

join

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopPlanDefinition

public NoopPlanDefinition()

Constructs a new instance.

Method Detail

getJobConfigClass

public Class<NoopPlanConfig> getJobConfigClass()

Returns:

the class of the associated JobConfig

selectExecutors

public Set<Pair<WorkerInfo,SerializableVoid>> selectExecutors(NoopPlanConfig config,
                                                              List<WorkerInfo> jobWorkerInfoList,
                                                              SelectExecutorsContext selectExecutorsContext)
                                                       throws Exception

Description copied from interface: PlanDefinition

Selects the workers to run the task.

Parameters:

config - the job configuration

jobWorkerInfoList - the list of available workers' information

selectExecutorsContext - the context containing information used to select executors

Returns:

a set of pairs of selected workers to the parameters to pass along

Throws:

Exception - if any error occurs

runTask

public SerializableVoid runTask(NoopPlanConfig config,
                                SerializableVoid args,
                                RunTaskContext runTaskContext)
                         throws Exception

Description copied from interface: PlanDefinition

Runs the task in the executor.

Parameters:

config - the job configuration

args - the arguments passed in

runTaskContext - the context containing information used to execute a task

Returns:

the task result

Throws:

Exception - if any error occurs