org.apache.reef.vortex.protocol.mastertoworker

Class TaskletExecutionRequest<TInput,TOutput>

java.lang.Object

org.apache.reef.vortex.protocol.mastertoworker.TaskletExecutionRequest<TInput,TOutput>

All Implemented Interfaces:

MasterToWorkerRequest

public final class TaskletExecutionRequest<TInput,TOutput>
extends Object
implements MasterToWorkerRequest

Request to execute a tasklet.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.reef.vortex.protocol.mastertoworker.MasterToWorkerRequest

MasterToWorkerRequest.Type

Constructor Summary

Constructors

Constructor and Description
TaskletExecutionRequest(int taskletId, VortexFunction<TInput,TOutput> userFunction, TInput input) Request from Vortex Master to Vortex Worker to execute a tasklet.

Method Summary

Methods

Modifier and Type	Method and Description
TOutput	execute() Execute the function using the input.
VortexFunction	getFunction() Get function of the tasklet.
TInput	getInput() Get input of the tasklet.
int	getTaskletId()
MasterToWorkerRequest.Type	getType()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskletExecutionRequest

public TaskletExecutionRequest(int taskletId,
                       VortexFunction<TInput,TOutput> userFunction,
                       TInput input)

Request from Vortex Master to Vortex Worker to execute a tasklet.

Method Detail

getType

public MasterToWorkerRequest.Type getType()

Specified by:

getType in interface MasterToWorkerRequest

Returns:

the type of this MasterToWorkerRequest.

execute

public TOutput execute()
                throws Exception

Execute the function using the input.

Returns:

Output of the function.

Throws:

Exception

getTaskletId

public int getTaskletId()

Returns:

the ID of the VortexTasklet associated with this MasterToWorkerRequest.

getFunction

public VortexFunction getFunction()

Get function of the tasklet.

getInput

public TInput getInput()

Get input of the tasklet.