public final class TaskletExecutionRequest<TInput,TOutput> extends Object implements VortexRequest
VortexRequest.RequestType
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 |
---|---|
byte[] |
execute()
Execute the function using the input.
|
VortexFunction |
getFunction()
Get function of the tasklet.
|
TInput |
getInput()
Get input of the tasklet.
|
int |
getTaskletId() |
VortexRequest.RequestType |
getType() |
public TaskletExecutionRequest(int taskletId, VortexFunction<TInput,TOutput> userFunction, TInput input)
public VortexRequest.RequestType getType()
getType
in interface VortexRequest
public byte[] execute() throws Exception
Exception
public int getTaskletId()
public VortexFunction getFunction()
Copyright © 2016 The Apache Software Foundation. All rights reserved.