public abstract class BaseComputeOp<I> extends BaseOp implements ICompute<I>, Closable
MultiEdgeOpAdapter
Modifier | Constructor and Description |
---|---|
protected |
BaseComputeOp() |
protected |
BaseComputeOp(BaseTSet originTSet,
java.util.Map<java.lang.String,java.lang.String> receivablesTSets) |
Modifier and Type | Method and Description |
---|---|
abstract TFunction |
getFunction() |
void |
prepare(Config cfg,
TaskContext ctx)
Prepare the task to be executed
|
protected void |
writeEndToEdges() |
protected <T> void |
writeToEdges(T output) |
add, getReceivableNames, gettSetContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
endExecute, execute
protected BaseComputeOp()
protected BaseComputeOp(BaseTSet originTSet, java.util.Map<java.lang.String,java.lang.String> receivablesTSets)
public void prepare(Config cfg, TaskContext ctx)
INode
public abstract TFunction getFunction()
protected <T> void writeToEdges(T output)
protected void writeEndToEdges()