alluxio.job.composite

Class CompositeDefinition

java.lang.Object

alluxio.job.AbstractVoidJobDefinition<CompositeConfig,ArrayList<CompositeTask>>

alluxio.job.composite.CompositeDefinition

All Implemented Interfaces:

JobDefinition<CompositeConfig,ArrayList<CompositeTask>,SerializableVoid>

public final class CompositeDefinition
extends AbstractVoidJobDefinition<CompositeConfig,ArrayList<CompositeTask>>

The job definition for CompositeConfig.

Constructor Summary

Constructors

Constructor and Description
CompositeDefinition() Constructs a new CompositeDefinition.

Method Summary

Modifier and Type	Method and Description
Class<CompositeConfig>	getJobConfigClass()
SerializableVoid	runTask(CompositeConfig config, ArrayList<CompositeTask> tasks, RunTaskContext context) Runs the task in the executor.
Map<WorkerInfo,ArrayList<CompositeTask>>	selectExecutors(CompositeConfig config, List<WorkerInfo> jobWorkers, SelectExecutorsContext context) Selects the workers to run the task.

Methods inherited from class alluxio.job.AbstractVoidJobDefinition

join

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeDefinition

public CompositeDefinition()

Constructs a new CompositeDefinition.

Method Detail

getJobConfigClass

public Class<CompositeConfig> getJobConfigClass()

Returns:

the class of the associated JobConfig

selectExecutors

public Map<WorkerInfo,ArrayList<CompositeTask>> selectExecutors(CompositeConfig config,
                                                                List<WorkerInfo> jobWorkers,
                                                                SelectExecutorsContext context)
                                                         throws Exception

Description copied from interface: JobDefinition

Selects the workers to run the task.

Parameters:

config - the job configuration

jobWorkers - the list of available workers' information

context - the context containing information used to select executors

Returns:

a map of selected workers to the parameters to pass along

Throws:

Exception - if any error occurs

runTask

public SerializableVoid runTask(CompositeConfig config,
                                ArrayList<CompositeTask> tasks,
                                RunTaskContext context)
                         throws Exception

Description copied from interface: JobDefinition

Runs the task in the executor.

Parameters:

config - the job configuration

tasks - the arguments passed in

context - the context containing information used to execute a task

Returns:

the task result

Throws:

Exception - if any error occurs