public class HiveTableScan extends org.apache.calcite.rel.core.TableScan implements HiveRelNode
Additional operations might be applied, using the "find" or "aggregate" methods.
HiveRelNode.Implementor
CONVENTION
Constructor and Description |
---|
HiveTableScan(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
RelOptHiveTable table,
String alias,
String concatQbIDAlias,
boolean useQBIdInDigest,
boolean insideView)
Creates a HiveTableScan.
|
Modifier and Type | Method and Description |
---|---|
String |
computeDigest() |
org.apache.calcite.plan.RelOptCost |
computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner,
org.apache.calcite.rel.metadata.RelMetadataQuery mq) |
HiveTableScan |
copy(org.apache.calcite.rel.type.RelDataType newRowtype)
Copy TableScan operator with a new Row Schema.
|
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
double |
estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq) |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
List<ColStatistics> |
getColStat(List<Integer> projIndxLst) |
String |
getConcatQbIDAlias() |
List<Integer> |
getNeededColIndxsFrmReloptHT() |
Set<Integer> |
getPartOrVirtualCols() |
org.apache.calcite.rel.type.RelDataType |
getPrunedRowType() |
String |
getTableAlias() |
void |
implement(HiveRelNode.Implementor implementor) |
boolean |
isInsideView() |
org.apache.calcite.rel.RelNode |
project(org.apache.calcite.util.ImmutableBitSet fieldsUsed,
Set<org.apache.calcite.rel.type.RelDataTypeField> extraFields,
org.apache.calcite.tools.RelBuilder relBuilder) |
void |
register(org.apache.calcite.plan.RelOptPlanner planner) |
accept, deriveRowType, getCollationList, getTable, identity, identity
accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, explain, getChildExps, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, replaceInput, sole, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, replaceInput
public HiveTableScan(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, RelOptHiveTable table, String alias, String concatQbIDAlias, boolean useQBIdInDigest, boolean insideView)
cluster
- ClustertraitSet
- Traitstable
- Tabletable
- HiveDB tablepublic String getTableAlias()
public String getConcatQbIDAlias()
public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
copy
in interface org.apache.calcite.rel.RelNode
copy
in class org.apache.calcite.rel.AbstractRelNode
public HiveTableScan copy(org.apache.calcite.rel.type.RelDataType newRowtype)
newRowtype
- public org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
computeSelfCost
in interface org.apache.calcite.rel.RelNode
computeSelfCost
in class org.apache.calcite.rel.core.TableScan
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.core.TableScan
public void register(org.apache.calcite.plan.RelOptPlanner planner)
register
in interface org.apache.calcite.rel.RelNode
register
in class org.apache.calcite.rel.AbstractRelNode
public void implement(HiveRelNode.Implementor implementor)
implement
in interface HiveRelNode
public double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq)
estimateRowCount
in interface org.apache.calcite.rel.RelNode
estimateRowCount
in class org.apache.calcite.rel.core.TableScan
public List<ColStatistics> getColStat(List<Integer> projIndxLst)
public org.apache.calcite.rel.RelNode project(org.apache.calcite.util.ImmutableBitSet fieldsUsed, Set<org.apache.calcite.rel.type.RelDataTypeField> extraFields, org.apache.calcite.tools.RelBuilder relBuilder)
project
in class org.apache.calcite.rel.core.TableScan
public org.apache.calcite.rel.type.RelDataType getPrunedRowType()
public boolean isInsideView()
public String computeDigest()
computeDigest
in class org.apache.calcite.rel.AbstractRelNode
Copyright © 2016 The Apache Software Foundation. All rights reserved.