Package | Description |
---|---|
org.apache.hadoop.hive.ql.optimizer.calcite.translator | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan.ptf | |
org.apache.hadoop.hive.ql.udf.ptf |
Modifier and Type | Method and Description |
---|---|
List<RowResolver> |
JoinTypeCheckCtx.getInputRRList() |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.getType(org.apache.calcite.plan.RelOptCluster cluster,
RowResolver rr,
List<String> neededCols) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rex.RexNode |
RexNodeConverter.convert(org.apache.calcite.plan.RelOptCluster cluster,
ExprNodeDesc joinCondnExprNode,
List<org.apache.calcite.rel.RelNode> inputRels,
LinkedHashMap<org.apache.calcite.rel.RelNode,RowResolver> relToHiveRR,
Map<org.apache.calcite.rel.RelNode,com.google.common.collect.ImmutableMap<String,Integer>> relToHiveColNameCalcitePosMap,
boolean flattenExpr) |
Constructor and Description |
---|
JoinTypeCheckCtx(RowResolver leftRR,
RowResolver rightRR,
JoinType hiveJoinType) |
Modifier and Type | Method and Description |
---|---|
protected static RowResolver |
PTFTranslator.buildRowResolverForNoop(String tabAlias,
StructObjectInspector rowObjectInspector,
RowResolver inputRowResolver) |
protected static RowResolver |
PTFTranslator.buildRowResolverForPTF(String tbFnName,
String tabAlias,
StructObjectInspector rowObjectInspector,
List<String> outputColNames,
RowResolver inputRR) |
protected RowResolver |
PTFTranslator.buildRowResolverForWindowing(WindowTableFunctionDef def) |
RowResolver |
RowResolver.duplicate() |
static RowResolver |
RowResolver.getCombinedRR(RowResolver leftRR,
RowResolver rightRR)
Return a new row resolver that is combination of left RR and right RR.
|
RowResolver |
TypeCheckCtx.getInputRR() |
RowResolver |
OpParseContext.getRowResolver() |
RowResolver |
SemanticAnalyzer.getRowResolver(Operator opt)
Get the row resolver given an operator.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
RowResolver.add(RowResolver rrToAddTo,
RowResolver rrToAddFrom) |
static boolean |
RowResolver.add(RowResolver rrToAddTo,
RowResolver rrToAddFrom,
int numColumns) |
protected static RowResolver |
PTFTranslator.buildRowResolverForNoop(String tabAlias,
StructObjectInspector rowObjectInspector,
RowResolver inputRowResolver) |
protected static RowResolver |
PTFTranslator.buildRowResolverForPTF(String tbFnName,
String tabAlias,
StructObjectInspector rowObjectInspector,
List<String> outputColNames,
RowResolver inputRR) |
Map<ASTNode,ExprNodeDesc> |
SemanticAnalyzer.genAllExprNodeDesc(ASTNode expr,
RowResolver input)
Generates an expression node descriptors for the expression and children of it
with default TypeCheckCtx.
|
Map<ASTNode,ExprNodeDesc> |
SemanticAnalyzer.genAllExprNodeDesc(ASTNode expr,
RowResolver input,
TypeCheckCtx tcCtx)
Generates all of the expression node descriptors for the expression and children of it
passed in the arguments.
|
ExprNodeDesc |
SemanticAnalyzer.genExprNodeDesc(ASTNode expr,
RowResolver input)
Generates an expression node descriptor for the expression with TypeCheckCtx.
|
ExprNodeDesc |
SemanticAnalyzer.genExprNodeDesc(ASTNode expr,
RowResolver input,
TypeCheckCtx tcCtx)
Returns expression node descriptor for the expression.
|
static ASTNode |
SemanticAnalyzer.genSelectDIAST(RowResolver rr) |
static ASTNode |
PTFTranslator.getASTNode(ColumnInfo cInfo,
RowResolver rr) |
static RowResolver |
RowResolver.getCombinedRR(RowResolver leftRR,
RowResolver rightRR)
Return a new row resolver that is combination of left RR and right RR.
|
static StructObjectInspector |
PTFTranslator.getStandardStructOI(RowResolver rr)
For each column on the input RR, construct a StructField for it
OI is constructed using the list of input column names and
their corresponding OIs.
|
WindowingSpec |
WindowingComponentizer.next(HiveConf hCfg,
SemanticAnalyzer semAly,
UnparseTranslator unparseT,
RowResolver inputRR) |
<T extends OperatorDesc> |
SemanticAnalyzer.putOpInsertMap(Operator<T> op,
RowResolver rr) |
void |
TypeCheckCtx.setInputRR(RowResolver inputRR) |
void |
OpParseContext.setRowResolver(RowResolver rr) |
PTFDesc |
PTFTranslator.translate(PTFInvocationSpec qSpec,
SemanticAnalyzer semAly,
HiveConf hCfg,
RowResolver inputRR,
UnparseTranslator unparseT) |
PTFDesc |
PTFTranslator.translate(WindowingSpec wdwSpec,
SemanticAnalyzer semAly,
HiveConf hCfg,
RowResolver inputRR,
UnparseTranslator unparseT) |
Constructor and Description |
---|
OpParseContext(RowResolver rr) |
TypeCheckCtx(RowResolver inputRR)
Constructor.
|
TypeCheckCtx(RowResolver inputRR,
boolean allowStatefulFunctions,
boolean allowDistinctFunctions,
boolean allowGBExprElimination,
boolean allowAllColRef,
boolean allowFunctionStar,
boolean allowWindowing,
boolean allowIndexExpr,
boolean allowSubQueryExpr) |
Modifier and Type | Method and Description |
---|---|
RowResolver |
ShapeDetails.getRr() |
Modifier and Type | Method and Description |
---|---|
void |
ShapeDetails.setRr(RowResolver rr) |
Modifier and Type | Method and Description |
---|---|
protected static RowResolver |
MatchPath.createSelectListRR(MatchPath evaluator,
PTFInputDef inpDef) |
Constructor and Description |
---|
MatchPath.ResultExpressionParser(String resultExprString,
RowResolver selectListInputRowResolver) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.