org.apache.hadoop.hive.ql.plan

Class ExprNodeDescUtils

java.lang.Object

org.apache.hadoop.hive.ql.plan.ExprNodeDescUtils

public class ExprNodeDescUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ExprNodeDescUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static ExprNodeDesc	backtrack(ExprNodeDesc source, Operator<?> current, Operator<?> terminal)
static ArrayList<ExprNodeDesc>	backtrack(List<ExprNodeDesc> sources, Operator<?> current, Operator<?> terminal) Convert expressions in current operator to those in terminal operator, which is an ancestor of current or null (back to top operator).
static ArrayList<ExprNodeDesc>	clone(List<ExprNodeDesc> sources)
static boolean	containsPredicate(ExprNodeDesc source, ExprNodeDesc predicate) return true if predicate is already included in source
static PrimitiveTypeInfo	deriveMinArgumentCast(ExprNodeDesc childExpr, TypeInfo targetType)
static ExprNodeDesc[]	extractComparePair(ExprNodeDesc expr1, ExprNodeDesc expr2)
static String[]	extractFields(ExprNodeFieldDesc expr) Extract fields from the given node descriptor
static ArrayList<ExprNodeDesc>	genExprNodeDesc(Operator inputOp, int startPos, int endPos, boolean addEmptyTabAlias, boolean setColToNonVirtual) Build ExprNodeColumnDesc for the projections in the input operator from sartpos to endpos(both included).
static void	getExprNodeColumnDesc(ExprNodeDesc exprDesc, Map<Integer,ExprNodeDesc> hashCodeToColumnDescMap) Get Map of ExprNodeColumnDesc HashCode to ExprNodeColumnDesc.
static void	getExprNodeColumnDesc(List<ExprNodeDesc> exprDescList, Map<Integer,ExprNodeDesc> hashCodeTocolumnDescMap)
static Operator<?>	getSingleParent(Operator<?> current, Operator<?> terminal)
static int	indexOf(ExprNodeDesc origin, List<ExprNodeDesc> sources)
static boolean	isAllConstants(List<ExprNodeDesc> value)
static boolean	isDeterministic(ExprNodeDesc desc) Return false if the expression has any non deterministic function
static ExprNodeGenericFuncDesc	mergePredicates(ExprNodeDesc prev, ExprNodeDesc next) bind two predicates by AND op
static ExprNodeDesc	mergePredicates(List<ExprNodeDesc> exprs) bind n predicates by AND op
static String	recommendInputName(ExprNodeDesc desc) Recommend name for the expression
static ExprNodeDesc	replace(ExprNodeDesc origin, List<ExprNodeDesc> sources, List<ExprNodeDesc> targets)
static List<ExprNodeDesc>	split(ExprNodeDesc current) split predicates by AND op
static List<ExprNodeDesc>	split(ExprNodeDesc current, List<ExprNodeDesc> splitted) split predicates by AND op

Methods inherited from class java.lang.Object

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

Constructor Detail

ExprNodeDescUtils

public ExprNodeDescUtils()

Method Detail

indexOf

public static int indexOf(ExprNodeDesc origin,
          List<ExprNodeDesc> sources)

replace

public static ExprNodeDesc replace(ExprNodeDesc origin,
                   List<ExprNodeDesc> sources,
                   List<ExprNodeDesc> targets)

containsPredicate

public static boolean containsPredicate(ExprNodeDesc source,
                        ExprNodeDesc predicate)

return true if predicate is already included in source

mergePredicates

public static ExprNodeGenericFuncDesc mergePredicates(ExprNodeDesc prev,
                                      ExprNodeDesc next)

bind two predicates by AND op

mergePredicates

public static ExprNodeDesc mergePredicates(List<ExprNodeDesc> exprs)

bind n predicates by AND op

split

public static List<ExprNodeDesc> split(ExprNodeDesc current)

split predicates by AND op

split

public static List<ExprNodeDesc> split(ExprNodeDesc current,
                       List<ExprNodeDesc> splitted)

split predicates by AND op

recommendInputName

public static String recommendInputName(ExprNodeDesc desc)

Recommend name for the expression

isDeterministic

public static boolean isDeterministic(ExprNodeDesc desc)

Return false if the expression has any non deterministic function

clone

public static ArrayList<ExprNodeDesc> clone(List<ExprNodeDesc> sources)

backtrack

public static ArrayList<ExprNodeDesc> backtrack(List<ExprNodeDesc> sources,
                                Operator<?> current,
                                Operator<?> terminal)
                                         throws SemanticException

Convert expressions in current operator to those in terminal operator, which is an ancestor of current or null (back to top operator). Possibly contain null values for non-traceable exprs

Throws:

SemanticException

backtrack

public static ExprNodeDesc backtrack(ExprNodeDesc source,
                     Operator<?> current,
                     Operator<?> terminal)
                              throws SemanticException

Throws:

SemanticException

getSingleParent

public static Operator<?> getSingleParent(Operator<?> current,
                          Operator<?> terminal)
                                   throws SemanticException

Throws:

SemanticException

extractComparePair

public static ExprNodeDesc[] extractComparePair(ExprNodeDesc expr1,
                                ExprNodeDesc expr2)

extractFields

public static String[] extractFields(ExprNodeFieldDesc expr)

Extract fields from the given node descriptor

getExprNodeColumnDesc

public static void getExprNodeColumnDesc(List<ExprNodeDesc> exprDescList,
                         Map<Integer,ExprNodeDesc> hashCodeTocolumnDescMap)

getExprNodeColumnDesc

public static void getExprNodeColumnDesc(ExprNodeDesc exprDesc,
                         Map<Integer,ExprNodeDesc> hashCodeToColumnDescMap)

Get Map of ExprNodeColumnDesc HashCode to ExprNodeColumnDesc.

Parameters:

exprDesc -

hashCodeToColumnDescMap - Assumption: If two ExprNodeColumnDesc have same hash code then they are logically referring to same projection

isAllConstants

public static boolean isAllConstants(List<ExprNodeDesc> value)

deriveMinArgumentCast

public static PrimitiveTypeInfo deriveMinArgumentCast(ExprNodeDesc childExpr,
                                      TypeInfo targetType)

genExprNodeDesc

public static ArrayList<ExprNodeDesc> genExprNodeDesc(Operator inputOp,
                                      int startPos,
                                      int endPos,
                                      boolean addEmptyTabAlias,
                                      boolean setColToNonVirtual)

Build ExprNodeColumnDesc for the projections in the input operator from sartpos to endpos(both included). Operator must have an associated colExprMap.

Parameters:

inputOp - Input Hive Operator

startPos - starting position in the input operator schema; must be >=0 and <= endPos

endPos - end position in the input operator schema; must be >=0.

Returns:

List of ExprNodeDesc