public class RowComupteCollectorOp extends BaseComputeOp<Table>
Constructor and Description |
---|
RowComupteCollectorOp() |
RowComupteCollectorOp(ComputeCollectorFunc<Row,java.util.Iterator<Row>> 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<Table> 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 RowComupteCollectorOp()
public RowComupteCollectorOp(ComputeCollectorFunc<Row,java.util.Iterator<Row>> 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<Table>
cfg
- the configurationctx
- the task context, this has runtime information about the taskpublic boolean execute(IMessage<Table> content)
ICompute
public void endExecute()
ICompute
public void close()
Closable
public TFunction getFunction()
getFunction
in class BaseComputeOp<Table>