public class CrossProduct extends CompletionHandlingAbstractIterationStrategyNode
CompletionHandlingAbstractIterationStrategyNode.CompletionState
allowsChildren, EMPTY_ENUMERATION, userObject
Constructor and Description |
---|
CrossProduct() |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanUp(String owningProcess)
Called after a final completion event has been emited for a given owning
process, should be used by subclasses to do any tidying required,
removing state etc.
|
int |
getIterationDepth(Map<String,Integer> inputDepths)
In the context of an enclosing iteration strategy each node should be
able to return the iteration depth, i.e.
|
void |
innerReceiveCompletion(int inputIndex,
Completion completion) |
void |
innerReceiveJob(int inputIndex,
Job newJob)
Receive a job, emit jobs corresponding to the orthogonal join of the new
job with all jobs in all other input lists.
|
getCompletionState, receiveCompletion, receiveJob
children, clear, getAllowsChildren, getChildAt, getChildCount, getChildren, getIndex, getParent, insert, insert, isLeaf, pushCompletion, pushJob, remove, remove, removeFromParent, setParent, setUserObject
add, breadthFirstEnumeration, clone, depthFirstEnumeration, getChildAfter, getChildBefore, getDepth, getFirstChild, getFirstLeaf, getLastChild, getLastLeaf, getLeafCount, getLevel, getNextLeaf, getNextNode, getNextSibling, getPath, getPathToRoot, getPreviousLeaf, getPreviousNode, getPreviousSibling, getRoot, getSharedAncestor, getSiblingCount, getUserObject, getUserObjectPath, isNodeAncestor, isNodeChild, isNodeDescendant, isNodeRelated, isNodeSibling, isRoot, pathFromAncestorEnumeration, postorderEnumeration, preorderEnumeration, removeAllChildren, setAllowsChildren, toString
public void innerReceiveJob(int inputIndex, Job newJob)
innerReceiveJob
in class CompletionHandlingAbstractIterationStrategyNode
public void innerReceiveCompletion(int inputIndex, Completion completion)
innerReceiveCompletion
in class CompletionHandlingAbstractIterationStrategyNode
protected final void cleanUp(String owningProcess)
CompletionHandlingAbstractIterationStrategyNode
cleanUp
in class CompletionHandlingAbstractIterationStrategyNode
public int getIterationDepth(Map<String,Integer> inputDepths) throws IterationTypeMismatchException
IterationStrategyNode
Nodes can choose to throw the IterationTypeMismatchException if their inputs aren't compatible with the operational semantics of the node such as in the case of a dot product node with inputs with different depths.
IterationTypeMismatchException
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.