public final class TaskletAggregationRequest<TInput,TOutput> extends Object implements VortexRequest
VortexWorker
to
record aggregate functions for later execution.VortexRequest.RequestType
Constructor and Description |
---|
TaskletAggregationRequest(int aggregateFunctionId,
VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> function,
VortexAggregatePolicy policy) |
Modifier and Type | Method and Description |
---|---|
byte[] |
executeAggregation(List<TOutput> outputs)
Execute the aggregate function using the list of outputs.
|
TOutput |
executeFunction(TInput input)
Execute the user specified function.
|
VortexAggregateFunction |
getAggregateFunction() |
int |
getAggregateFunctionId() |
VortexFunction |
getFunction() |
VortexAggregatePolicy |
getPolicy() |
VortexRequest.RequestType |
getType() |
public TaskletAggregationRequest(int aggregateFunctionId, VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy)
public VortexRequest.RequestType getType()
getType
in interface VortexRequest
public int getAggregateFunctionId()
public VortexAggregateFunction getAggregateFunction()
public VortexFunction getFunction()
public VortexAggregatePolicy getPolicy()
public byte[] executeAggregation(List<TOutput> outputs) throws Exception
Exception
public TOutput executeFunction(TInput input) throws Exception
Exception
Copyright © 2016 The Apache Software Foundation. All rights reserved.