Modifier and Type | Method and Description |
---|---|
PrunedPartitionList |
FixedBucketPruningOptimizer.FixedBucketPruningOptimizerCtxt.getPartitions() |
Modifier and Type | Method and Description |
---|---|
static void |
GenMapRedUtils.setMapWork(MapWork plan,
ParseContext parseCtx,
Set<ReadEntity> inputs,
PrunedPartitionList partsList,
TableScanOperator tsOp,
String alias_id,
HiveConf conf,
boolean local)
initialize MapWork
|
void |
FixedBucketPruningOptimizer.FixedBucketPruningOptimizerCtxt.setPartitions(PrunedPartitionList partitions) |
static void |
GenMapRedUtils.setTaskPlan(String alias_id,
TableScanOperator topOp,
Task<?> task,
boolean local,
GenMRProcContext opProcCtx,
PrunedPartitionList pList)
set the current task in the mapredWork.
|
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) |
Modifier and Type | Method and Description |
---|---|
PrunedPartitionList |
LBOpPartitionWalkerCtx.getPartitions()
Return partitions.
|
Modifier and Type | Method and Description |
---|---|
void |
LBOpPartitionWalkerCtx.setPartitions(PrunedPartitionList partitions)
Set partitions.
|
Modifier and Type | Method and Description |
---|---|
boolean |
OpTraitsRulesProcFactory.TableScanRule.checkBucketedTable(Table tbl,
ParseContext pGraphContext,
PrunedPartitionList prunedParts) |
Modifier and Type | Method and Description |
---|---|
static PrunedPartitionList |
PartitionPruner.prune(Table tab,
ExprNodeDesc prunerExpr,
HiveConf conf,
String alias,
Map<String,PrunedPartitionList> prunedPartitionsMap)
Get the partition list for the table that satisfies the partition pruner
condition.
|
static PrunedPartitionList |
PartitionPruner.prune(TableScanOperator ts,
ParseContext parseCtx,
String alias)
Get the partition list for the TS operator that satisfies the partition pruner
condition.
|
Modifier and Type | Method and Description |
---|---|
static PrunedPartitionList |
PartitionPruner.prune(Table tab,
ExprNodeDesc prunerExpr,
HiveConf conf,
String alias,
Map<String,PrunedPartitionList> prunedPartitionsMap)
Get the partition list for the table that satisfies the partition pruner
condition.
|
Modifier and Type | Method and Description |
---|---|
PrunedPartitionList |
ParseContext.getPrunedPartitions(String alias,
TableScanOperator ts) |
PrunedPartitionList |
ParseContext.getPrunedPartitions(TableScanOperator ts) |
Modifier and Type | Method and Description |
---|---|
HashMap<TableScanOperator,PrunedPartitionList> |
ParseContext.getOpToPartList() |
Map<String,PrunedPartitionList> |
ParseContext.getPrunedPartitions() |
Modifier and Type | Method and Description |
---|---|
MapWork |
GenTezUtils.createMapWork(GenTezProcContext context,
Operator<?> root,
TezWork tezWork,
PrunedPartitionList partitions) |
protected void |
GenTezUtils.setupMapWork(MapWork mapWork,
GenTezProcContext context,
PrunedPartitionList partitions,
TableScanOperator root,
String alias) |
Modifier and Type | Method and Description |
---|---|
void |
ParseContext.setPrunedPartitions(Map<String,PrunedPartitionList> prunedPartitions) |
Modifier and Type | Method and Description |
---|---|
MapWork |
GenSparkUtils.createMapWork(GenSparkProcContext context,
Operator<?> root,
SparkWork sparkWork,
PrunedPartitionList partitions) |
MapWork |
GenSparkUtils.createMapWork(GenSparkProcContext context,
Operator<?> root,
SparkWork sparkWork,
PrunedPartitionList partitions,
boolean deferSetup) |
protected void |
GenSparkUtils.setupMapWork(MapWork mapWork,
GenSparkProcContext context,
PrunedPartitionList partitions,
TableScanOperator root,
String alias) |
Modifier and Type | Method and Description |
---|---|
PrunedPartitionList |
StatsNoJobWork.getPrunedPartitionList() |
Modifier and Type | Method and Description |
---|---|
void |
StatsNoJobWork.setPrunedPartitionList(PrunedPartitionList prunedPartitionList) |
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 Statistics |
StatsUtils.collectStatistics(HiveConf conf,
PrunedPartitionList partList,
Table table,
TableScanOperator tableScanOperator)
Collect table, partition and column level statistics
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.