public final class TaskletExecutionRequest<TInput,TOutput> extends Object implements MasterToWorkerRequest
MasterToWorkerRequest.Type
Constructor and Description |
---|
TaskletExecutionRequest(int taskletId,
VortexFunction<TInput,TOutput> userFunction,
TInput input)
Request from Vortex Master to Vortex Worker to execute a tasklet.
|
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() |
public TaskletExecutionRequest(int taskletId, VortexFunction<TInput,TOutput> userFunction, TInput input)
public MasterToWorkerRequest.Type getType()
getType
in interface MasterToWorkerRequest
public TOutput execute() throws Exception
Exception
public int getTaskletId()
public VortexFunction getFunction()
Copyright © 2017 The Apache Software Foundation. All rights reserved.