org.apache.hadoop.hive.ql.parse.spark

Class GenSparkWorkWalker

java.lang.Object

org.apache.hadoop.hive.ql.lib.DefaultGraphWalker

org.apache.hadoop.hive.ql.parse.spark.GenSparkWorkWalker

All Implemented Interfaces:

GraphWalker

public class GenSparkWorkWalker
extends DefaultGraphWalker

Walks the operator tree in DFS fashion. Cloned from GenTezWorkWarlker.

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.lib.DefaultGraphWalker

dispatcher, opQueue, opStack, retMap, toWalk

Constructor Summary

Constructors

Constructor and Description
GenSparkWorkWalker(Dispatcher disp, GenSparkProcContext ctx) constructor of the walker - the dispatcher is passed.

Method Summary

Modifier and Type	Method and Description
void	startWalking(Collection<Node> startNodes, HashMap<Node,Object> nodeOutput) starting point for walking.
protected void	walk(Node nd) Walk the given operator.

Methods inherited from class org.apache.hadoop.hive.ql.lib.DefaultGraphWalker

dispatch, dispatchAndReturn, getDispatchedList

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GenSparkWorkWalker

public GenSparkWorkWalker(Dispatcher disp,
                          GenSparkProcContext ctx)

constructor of the walker - the dispatcher is passed.

Parameters:

disp - the dispatcher to be called for each node visited

ctx - the context where we'll set the current root operator

Method Detail

startWalking

public void startWalking(Collection<Node> startNodes,
                         HashMap<Node,Object> nodeOutput)
                  throws SemanticException

starting point for walking.

Specified by:

startWalking in interface GraphWalker

Overrides:

startWalking in class DefaultGraphWalker

Parameters:

startNodes - list of starting operators

nodeOutput - If this parameter is not null, the call to the function returns the map from node to objects returned by the processors.

Throws:

SemanticException

walk

protected void walk(Node nd)
             throws SemanticException

Walk the given operator.

Overrides:

walk in class DefaultGraphWalker

Parameters:

nd - operator being walked

Throws:

SemanticException