org.apache.hadoop.hive.ql.optimizer.calcite

Class RelOptHiveTable

java.lang.Object

org.apache.calcite.plan.RelOptAbstractTable

org.apache.hadoop.hive.ql.optimizer.calcite.RelOptHiveTable

All Implemented Interfaces:

org.apache.calcite.plan.RelOptTable

public class RelOptHiveTable
extends org.apache.calcite.plan.RelOptAbstractTable

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.plan.RelOptTable

org.apache.calcite.plan.RelOptTable.ToRelContext, org.apache.calcite.plan.RelOptTable.ViewExpander

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Fields inherited from class org.apache.calcite.plan.RelOptAbstractTable

name, rowType, schema

Constructor Summary

Constructors

Constructor and Description
RelOptHiveTable(org.apache.calcite.plan.RelOptSchema calciteSchema, String qualifiedTblName, org.apache.calcite.rel.type.RelDataType rowType, Table hiveTblMetadata, List<ColumnInfo> hiveNonPartitionCols, List<ColumnInfo> hivePartitionCols, List<VirtualColumn> hiveVirtualCols, HiveConf hconf, Map<String,PrunedPartitionList> partitionCache, AtomicInteger noColsMissingStats)

Method Summary

Modifier and Type	Method and Description
void	computePartitionList(HiveConf conf, org.apache.calcite.rex.RexNode pruneNode, Set<Integer> partOrVirtualCols)
boolean	containsPartitionColumnsOnly(org.apache.calcite.util.ImmutableBitSet cols)
RelOptHiveTable	copy(org.apache.calcite.rel.type.RelDataType newRowType)
List<org.apache.calcite.rel.RelCollation>	getCollationList()
List<ColStatistics>	getColStat(List<Integer> projIndxLst)
List<ColStatistics>	getColStat(List<Integer> projIndxLst, boolean allowNullColumnForMissingStats)
org.apache.calcite.rel.RelDistribution	getDistribution()
Table	getHiveTableMD()
Map<Integer,ColumnInfo>	getNonPartColInfoMap()
List<ColumnInfo>	getNonPartColumns()
int	getNoOfNonVirtualCols()
Map<Integer,ColumnInfo>	getPartColInfoMap()
List<ColumnInfo>	getPartColumns()
double	getRowCount()
List<VirtualColumn>	getVirtualCols()
boolean	isKey(org.apache.calcite.util.ImmutableBitSet arg0)
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context)
<T> T	unwrap(Class<T> arg0)

Methods inherited from class org.apache.calcite.plan.RelOptAbstractTable

extend, getExpression, getName, getQualifiedName, getRelOptSchema, getRowType

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

RelOptHiveTable

public RelOptHiveTable(org.apache.calcite.plan.RelOptSchema calciteSchema,
                       String qualifiedTblName,
                       org.apache.calcite.rel.type.RelDataType rowType,
                       Table hiveTblMetadata,
                       List<ColumnInfo> hiveNonPartitionCols,
                       List<ColumnInfo> hivePartitionCols,
                       List<VirtualColumn> hiveVirtualCols,
                       HiveConf hconf,
                       Map<String,PrunedPartitionList> partitionCache,
                       AtomicInteger noColsMissingStats)

Method Detail

copy

public RelOptHiveTable copy(org.apache.calcite.rel.type.RelDataType newRowType)

isKey

public boolean isKey(org.apache.calcite.util.ImmutableBitSet arg0)

Specified by:

isKey in interface org.apache.calcite.plan.RelOptTable

Overrides:

isKey in class org.apache.calcite.plan.RelOptAbstractTable

toRel

public org.apache.calcite.rel.RelNode toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context)

Specified by:

toRel in interface org.apache.calcite.plan.RelOptTable

Overrides:

toRel in class org.apache.calcite.plan.RelOptAbstractTable

unwrap

public <T> T unwrap(Class<T> arg0)

Specified by:

unwrap in interface org.apache.calcite.plan.RelOptTable

Overrides:

unwrap in class org.apache.calcite.plan.RelOptAbstractTable

getCollationList

public List<org.apache.calcite.rel.RelCollation> getCollationList()

Specified by:

getCollationList in interface org.apache.calcite.plan.RelOptTable

Overrides:

getCollationList in class org.apache.calcite.plan.RelOptAbstractTable

getDistribution

public org.apache.calcite.rel.RelDistribution getDistribution()

Specified by:

getDistribution in interface org.apache.calcite.plan.RelOptTable

Overrides:

getDistribution in class org.apache.calcite.plan.RelOptAbstractTable

getRowCount

public double getRowCount()

Specified by:

getRowCount in interface org.apache.calcite.plan.RelOptTable

Overrides:

getRowCount in class org.apache.calcite.plan.RelOptAbstractTable

getHiveTableMD

public Table getHiveTableMD()

computePartitionList

public void computePartitionList(HiveConf conf,
                                 org.apache.calcite.rex.RexNode pruneNode,
                                 Set<Integer> partOrVirtualCols)

getColStat

public List<ColStatistics> getColStat(List<Integer> projIndxLst)

getColStat

public List<ColStatistics> getColStat(List<Integer> projIndxLst,
                                      boolean allowNullColumnForMissingStats)

containsPartitionColumnsOnly

public boolean containsPartitionColumnsOnly(org.apache.calcite.util.ImmutableBitSet cols)

getVirtualCols

public List<VirtualColumn> getVirtualCols()

getPartColumns

public List<ColumnInfo> getPartColumns()

getNonPartColumns

public List<ColumnInfo> getNonPartColumns()

getNoOfNonVirtualCols

public int getNoOfNonVirtualCols()

getPartColInfoMap

public Map<Integer,ColumnInfo> getPartColInfoMap()

getNonPartColInfoMap

public Map<Integer,ColumnInfo> getNonPartColInfoMap()