Modifier and Type | Method and Description |
---|---|
void |
AbstractIndexHandler.generateIndexQuery(Index index,
ExprNodeDesc predicate,
ParseContext pctx,
HiveIndexQueryContext queryContext) |
void |
HiveIndexHandler.generateIndexQuery(List<Index> indexes,
ExprNodeDesc predicate,
ParseContext pctx,
HiveIndexQueryContext queryContext)
Generate the list of tasks required to run an index optimized sub-query for the
given predicate, using the given indexes.
|
Modifier and Type | Method and Description |
---|---|
void |
BitmapIndexHandler.generateIndexQuery(List<Index> indexes,
ExprNodeDesc predicate,
ParseContext pctx,
HiveIndexQueryContext queryContext) |
Modifier and Type | Method and Description |
---|---|
void |
CompactIndexHandler.generateIndexQuery(List<Index> indexes,
ExprNodeDesc predicate,
ParseContext pctx,
HiveIndexQueryContext queryContext) |
Modifier and Type | Field and Description |
---|---|
ParseContext |
FixedBucketPruningOptimizer.FixedBucketPruningOptimizerCtxt.pctx |
protected ParseContext |
GroupByOptimizer.SortGroupByProcessor.pGraphContext |
protected ParseContext |
ConstantPropagate.pGraphContext |
protected ParseContext |
ColumnPruner.pGraphContext |
protected ParseContext |
BucketingSortingReduceSinkOptimizer.BucketSortReduceSinkProcessor.pGraphContext |
protected ParseContext |
AbstractBucketJoinProc.pGraphContext |
Modifier and Type | Method and Description |
---|---|
ParseContext |
ColumnPrunerProcCtx.getParseContext() |
ParseContext |
GenMRProcContext.getParseCtx() |
ParseContext |
Optimizer.getPctx() |
ParseContext |
SkewJoinOptimizer.SkewJoinOptProcCtx.getpGraphContext() |
ParseContext |
MapJoinProcessor.MapJoinWalkerCtx.getpGraphContext() |
ParseContext |
Optimizer.optimize()
Invoke all the transformations one-by-one, and alter the query plan.
|
abstract ParseContext |
Transform.transform(ParseContext pctx)
All transformation steps implement this interface.
|
ParseContext |
StatsOptimizer.transform(ParseContext pctx) |
ParseContext |
SortedMergeBucketMapJoinOptimizer.transform(ParseContext pctx) |
ParseContext |
SortedDynPartitionOptimizer.transform(ParseContext pCtx) |
ParseContext |
SkewJoinOptimizer.transform(ParseContext pctx) |
ParseContext |
SimpleFetchOptimizer.transform(ParseContext pctx) |
ParseContext |
SimpleFetchAggregation.transform(ParseContext pctx) |
ParseContext |
SamplePruner.transform(ParseContext pctx) |
ParseContext |
RedundantDynamicPruningConditionsRemoval.transform(ParseContext pctx)
Transform the query tree.
|
ParseContext |
PointLookupOptimizer.transform(ParseContext pctx) |
ParseContext |
PartitionColumnsSeparator.transform(ParseContext pctx) |
ParseContext |
NonBlockingOpDeDupProc.transform(ParseContext pctx) |
ParseContext |
MapJoinProcessor.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
LimitPushdownOptimizer.transform(ParseContext pctx) |
ParseContext |
JoinReorder.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
IdentityProjectRemover.transform(ParseContext pctx) |
ParseContext |
GroupByOptimizer.transform(ParseContext pctx) |
ParseContext |
GlobalLimitOptimizer.transform(ParseContext pctx) |
ParseContext |
FixedBucketPruningOptimizer.transform(ParseContext pctx) |
ParseContext |
ConstantPropagate.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
ColumnPruner.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
BucketMapJoinOptimizer.transform(ParseContext pctx) |
ParseContext |
BucketingSortingReduceSinkOptimizer.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
static void |
BucketMapjoinProc.checkAndConvertBucketMapJoin(ParseContext pGraphContext,
MapJoinOperator mapJoinOp,
String baseBigAlias,
List<String> joinAliases)
Check if a mapjoin can be converted to a bucket mapjoin,
and do the version if possible.
|
static Set<Partition> |
IndexUtils.checkPartitionsCoveredByIndex(TableScanOperator tableScan,
ParseContext pctx,
List<Index> indexes)
Check the partitions used by the table scan to make sure they also exist in the
index table.
|
static org.apache.hadoop.fs.Path |
GenMapRedUtils.createMoveTask(Task<? extends Serializable> currTask,
boolean chDir,
FileSinkOperator fsOp,
ParseContext parseCtx,
List<Task<MoveWork>> mvTasks,
HiveConf hconf,
DependencyCollectionTask dependencyTask)
Create and add any dependent move tasks
|
static TableScanOperator |
GenMapRedUtils.createTemporaryFile(Operator<? extends OperatorDesc> parent,
Operator<? extends OperatorDesc> child,
org.apache.hadoop.fs.Path taskTmpDir,
TableDesc tt_desc,
ParseContext parseCtx)
Break the pipeline between parent and child, and then
output data generated by parent to a temporary file stored in taskTmpDir.
|
MapJoinOperator |
MapJoinProcessor.generateMapJoinOperator(ParseContext pctx,
JoinOperator op,
int mapJoinPos) |
protected void |
MapJoinProcessor.genSelectPlan(ParseContext pctx,
MapJoinOperator input) |
int |
TableSizeBasedBigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseCtx,
JoinOperator joinOp,
Set<Integer> bigTableCandidates) |
int |
LeftmostBigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseContext,
JoinOperator joinOp,
Set<Integer> bigTableCandidates) |
int |
BigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseContext,
JoinOperator joinOp,
Set<Integer> joinCandidates) |
int |
AvgPartitionSizeBasedBigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseCtx,
JoinOperator joinOp,
Set<Integer> bigTableCandidates) |
static List<String> |
AbstractBucketJoinProc.getBucketFilePathsOfPartition(org.apache.hadoop.fs.Path location,
ParseContext pGraphContext) |
static MapredWork |
GenMapRedUtils.getMapRedWork(ParseContext parseCtx)
create a new plan and return.
|
static boolean |
GenMapRedUtils.isInsertInto(ParseContext parseCtx,
FileSinkOperator fsOp)
Returns true iff current query is an insert into for the given file sink
|
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 |
GenMRProcContext.setParseCtx(ParseContext parseCtx) |
void |
Optimizer.setPctx(ParseContext pctx) |
void |
MapJoinProcessor.MapJoinWalkerCtx.setpGraphContext(ParseContext pGraphContext) |
void |
SkewJoinOptimizer.SkewJoinOptProcCtx.setPGraphContext(ParseContext graphContext) |
abstract ParseContext |
Transform.transform(ParseContext pctx)
All transformation steps implement this interface.
|
ParseContext |
StatsOptimizer.transform(ParseContext pctx) |
ParseContext |
SortedMergeBucketMapJoinOptimizer.transform(ParseContext pctx) |
ParseContext |
SortedDynPartitionOptimizer.transform(ParseContext pCtx) |
ParseContext |
SkewJoinOptimizer.transform(ParseContext pctx) |
ParseContext |
SimpleFetchOptimizer.transform(ParseContext pctx) |
ParseContext |
SimpleFetchAggregation.transform(ParseContext pctx) |
ParseContext |
SamplePruner.transform(ParseContext pctx) |
ParseContext |
RedundantDynamicPruningConditionsRemoval.transform(ParseContext pctx)
Transform the query tree.
|
ParseContext |
PointLookupOptimizer.transform(ParseContext pctx) |
ParseContext |
PartitionColumnsSeparator.transform(ParseContext pctx) |
ParseContext |
NonBlockingOpDeDupProc.transform(ParseContext pctx) |
ParseContext |
MapJoinProcessor.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
LimitPushdownOptimizer.transform(ParseContext pctx) |
ParseContext |
JoinReorder.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
IdentityProjectRemover.transform(ParseContext pctx) |
ParseContext |
GroupByOptimizer.transform(ParseContext pctx) |
ParseContext |
GlobalLimitOptimizer.transform(ParseContext pctx) |
ParseContext |
FixedBucketPruningOptimizer.transform(ParseContext pctx) |
ParseContext |
ConstantPropagate.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
ColumnPruner.transform(ParseContext pactx)
Transform the query tree.
|
ParseContext |
BucketMapJoinOptimizer.transform(ParseContext pctx) |
ParseContext |
BucketingSortingReduceSinkOptimizer.transform(ParseContext pctx) |
static void |
PrunerUtils.walkOperatorTree(ParseContext pctx,
NodeProcessorCtx opWalkerCtx,
NodeProcessor filterProc,
NodeProcessor defaultProc)
Walk operator tree for pruner generation.
|
Modifier and Type | Method and Description |
---|---|
ParseContext |
HiveOpConverterPostProc.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
HiveOpConverterPostProc.transform(ParseContext pctx) |
Modifier and Type | Field and Description |
---|---|
protected ParseContext |
ReduceSinkDeDuplication.pGraphContext |
Modifier and Type | Method and Description |
---|---|
ParseContext |
ReduceSinkDeDuplication.transform(ParseContext pctx) |
ParseContext |
CorrelationOptimizer.transform(ParseContext pctx)
Detect correlations and transform the query tree.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
QueryPlanTreeTransformation.applyCorrelation(ParseContext pCtx,
CorrelationOptimizer.CorrelationNodeProcCtx corrCtx,
IntraQueryCorrelation correlation)
Based on the correlation, we transform the query plan tree (operator tree).
|
protected static void |
CorrelationUtilities.removeOperator(Operator<?> target,
Operator<?> child,
Operator<?> parent,
ParseContext context) |
static void |
CorrelationUtilities.removeOperator(Operator<?> target,
ParseContext context) |
protected static void |
CorrelationUtilities.removeReduceSinkForGroupBy(ReduceSinkOperator cRS,
GroupByOperator cGBYr,
ParseContext context,
org.apache.hadoop.hive.ql.optimizer.correlation.AbstractCorrelationProcCtx procCtx) |
protected static SelectOperator |
CorrelationUtilities.replaceReduceSinkWithSelectOperator(ReduceSinkOperator childRS,
ParseContext context,
org.apache.hadoop.hive.ql.optimizer.correlation.AbstractCorrelationProcCtx procCtx) |
ParseContext |
ReduceSinkDeDuplication.transform(ParseContext pctx) |
ParseContext |
CorrelationOptimizer.transform(ParseContext pctx)
Detect correlations and transform the query tree.
|
Constructor and Description |
---|
CorrelationNodeProcCtx(ParseContext pctx) |
ReduceSinkDeduplicateProcCtx(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
RewriteQueryUsingAggregateIndexCtx.getParseContext() |
ParseContext |
RewriteCanApplyCtx.getParseContext() |
ParseContext |
RewriteGBUsingIndex.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
static RewriteCanApplyCtx |
RewriteCanApplyCtx.getInstance(ParseContext parseContext) |
static RewriteQueryUsingAggregateIndexCtx |
RewriteQueryUsingAggregateIndexCtx.getInstance(ParseContext parseContext,
Hive hiveDb,
RewriteCanApplyCtx canApplyCtx) |
ParseContext |
RewriteGBUsingIndex.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
LineageCtx.getParseCtx()
Gets the parse context.
|
ParseContext |
Generator.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
Generator.transform(ParseContext pctx) |
Constructor and Description |
---|
LineageCtx(ParseContext pctx,
LineageCtx.Index index)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
ParseContext |
LBOpPartitionWalkerCtx.getParseContext()
Return parse context.
|
ParseContext |
ListBucketingPruner.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.fs.Path[] |
ListBucketingPruner.prune(ParseContext ctx,
Partition part,
ExprNodeDesc pruner)
Prunes to the directories which match the skewed keys in where clause.
|
ParseContext |
ListBucketingPruner.transform(ParseContext pctx) |
Constructor and Description |
---|
LBOpPartitionWalkerCtx(ParseContext parseContext)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
ParseContext |
AnnotateOpTraitsProcCtx.getParseContext() |
ParseContext |
AnnotateWithOpTraits.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
boolean |
OpTraitsRulesProcFactory.TableScanRule.checkBucketedTable(Table tbl,
ParseContext pGraphContext,
PrunedPartitionList prunedParts) |
void |
AnnotateOpTraitsProcCtx.setParseContext(ParseContext parseContext) |
ParseContext |
AnnotateWithOpTraits.transform(ParseContext pctx) |
Constructor and Description |
---|
AnnotateOpTraitsProcCtx(ParseContext parseContext) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
PcrOpWalkerCtx.getParseContext() |
ParseContext |
PartitionConditionRemover.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
PartitionConditionRemover.transform(ParseContext pctx) |
Constructor and Description |
---|
PcrOpWalkerCtx(ParseContext parseContext,
List<PcrOpWalkerCtx.OpToDeleteInfo> opToRemove)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
ParseContext |
PhysicalContext.getParseContext() |
ParseContext |
SkewJoinResolver.SkewJoinProcCtx.getParseCtx() |
ParseContext |
MapJoinResolver.LocalMapJoinProcCtx.getParseCtx() |
Modifier and Type | Method and Description |
---|---|
static void |
GenMRSkewJoinProcessor.processSkewJoin(JoinOperator joinOp,
Task<? extends Serializable> currTask,
ParseContext parseCtx)
Create tasks for processing skew joins.
|
static void |
GenSparkSkewJoinProcessor.processSkewJoin(JoinOperator joinOp,
Task<? extends Serializable> currTask,
ReduceWork reduceWork,
ParseContext parseCtx) |
void |
PhysicalContext.setParseContext(ParseContext parseContext) |
void |
SkewJoinResolver.SkewJoinProcCtx.setParseCtx(ParseContext parseCtx) |
void |
MapJoinResolver.LocalMapJoinProcCtx.setParseCtx(ParseContext parseCtx) |
Constructor and Description |
---|
LocalMapJoinProcCtx(Task<? extends Serializable> task,
ParseContext parseCtx) |
PhysicalContext(HiveConf conf,
ParseContext parseContext,
Context context,
List<Task<? extends Serializable>> rootTasks,
Task<? extends Serializable> fetchTask) |
SkewJoinProcCtx(Task<? extends Serializable> task,
ParseContext parseCtx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
IndexWhereProcCtx.getParseContext() |
Constructor and Description |
---|
IndexWhereProcCtx(Task<? extends Serializable> task,
ParseContext parseCtx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
PartitionPruner.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
static PrunedPartitionList |
PartitionPruner.prune(TableScanOperator ts,
ParseContext parseCtx,
String alias)
Get the partition list for the TS operator that satisfies the partition pruner
condition.
|
ParseContext |
PartitionPruner.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SparkSortMergeJoinOptimizer.canConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext,
ParseContext pGraphContext,
Stack<Node> stack) |
Constructor and Description |
---|
SparkJoinHintOptimizer(ParseContext parseCtx) |
SparkJoinOptimizer(ParseContext procCtx) |
SparkSkewJoinProcCtx(Task<? extends Serializable> task,
ParseContext parseCtx) |
SparkSMBJoinHintOptimizer(ParseContext pctx) |
SparkSortMergeJoinOptimizer(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
AnnotateStatsProcCtx.getParseContext() |
ParseContext |
AnnotateWithStatistics.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
void |
AnnotateStatsProcCtx.setParseContext(ParseContext pctx) |
ParseContext |
AnnotateWithStatistics.transform(ParseContext pctx) |
Constructor and Description |
---|
AnnotateStatsProcCtx(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
UnionProcContext.getParseContext() |
ParseContext |
UnionProcessor.transform(ParseContext pCtx)
Transform the query tree.
|
Modifier and Type | Method and Description |
---|---|
void |
UnionProcContext.setParseContext(ParseContext parseContext) |
ParseContext |
UnionProcessor.transform(ParseContext pCtx)
Transform the query tree.
|
Modifier and Type | Field and Description |
---|---|
ParseContext |
OptimizeTezProcContext.parseContext |
ParseContext |
GenTezProcContext.parseContext |
protected ParseContext |
TableAccessAnalyzer.GroupByProcessor.pGraphContext |
protected ParseContext |
TableAccessAnalyzer.JoinProcessor.pGraphContext |
Modifier and Type | Method and Description |
---|---|
ParseContext |
SemanticAnalyzer.getParseContext() |
ParseContext |
TaskCompiler.getParseContext(ParseContext pCtx,
List<Task<? extends Serializable>> rootTasks)
Create a clone of the parse context
|
Modifier and Type | Method and Description |
---|---|
void |
TaskCompiler.compile(ParseContext pCtx,
List<Task<? extends Serializable>> rootTasks,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs) |
protected void |
TezCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected abstract void |
TaskCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected void |
MapReduceCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
static TaskCompiler |
TaskCompilerFactory.getCompiler(HiveConf conf,
ParseContext parseContext)
Returns the appropriate compiler to translate the operator tree
into executable units.
|
ParseContext |
TaskCompiler.getParseContext(ParseContext pCtx,
List<Task<? extends Serializable>> rootTasks)
Create a clone of the parse context
|
void |
SemanticAnalyzer.initParseCtx(ParseContext pctx) |
protected void |
TezCompiler.optimizeOperatorPlan(ParseContext pCtx,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected void |
TaskCompiler.optimizeOperatorPlan(ParseContext pCtxSet,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected void |
TezCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
Context ctx) |
protected abstract void |
TaskCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
Context ctx) |
protected void |
MapReduceCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
Context ctx) |
Constructor and Description |
---|
ColumnAccessAnalyzer(ParseContext pactx) |
GenTezProcContext(HiveConf conf,
ParseContext parseContext,
List<Task<MoveWork>> moveTask,
List<Task<? extends Serializable>> rootTasks,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
GroupByProcessor(ParseContext pGraphContext) |
JoinProcessor(ParseContext pGraphContext) |
OptimizeTezProcContext(HiveConf conf,
ParseContext parseContext,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
TableAccessAnalyzer(ParseContext pactx) |
Modifier and Type | Field and Description |
---|---|
ParseContext |
GenSparkProcContext.parseContext |
Modifier and Type | Method and Description |
---|---|
ParseContext |
OptimizeSparkProcContext.getParseContext() |
Modifier and Type | Method and Description |
---|---|
protected void |
SparkCompiler.generateTaskTree(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
List<Task<MoveWork>> mvTask,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs)
TODO: need to turn on rules that's commented out and add more if necessary.
|
protected void |
SparkCompiler.optimizeOperatorPlan(ParseContext pCtx,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
protected void |
SparkCompiler.optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks,
ParseContext pCtx,
Context ctx) |
Constructor and Description |
---|
GenSparkProcContext(HiveConf conf,
ParseContext parseContext,
List<Task<MoveWork>> moveTask,
List<Task<? extends Serializable>> rootTasks,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
Map<String,TableScanOperator> topOps) |
OptimizeSparkProcContext(HiveConf conf,
ParseContext parseContext,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
ExplainWork.getParseContext() |
Modifier and Type | Method and Description |
---|---|
static void |
PlanUtils.addInputsForView(ParseContext parseCtx) |
void |
ExplainWork.setParseContext(ParseContext pCtx) |
Constructor and Description |
---|
ExplainWork(org.apache.hadoop.fs.Path resFile,
ParseContext pCtx,
List<Task<? extends Serializable>> rootTasks,
Task<? extends Serializable> fetchTask,
BaseSemanticAnalyzer analyzer,
boolean extended,
boolean formatted,
boolean dependency,
boolean logical,
boolean authorize,
boolean userLevelExplain,
String cboInfo) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
OpWalkerInfo.getParseContext() |
ParseContext |
SyntheticJoinPredicate.transform(ParseContext pctx) |
ParseContext |
SimplePredicatePushDown.transform(ParseContext pctx) |
ParseContext |
PredicateTransitivePropagate.transform(ParseContext pctx) |
ParseContext |
PredicatePushDown.transform(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
ParseContext |
SyntheticJoinPredicate.transform(ParseContext pctx) |
ParseContext |
SimplePredicatePushDown.transform(ParseContext pctx) |
ParseContext |
PredicateTransitivePropagate.transform(ParseContext pctx) |
ParseContext |
PredicatePushDown.transform(ParseContext pctx) |
Constructor and Description |
---|
OpWalkerInfo(ParseContext pGraphContext) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.