|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.hive.ql.lib.TaskGraphWalker
public class TaskGraphWalker
base class for operator graph walker this class takes list of starting ops and walks them one by one. it maintains list of walked operators (dispatchedList) and a list of operators that are discovered but not yet dispatched
Nested Class Summary | |
---|---|
class |
TaskGraphWalker.TaskGraphWalkerContext
|
Constructor Summary | |
---|---|
TaskGraphWalker(Dispatcher disp)
Constructor. |
Method Summary | |
---|---|
void |
dispatch(Node nd,
Stack<Node> ndStack)
|
void |
dispatch(Node nd,
Stack<Node> ndStack,
TaskGraphWalker.TaskGraphWalkerContext walkerCtx)
Dispatch the current operator. |
Set<Node> |
getDispatchedList()
|
List<Node> |
getToWalk()
|
void |
startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking. |
void |
walk(Node nd)
walk the current operator and its descendants. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TaskGraphWalker(Dispatcher disp)
disp
- dispatcher to call for each op encounteredMethod Detail |
---|
public List<Node> getToWalk()
public Set<Node> getDispatchedList()
public void dispatch(Node nd, Stack<Node> ndStack, TaskGraphWalker.TaskGraphWalkerContext walkerCtx) throws SemanticException
nd
- node being walkedndStack
- stack of nodes encountered
SemanticException
public void dispatch(Node nd, Stack<Node> ndStack) throws SemanticException
SemanticException
public void startWalking(Collection<Node> startNodes, HashMap<Node,Object> nodeOutput) throws SemanticException
startWalking
in interface GraphWalker
startNodes
- list of starting operatorsnodeOutput
- If this parameter is not null, the call to the function returns
the map from node to objects returned by the processors.
SemanticException
public void walk(Node nd) throws SemanticException
nd
- current operator in the graph
SemanticException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |