List of startWalking() Examples

Examples of startWalking()

org.apache.hadoop.hive.ql.lib.DefaultGraphWalker.startWalking()
starting point for walking @throws SemanticException
org.apache.hadoop.hive.ql.lib.ForwardWalker.startWalking()
org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()
starting point for walking. @param startNodes list of starting operators @param 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
org.apache.hadoop.hive.ql.lib.PreOrderWalker.startWalking()
org.apache.hadoop.hive.ql.lib.TaskGraphWalker.startWalking()
starting point for walking. @throws SemanticException
org.apache.hadoop.hive.ql.parse.GenMapRedWalker.startWalking()

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

    GraphWalker ogw = new DefaultGraphWalker(disp);


    // Create a list of topop nodes
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.addAll(pctx.getTopOps().values());
    ogw.startWalking(topNodes, null);
    pctx.setHasNonPartCols(opWalkerCtx.getHasNonPartCols());


    return pctx;
  }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

    GraphWalker ogw = new DefaultGraphWalker(disp);


    // Create a list of topop nodes
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.add(tree);
    ogw.startWalking(topNodes, null);
  }


  public static void main(String[] args) throws IOException, ParseException,
  SemanticException {

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

    Dispatcher disp = new DefaultRuleDispatcher(new GenMROperator(), opRules, procCtx);


    GraphWalker ogw = new GenMapRedWalker(disp);
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.addAll(this.topOps.values());
    ogw.startWalking(topNodes, null);


    // reduce sink does not have any kids - since the plan by now has been broken up into multiple
    // tasks, iterate over all tasks.
    // For each task, go over all operators recursively
    for(Task<? extends Serializable> rootTask: rootTasks)

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

   
    // Create a list of topop nodes
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.add(expr);
    HashMap<Node, Object> nodeOutputs = new HashMap<Node, Object>();
    ogw.startWalking(topNodes, nodeOutputs);
    exprNodeDesc desc = (exprNodeDesc)nodeOutputs.get(expr);
    if (desc == null) {
      throw new SemanticException(tcCtx.getError());
    }

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

    GraphWalker ogw = new ColumnPrunerWalker(disp);
   
    // Create a list of topop nodes
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.addAll(pGraphContext.getTopOps().values());
    ogw.startWalking(topNodes, null);


    // create a new select operator if any of input tables' columns can be pruned
    for (String alias_id : pGraphContext.getTopOps().keySet()) {
      Operator<? extends Serializable> topOp = pGraphContext.getTopOps().get(alias_id);

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

    GraphWalker ogw = new PreOrderWalker(disp);
   
    // Create a list of topop nodes
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.addAll(pCtx.getTopOps().values());
    ogw.startWalking(topNodes, null);
    pCtx.setUCtx(uCtx);
    
    return pCtx;
  }
}

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()


    // Create a list of topop nodes
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.add(expr);
    HashMap<Node, Object> nodeOutputs = new LinkedHashMap<Node, Object>();
    ogw.startWalking(topNodes, nodeOutputs);


    return convert(nodeOutputs);
  }


  // temporary type-safe casting

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

        procCtx);


    GraphWalker ogw = new GenMapRedWalker(disp);
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.addAll(pCtx.getTopOps().values());
    ogw.startWalking(topNodes, null);


    /*
     * If the query was the result of analyze table column compute statistics rewrite, create
     * a column stats task instead of a fetch task to persist stats to the metastore.
     */

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

  public PhysicalContext resolve(PhysicalContext pctx) throws SemanticException {
    Dispatcher disp = new MetadataOnlyTaskDispatcher(pctx);
    GraphWalker ogw = new DefaultGraphWalker(disp);
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.addAll(pctx.getRootTasks());
    ogw.startWalking(topNodes, null);
    return pctx;
  }


  /**
   * Iterate over all tasks one-to-one and convert them to metadata only

View Full Code Here

Examples of org.apache.hadoop.hive.ql.lib.GraphWalker.startWalking()

        listMapJoinOpsNoRed, pGraphContext));


    GraphWalker ogw = new GenMapRedWalker(disp);
    ArrayList<Node> topNodes = new ArrayList<Node>();
    topNodes.addAll(listMapJoinOps);
    ogw.startWalking(topNodes, null);


    pGraphContext.setListMapJoinOpsNoReducer(listMapJoinOpsNoRed);
    return pGraphContext;
  }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.