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, writeToEdgesadd, getReceivableNames, gettSetContextpublic 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)
INodeprepare in interface INodeprepare in class BaseComputeOp<I>cfg - the configurationctx - the task context, this has runtime information about the taskpublic boolean execute(IMessage<I> content)
IComputepublic void close()
Closablepublic void endExecute()
IComputepublic TFunction getFunction()
getFunction in class BaseComputeOp<I>