Modifier and Type | Method and Description |
---|---|
static HiveCalciteUtil.JoinPredicateInfo |
HiveCalciteUtil.JoinPredicateInfo.constructJoinPredicateInfo(HiveMultiJoin mj) |
static HiveCalciteUtil.JoinPredicateInfo |
HiveCalciteUtil.JoinPredicateInfo.constructJoinPredicateInfo(HiveMultiJoin mj,
org.apache.calcite.rex.RexNode predicate) |
static HiveCalciteUtil.JoinPredicateInfo |
HiveCalciteUtil.JoinPredicateInfo.constructJoinPredicateInfo(org.apache.calcite.rel.core.Join j) |
static HiveCalciteUtil.JoinPredicateInfo |
HiveCalciteUtil.JoinPredicateInfo.constructJoinPredicateInfo(org.apache.calcite.rel.core.Join j,
org.apache.calcite.rex.RexNode predicate) |
static HiveCalciteUtil.JoinPredicateInfo |
HiveCalciteUtil.JoinPredicateInfo.constructJoinPredicateInfo(List<org.apache.calcite.rel.RelNode> inputs,
List<org.apache.calcite.rel.type.RelDataTypeField> systemFieldList,
org.apache.calcite.rex.RexNode predicate) |
static org.apache.calcite.rex.RexNode |
HiveRelOptUtil.splitHiveJoinCondition(List<org.apache.calcite.rel.type.RelDataTypeField> sysFieldList,
List<org.apache.calcite.rel.RelNode> inputs,
org.apache.calcite.rex.RexNode condition,
List<List<org.apache.calcite.rex.RexNode>> joinKeys,
List<Integer> filterNulls,
List<org.apache.calcite.sql.SqlOperator> rangeOp)
Splits out the equi-join (and optionally, a single non-equi) components
of a join condition, and returns what's left.
|
Modifier and Type | Method and Description |
---|---|
static HiveProject |
HiveProject.create(org.apache.calcite.rel.RelNode child,
List<? extends org.apache.calcite.rex.RexNode> exps,
List<String> fieldNames)
Creates a HiveProject with no sort keys.
|
org.apache.calcite.util.ImmutableBitSet |
HiveJoin.getSortedInputs() |
static org.apache.calcite.rel.RelNode |
HiveProject.projectMapping(org.apache.calcite.rel.RelNode rel,
org.apache.calcite.util.mapping.Mapping mapping,
List<String> fieldNames)
Creates a relational expression which projects the output fields of a
relational expression according to a partial mapping.
|
Constructor and Description |
---|
HiveJoin(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
org.apache.calcite.rel.RelNode left,
org.apache.calcite.rel.RelNode right,
org.apache.calcite.rex.RexNode condition,
org.apache.calcite.rel.core.JoinRelType joinType,
Set<String> variablesStopped,
HiveCostModel.JoinAlgorithm joinAlgo,
boolean leftSemiJoin) |
HiveSemiJoin(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode left,
org.apache.calcite.rel.RelNode right,
org.apache.calcite.rex.RexNode condition,
org.apache.calcite.util.ImmutableIntList leftKeys,
org.apache.calcite.util.ImmutableIntList rightKeys) |
Modifier and Type | Method and Description |
---|---|
Double |
HiveRelMdSelectivity.getSelectivity(HiveJoin j,
org.apache.calcite.rel.metadata.RelMetadataQuery mq,
org.apache.calcite.rex.RexNode predicate) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.calcite.rex.RexNode |
RexNodeConverter.convert(ExprNodeConstantDesc literal) |
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.convert(ListTypeInfo lstType,
org.apache.calcite.rel.type.RelDataTypeFactory dtFactory) |
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.convert(MapTypeInfo mapType,
org.apache.calcite.rel.type.RelDataTypeFactory dtFactory) |
static ASTNode |
ASTConverter.convert(org.apache.calcite.rel.RelNode relNode,
List<FieldSchema> resultSchema,
boolean alignColumns) |
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.convert(StructTypeInfo structType,
org.apache.calcite.rel.type.RelDataTypeFactory dtFactory) |
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.convert(TypeInfo type,
org.apache.calcite.rel.type.RelDataTypeFactory dtFactory) |
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.convert(UnionTypeInfo unionType,
org.apache.calcite.rel.type.RelDataTypeFactory dtFactory) |
static org.apache.calcite.rel.RelNode |
PlanModifierForReturnPath.convertOpTree(org.apache.calcite.rel.RelNode rel,
List<FieldSchema> resultSchema,
boolean isCTAS) |
static org.apache.calcite.rel.RelNode |
PlanModifierForASTConv.convertOpTree(org.apache.calcite.rel.RelNode rel,
List<FieldSchema> resultSchema,
boolean alignColumns) |
protected static void |
PlanModifierUtil.fixTopOBSchema(org.apache.calcite.rel.RelNode rootRel,
org.apache.calcite.util.Pair<org.apache.calcite.rel.RelNode,org.apache.calcite.rel.RelNode> topSelparentPair,
List<FieldSchema> resultSchema,
boolean replaceProject) |
static org.apache.calcite.sql.SqlOperator |
SqlFunctionConverter.getCalciteFn(String hiveUdfName,
com.google.common.collect.ImmutableList<org.apache.calcite.rel.type.RelDataType> calciteArgTypes,
org.apache.calcite.rel.type.RelDataType calciteRetType,
boolean deterministic) |
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.getType(org.apache.calcite.plan.RelOptCluster cluster,
List<ColumnInfo> cInfoLst)
Convert Hive Types To Calcite Types
|
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.getType(org.apache.calcite.plan.RelOptCluster cluster,
RowResolver rr,
List<String> neededCols) |
static org.apache.calcite.rel.RelNode |
PlanModifierForASTConv.renameTopLevelSelectInResultSchema(org.apache.calcite.rel.RelNode rootRel,
org.apache.calcite.util.Pair<org.apache.calcite.rel.RelNode,org.apache.calcite.rel.RelNode> topSelparentPair,
List<FieldSchema> resultSchema) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.