org.apache.hadoop.hive.ql.exec
Class OperatorUtils

java.lang.Object
  org.apache.hadoop.hive.ql.exec.OperatorUtils

public class OperatorUtils
extends Object

Constructor Summary

OperatorUtils()

Method Summary

static <T> Set<T>	findOperators(Collection<Operator<?>> starts, Class<T> clazz)
static <T> Set<T>	findOperators(Operator<?> start, Class<T> clazz)
static <T> Set<T>	findOperatorsUpstream(Collection<Operator<?>> starts, Class<T> clazz)
static <T> Set<T>	findOperatorsUpstream(Operator<?> start, Class<T> clazz)
static <T> T	findSingleOperator(Operator<?> start, Class<T> clazz)
static <T> T	findSingleOperatorUpstream(Operator<?> start, Class<T> clazz)
static void	iterateParents(Operator<?> operator, NodeUtils.Function<Operator<?>> function)
static void	setChildrenCollector(List<Operator<? extends OperatorDesc>> childOperators, Map<String,org.apache.hadoop.mapred.OutputCollector> outMap)
static void	setChildrenCollector(List<Operator<? extends OperatorDesc>> childOperators, org.apache.hadoop.mapred.OutputCollector out)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorUtils

public OperatorUtils()

Method Detail

findOperators

public static <T> Set<T> findOperators(Operator<?> start,
                                       Class<T> clazz)

findSingleOperator

public static <T> T findSingleOperator(Operator<?> start,
                                       Class<T> clazz)

findOperators

public static <T> Set<T> findOperators(Collection<Operator<?>> starts,
                                       Class<T> clazz)

findOperatorsUpstream

public static <T> Set<T> findOperatorsUpstream(Operator<?> start,
                                               Class<T> clazz)

findSingleOperatorUpstream

public static <T> T findSingleOperatorUpstream(Operator<?> start,
                                               Class<T> clazz)

findOperatorsUpstream

public static <T> Set<T> findOperatorsUpstream(Collection<Operator<?>> starts,
                                               Class<T> clazz)

setChildrenCollector

public static void setChildrenCollector(List<Operator<? extends OperatorDesc>> childOperators,
                                        org.apache.hadoop.mapred.OutputCollector out)

setChildrenCollector

public static void setChildrenCollector(List<Operator<? extends OperatorDesc>> childOperators,
                                        Map<String,org.apache.hadoop.mapred.OutputCollector> outMap)

iterateParents

public static void iterateParents(Operator<?> operator,
                                  NodeUtils.Function<Operator<?>> function)