O
- Collector typeI
- Input message content typepublic class ComputeCollectorOp<O,I> extends BaseComputeOp<I>
Constructor and Description |
---|
ComputeCollectorOp() |
ComputeCollectorOp(ComputeCollectorFunc<O,I> computeFunction,
BaseTSet origin,
java.util.Map<java.lang.String,java.lang.String> receivables) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close method for cleaning up the resources
|
void |
endExecute()
Callback that is gets called when the stream ends
|
boolean |
execute(IMessage<I> content)
Execute with an incoming message
|
TFunction |
getFunction() |
void |
prepare(Config cfg,
TaskContext ctx)
Prepare the task to be executed
|
writeEndToEdges, writeToEdges
add, getReceivableNames, gettSetContext
public ComputeCollectorOp()
public ComputeCollectorOp(ComputeCollectorFunc<O,I> computeFunction, BaseTSet origin, java.util.Map<java.lang.String,java.lang.String> receivables)
public void prepare(Config cfg, TaskContext ctx)
INode
prepare
in interface INode
prepare
in class BaseComputeOp<I>
cfg
- the configurationctx
- the task context, this has runtime information about the taskpublic boolean execute(IMessage<I> content)
ICompute
public void close()
Closable
public void endExecute()
ICompute
public TFunction getFunction()
getFunction
in class BaseComputeOp<I>