Package | Description |
---|---|
org.apache.flink.table.planner.delegation.hive | |
org.apache.flink.table.planner.delegation.hive.copy |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.hadoop.hive.metastore.api.FieldSchema> |
HiveParserUtils.convertRowSchemaToResultSetSchema(HiveParserRowResolver rr,
boolean useTabAliasIfAvailable) |
static HiveParserUtils.LateralViewInfo |
HiveParserUtils.extractLateralViewInfo(HiveParserASTNode lateralView,
HiveParserRowResolver inputRR,
HiveParserSemanticAnalyzer hiveAnalyzer,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster) |
static HiveParserASTNode |
HiveParserUtils.genSelectDIAST(HiveParserRowResolver rr) |
static String[] |
HiveParserUtils.getColAlias(HiveParserASTNode selExpr,
String defaultName,
HiveParserRowResolver inputRR,
boolean includeFuncName,
int colNum) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rex.RexNode |
HiveParserRexNodeConverter.convert(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.hadoop.hive.ql.plan.ExprNodeDesc joinCondnExprNode,
List<org.apache.calcite.rel.RelNode> inputRels,
LinkedHashMap<org.apache.calcite.rel.RelNode,HiveParserRowResolver> relToHiveRR,
Map<org.apache.calcite.rel.RelNode,Map<String,Integer>> relToHiveColNameCalcitePosMap,
boolean flattenExpr,
SqlFunctionConverter funcConverter) |
Constructor and Description |
---|
HiveParserRexNodeConverter(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.rel.type.RelDataType inpDataType,
Map<String,Integer> outerNameToPos,
Map<String,Integer> nameToPos,
HiveParserRowResolver hiveRR,
HiveParserRowResolver outerRR,
int offset,
boolean flattenExpr,
int correlatedId,
SqlFunctionConverter funcConverter) |
Modifier and Type | Method and Description |
---|---|
static HiveParserRowResolver |
HiveParserRowResolver.getCombinedRR(HiveParserRowResolver leftRR,
HiveParserRowResolver rightRR)
Return a new row resolver that is combination of left RR and right RR.
|
HiveParserRowResolver |
HiveParserTypeCheckCtx.getInputRR() |
HiveParserRowResolver |
HiveParserTypeCheckCtx.getOuterRR() |
Modifier and Type | Method and Description |
---|---|
List<HiveParserRowResolver> |
HiveParserJoinTypeCheckCtx.getInputRRList() |
Modifier and Type | Method and Description |
---|---|
static boolean |
HiveParserRowResolver.add(HiveParserRowResolver rrToAddTo,
HiveParserRowResolver rrToAddFrom) |
static void |
HiveParserBaseSemanticAnalyzer.addToGBExpr(HiveParserRowResolver groupByOutputRowResolver,
HiveParserRowResolver groupByInputRowResolver,
HiveParserASTNode grpbyExpr,
org.apache.hadoop.hive.ql.plan.ExprNodeDesc grpbyExprNDesc,
List<org.apache.hadoop.hive.ql.plan.ExprNodeDesc> gbExprNDescLst,
List<String> outputColumnNames) |
static Map<String,Integer> |
HiveParserBaseSemanticAnalyzer.buildHiveColNameToInputPosMap(List<org.apache.hadoop.hive.ql.plan.ExprNodeDesc> colList,
HiveParserRowResolver inputRR) |
static Map<String,Integer> |
HiveParserBaseSemanticAnalyzer.buildHiveToCalciteColumnMap(HiveParserRowResolver rr) |
void |
HiveParserSemanticAnalyzer.checkExpressionsForGroupingSet(List<HiveParserASTNode> grpByExprs,
List<HiveParserASTNode> distinctGrpByExprs,
Map<String,HiveParserASTNode> aggregationTrees,
HiveParserRowResolver inputRowResolver) |
Map<HiveParserASTNode,org.apache.hadoop.hive.ql.plan.ExprNodeDesc> |
HiveParserSemanticAnalyzer.genAllExprNodeDesc(HiveParserASTNode expr,
HiveParserRowResolver input)
Generates an expression node descriptors for the expression and children of it with default
HiveParserTypeCheckCtx.
|
Map<HiveParserASTNode,org.apache.hadoop.hive.ql.plan.ExprNodeDesc> |
HiveParserSemanticAnalyzer.genAllExprNodeDesc(HiveParserASTNode expr,
HiveParserRowResolver input,
HiveParserTypeCheckCtx tcCtx)
Generates all of the expression node descriptors for the expression and children of it passed
in the arguments.
|
Integer |
HiveParserSemanticAnalyzer.genColListRegex(String colRegex,
String tabAlias,
HiveParserASTNode sel,
ArrayList<org.apache.hadoop.hive.ql.plan.ExprNodeDesc> colList,
HashSet<org.apache.hadoop.hive.ql.exec.ColumnInfo> excludeCols,
HiveParserRowResolver input,
HiveParserRowResolver colSrcRR,
Integer pos,
HiveParserRowResolver output,
List<String> aliases,
boolean ensureUniqueCols) |
org.apache.hadoop.hive.ql.plan.ExprNodeDesc |
HiveParserSemanticAnalyzer.genExprNodeDesc(HiveParserASTNode expr,
HiveParserRowResolver input) |
org.apache.hadoop.hive.ql.plan.ExprNodeDesc |
HiveParserSemanticAnalyzer.genExprNodeDesc(HiveParserASTNode expr,
HiveParserRowResolver input,
HiveParserRowResolver outerRR,
Map<HiveParserASTNode,org.apache.calcite.rel.RelNode> subqueryToRelNode,
boolean useCaching) |
org.apache.hadoop.hive.ql.plan.ExprNodeDesc |
HiveParserSemanticAnalyzer.genExprNodeDesc(HiveParserASTNode expr,
HiveParserRowResolver input,
HiveParserTypeCheckCtx tcCtx)
Returns expression node descriptor for the expression.
|
static org.apache.calcite.rel.RelNode |
HiveParserBaseSemanticAnalyzer.genValues(String tabAlias,
org.apache.hadoop.hive.ql.metadata.Table tmpTable,
HiveParserRowResolver rowResolver,
org.apache.calcite.plan.RelOptCluster cluster,
List<List<String>> values) |
static HiveParserRowResolver |
HiveParserRowResolver.getCombinedRR(HiveParserRowResolver leftRR,
HiveParserRowResolver rightRR)
Return a new row resolver that is combination of left RR and right RR.
|
static HiveParserBaseSemanticAnalyzer.AggInfo |
HiveParserBaseSemanticAnalyzer.getHiveAggInfo(HiveParserASTNode aggAst,
int aggFnLstArgIndx,
HiveParserRowResolver inputRR,
HiveParserWindowingSpec.WindowFunctionSpec winFuncSpec,
HiveParserSemanticAnalyzer semanticAnalyzer,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster) |
static List<org.apache.calcite.rex.RexFieldCollation> |
HiveParserBaseSemanticAnalyzer.getOrderKeys(HiveParserPTFInvocationSpec.OrderSpec orderSpec,
HiveParserRexNodeConverter converter,
HiveParserRowResolver inputRR,
HiveParserTypeCheckCtx typeCheckCtx,
HiveParserSemanticAnalyzer semanticAnalyzer) |
static List<org.apache.calcite.rex.RexNode> |
HiveParserBaseSemanticAnalyzer.getPartitionKeys(HiveParserPTFInvocationSpec.PartitionSpec partitionSpec,
HiveParserRexNodeConverter converter,
HiveParserRowResolver inputRR,
HiveParserTypeCheckCtx typeCheckCtx,
HiveParserSemanticAnalyzer semanticAnalyzer) |
static org.apache.calcite.rel.type.RelDataType |
HiveParserTypeConverter.getType(org.apache.calcite.plan.RelOptCluster cluster,
HiveParserRowResolver rr,
List<String> neededCols) |
void |
HiveParserTypeCheckCtx.setInputRR(HiveParserRowResolver inputRR) |
void |
HiveParserTypeCheckCtx.setOuterRR(HiveParserRowResolver outerRR) |
boolean |
HiveParserQBSubQuery.subqueryRestrictionsCheck(HiveParserRowResolver parentQueryRR,
boolean forHavingClause,
String outerQueryAlias) |
static void |
HiveParserBaseSemanticAnalyzer.validateNoHavingReferenceToAlias(HiveParserQB qb,
HiveParserASTNode havingExpr,
HiveParserRowResolver inputRR,
HiveParserSemanticAnalyzer semanticAnalyzer) |
Constructor and Description |
---|
HiveParserJoinTypeCheckCtx(HiveParserRowResolver leftRR,
HiveParserRowResolver rightRR,
org.apache.hadoop.hive.ql.parse.JoinType hiveJoinType,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster) |
HiveParserTypeCheckCtx(HiveParserRowResolver inputRR,
boolean useCaching,
boolean foldExpr,
boolean allowStatefulFunctions,
boolean allowDistinctFunctions,
boolean allowGBExprElimination,
boolean allowAllColRef,
boolean allowFunctionStar,
boolean allowWindowing,
boolean allowIndexExpr,
boolean allowSubQueryExpr,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster) |
HiveParserTypeCheckCtx(HiveParserRowResolver inputRR,
boolean useCaching,
boolean foldExpr,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster) |
HiveParserTypeCheckCtx(HiveParserRowResolver inputRR,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster)
Constructor.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.