org.apache.hadoop.hive.ql.optimizer.correlation
Class CorrelationUtilities

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.correlation.CorrelationUtilities

public final class CorrelationUtilities
extends Object

Utilities for both CorrelationOptimizer and ReduceSinkDeDuplication.

Constructor Summary

CorrelationUtilities()

Method Summary

static List<Operator<? extends OperatorDesc>>	findSiblingOperators(Operator<? extends OperatorDesc> op) Find all sibling operators (which have the same child operator of op) of op (op included).
static List<ReduceSinkOperator>	findSiblingReduceSinkOperators(ReduceSinkOperator op) Find all sibling ReduceSinkOperators (which have the same child operator of op) of op (op included).
static void	removeOperator(Operator<?> target, ParseContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

CorrelationUtilities

public CorrelationUtilities()

Method Detail

findSiblingReduceSinkOperators

public static List<ReduceSinkOperator> findSiblingReduceSinkOperators(ReduceSinkOperator op)
                                                               throws SemanticException

Find all sibling ReduceSinkOperators (which have the same child operator of op) of op (op included).

Throws:

SemanticException

findSiblingOperators

public static List<Operator<? extends OperatorDesc>> findSiblingOperators(Operator<? extends OperatorDesc> op)
                                                                   throws SemanticException

Find all sibling operators (which have the same child operator of op) of op (op included).

Throws:

SemanticException

removeOperator

public static void removeOperator(Operator<?> target,
                                  ParseContext context)