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

Constructors

Constructor and Description
OperatorUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static com.google.common.collect.Multimap<Class<? extends Operator<?>>,Operator<?>>	classifyOperators(Operator<?> start, Set<Class<? extends Operator<?>>> classes) Given an operator and a set of classes, it classifies the operators it finds in the stream depending on the classes they instantiate.
static com.google.common.collect.Multimap<Class<? extends Operator<?>>,Operator<?>>	classifyOperatorsUpstream(Operator<?> start, Set<Class<? extends Operator<?>>> classes) Given an operator and a set of classes, it classifies the operators it finds upstream depending on the classes it instantiates.
static <T> T	findLastOperator(Operator<?> op, Class<T> clazz) Starting at the input operator, finds the last operator in the stream that is an instance of the input class.
static <T> T	findLastOperatorUpstream(Operator<?> op, Class<T> clazz) Starting at the input operator, finds the last operator upstream that is an instance of the input class.
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> Set<T>	findOperatorsUpstreamJoinAccounted(Operator<?> start, Class<T> clazz, Set<T> found)
static <T> T	findSingleOperator(Operator<?> start, Class<T> clazz)
static <T> T	findSingleOperatorUpstream(Operator<?> start, Class<T> clazz)
static <T> T	findSingleOperatorUpstreamJoinAccounted(Operator<?> start, Class<T> clazz)
static void	iterateParents(Operator<?> operator, NodeUtils.Function<Operator<?>> function)
static boolean	sameRowSchema(Operator<?> operator1, Operator<?> operator2)
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

clone, equals, finalize, 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)

findSingleOperatorUpstreamJoinAccounted

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

findOperatorsUpstream

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

findOperatorsUpstreamJoinAccounted

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

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)

findLastOperator

public static <T> T findLastOperator(Operator<?> op,
                     Class<T> clazz)

Starting at the input operator, finds the last operator in the stream that is an instance of the input class.

Parameters:

op - the starting operator

clazz - the class that the operator that we are looking for instantiates

Returns:

null if no such operator exists or multiple branches are found in the stream, the last operator otherwise

findLastOperatorUpstream

public static <T> T findLastOperatorUpstream(Operator<?> op,
                             Class<T> clazz)

Starting at the input operator, finds the last operator upstream that is an instance of the input class.

Parameters:

op - the starting operator

clazz - the class that the operator that we are looking for instantiates

Returns:

null if no such operator exists or multiple branches are found in the stream, the last operator otherwise

iterateParents

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

sameRowSchema

public static boolean sameRowSchema(Operator<?> operator1,
                    Operator<?> operator2)

classifyOperators

public static com.google.common.collect.Multimap<Class<? extends Operator<?>>,Operator<?>> classifyOperators(Operator<?> start,
                                                                                             Set<Class<? extends Operator<?>>> classes)

Given an operator and a set of classes, it classifies the operators it finds in the stream depending on the classes they instantiate. If a given operator object is an instance of more than one of the input classes, e.g. the operator instantiates one of the classes in the input set that is a subclass of another class in the set, the operator will be associated to both classes in the output map.

Parameters:

start - the start operator

classes - the set of classes

Returns:

a multimap from each of the classes to the operators that instantiate them

classifyOperatorsUpstream

public static com.google.common.collect.Multimap<Class<? extends Operator<?>>,Operator<?>> classifyOperatorsUpstream(Operator<?> start,
                                                                                                     Set<Class<? extends Operator<?>>> classes)

Given an operator and a set of classes, it classifies the operators it finds upstream depending on the classes it instantiates. If a given operator object is an instance of more than one of the input classes, e.g. the operator instantiates one of the classes in the input set that is a subclass of another class in the set, the operator will be associated to both classes in the output map.

Parameters:

start - the start operator

classes - the set of classes

Returns:

a multimap from each of the classes to the operators that instantiate them