public final class TaskletAggregationRequest<TInput,TOutput> extends Object implements MasterToWorkerRequest
VortexWorker
to
record aggregate functions for later execution.MasterToWorkerRequest.Type
Constructor and Description |
---|
TaskletAggregationRequest(int aggregateFunctionId,
VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> function,
VortexAggregatePolicy policy) |
Modifier and Type | Method and Description |
---|---|
TOutput |
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() |
MasterToWorkerRequest.Type |
getType() |
public TaskletAggregationRequest(int aggregateFunctionId, VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy)
public MasterToWorkerRequest.Type getType()
getType
in interface MasterToWorkerRequest
public int getAggregateFunctionId()
public VortexAggregateFunction getAggregateFunction()
public VortexFunction getFunction()
public VortexAggregatePolicy getPolicy()
public TOutput executeAggregation(List<TOutput> outputs) throws Exception
Exception
public TOutput executeFunction(TInput input) throws Exception
Exception
Copyright © 2017 The Apache Software Foundation. All rights reserved.