Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.metadata | |
org.apache.hadoop.hive.ql.optimizer | |
org.apache.hadoop.hive.ql.optimizer.calcite | |
org.apache.hadoop.hive.ql.optimizer.calcite.translator | |
org.apache.hadoop.hive.ql.optimizer.lineage | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan | |
org.apache.hadoop.hive.ql.stats |
Modifier and Type | Method and Description |
---|---|
ColumnInfo |
RowSchema.getColumnInfo(String internalName) |
ColumnInfo |
RowSchema.getColumnInfo(String tabAlias,
String alias) |
Modifier and Type | Method and Description |
---|---|
ArrayList<ColumnInfo> |
RowSchema.getSignature() |
Modifier and Type | Method and Description |
---|---|
boolean |
ColumnInfo.internalEquals(ColumnInfo dest) |
boolean |
ColumnInfo.isSameColumnForRR(ColumnInfo other) |
Modifier and Type | Method and Description |
---|---|
static List<String> |
Utilities.getInternalColumnNamesFromSignature(List<ColumnInfo> colInfos) |
void |
RowSchema.setSignature(ArrayList<ColumnInfo> signature) |
Constructor and Description |
---|
ColumnInfo(ColumnInfo columnInfo) |
Constructor and Description |
---|
RowSchema(ArrayList<ColumnInfo> signature) |
Modifier and Type | Method and Description |
---|---|
static boolean |
VirtualColumn.isVirtualColumnBasedOnAlias(ColumnInfo column) |
Modifier and Type | Method and Description |
---|---|
static ColumnInfo |
ConstantPropagateProcFactory.resolveColumn(RowSchema rs,
ExprNodeColumnDesc desc)
Get ColumnInfo from column expression.
|
Modifier and Type | Method and Description |
---|---|
Map<Operator<? extends Serializable>,Map<ColumnInfo,ExprNodeDesc>> |
ConstantPropagateProcCtx.getOpToConstantExprs() |
Map<ColumnInfo,ExprNodeDesc> |
ConstantPropagateProcCtx.getPropagatedConstants(Operator<? extends Serializable> op)
Get propagated constant map from parents.
|
Modifier and Type | Method and Description |
---|---|
Map<Integer,ColumnInfo> |
RelOptHiveTable.getNonPartColInfoMap() |
List<ColumnInfo> |
RelOptHiveTable.getNonPartColumns() |
Map<Integer,ColumnInfo> |
RelOptHiveTable.getPartColInfoMap() |
List<ColumnInfo> |
RelOptHiveTable.getPartColumns() |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.type.RelDataType |
TypeConverter.getType(org.apache.calcite.plan.RelOptCluster cluster,
List<ColumnInfo> cInfoLst)
Convert Hive Types To Calcite Types
|
Modifier and Type | Method and Description |
---|---|
Map<ColumnInfo,LineageInfo.Dependency> |
LineageCtx.Index.getDependencies(Operator<? extends OperatorDesc> op) |
Modifier and Type | Method and Description |
---|---|
LineageInfo.Dependency |
LineageCtx.Index.getDependency(Operator<? extends OperatorDesc> op,
ColumnInfo col)
Gets the dependency for an operator, columninfo tuple.
|
void |
LineageCtx.Index.mergeDependency(Operator<? extends OperatorDesc> op,
ColumnInfo ci,
LineageInfo.Dependency dep)
Merges the new dependencies in dep to the existing dependencies
of (op, ci).
|
void |
LineageCtx.Index.putDependency(Operator<? extends OperatorDesc> op,
ColumnInfo col,
LineageInfo.Dependency dep)
Puts the dependency for an operator, columninfo tuple.
|
Modifier and Type | Method and Description |
---|---|
ColumnInfo |
RowResolver.get(String tab_alias,
String col_alias)
Gets the column Info to tab_alias.col_alias type of a column reference.
|
ColumnInfo |
RowResolver.getExpression(ASTNode node)
Retrieves the ColumnInfo corresponding to a source expression which
exactly matches the string rendering of the given ASTNode.
|
Modifier and Type | Method and Description |
---|---|
ArrayList<ColumnInfo> |
RowResolver.getColumnInfos() |
HashMap<String,ColumnInfo> |
RowResolver.getFieldMap(String tabAlias) |
LinkedHashMap<String,LinkedHashMap<String,ColumnInfo>> |
RowResolver.getRslvMap() |
Modifier and Type | Method and Description |
---|---|
boolean |
RowResolver.addMappingOnly(String tab_alias,
String col_alias,
ColumnInfo colInfo) |
static ASTNode |
PTFTranslator.getASTNode(ColumnInfo cInfo,
RowResolver rr) |
void |
RowResolver.put(String tab_alias,
String col_alias,
ColumnInfo colInfo) |
void |
RowResolver.putExpression(ASTNode node,
ColumnInfo colInfo)
Puts a resolver entry corresponding to a source expression which is to be
used for identical expression recognition (e.g.
|
boolean |
RowResolver.putWithCheck(String tabAlias,
String colAlias,
String internalName,
ColumnInfo newCI)
Adds column to RR, checking for duplicate columns.
|
Modifier and Type | Method and Description |
---|---|
static List<FieldSchema> |
PlanUtils.getFieldSchemasFromColumnInfo(ArrayList<ColumnInfo> cols,
String fieldPrefix)
Convert the ColumnInfo to FieldSchema.
|
Constructor and Description |
---|
ExprNodeColumnDesc(ColumnInfo ci) |
Modifier and Type | Method and Description |
---|---|
static Statistics |
StatsUtils.collectStatistics(HiveConf conf,
PrunedPartitionList partList,
Table table,
List<ColumnInfo> schema,
List<String> neededColumns,
List<String> referencedColumns,
boolean fetchColStats,
boolean fetchPartStats) |
static int |
StatsUtils.estimateRowSizeFromSchema(HiveConf conf,
List<ColumnInfo> schema,
List<String> neededColumns) |
static List<ColStatistics> |
StatsUtils.getTableColumnStats(Table table,
List<ColumnInfo> schema,
List<String> neededColumns)
Get table level column statistics from metastore for needed columns
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.