Modifier and Type | Method and Description |
---|---|
Object |
AccumuloRangeGenerator.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
NodeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
Object |
CompositeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Constructor and Description |
---|
DefaultRuleDispatcher(NodeProcessor defaultProc,
Map<Rule,NodeProcessor> rules,
NodeProcessorCtx procCtx)
Constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
BucketJoinProcCtx |
class |
ColumnPrunerProcCtx
This class implements the processor context for Column Pruner.
|
class |
ConstantPropagateProcCtx
This class implements the processor context for Constant Propagate.
|
class |
FixedBucketPruningOptimizer.FixedBucketPruningOptimizerCtxt |
class |
GenMRProcContext
Processor Context for creating map reduce task.
|
class |
GroupByOptimizer.GroupByOptimizerContext |
static class |
MapJoinProcessor.MapJoinWalkerCtx
MapJoinWalkerCtx.
|
static class |
SamplePruner.SamplePrunerCtx
SamplePrunerCtx.
|
static class |
SkewJoinOptimizer.SkewJoinOptProcCtx
SkewJoinOptProcCtx.
|
class |
SortBucketJoinProcCtx |
class |
TezBucketJoinProcCtx |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
PrunerOperatorFactory.FilterPruner.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top)
Generate predicate.
|
protected void |
FixedBucketPruningOptimizer.FixedBucketPartitionWalker.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
protected void |
FixedBucketPruningOptimizer.BucketBitsetGenerator.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
Object |
SparkRemoveDynamicPruningBySize.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SortedMergeJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SortedMergeBucketMapjoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SkewJoinOptimizer.SkewJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SetReducerParallelism.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SamplePruner.FilterPPR.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SamplePruner.DefaultPPR.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
RemoveDynamicPruningBySize.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
ReduceSinkMapJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
PrunerOperatorFactory.FilterPruner.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PrunerOperatorFactory.DefaultPruner.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PrunerExpressionOperatorFactory.GenericFuncExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PrunerExpressionOperatorFactory.FieldExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PrunerExpressionOperatorFactory.ColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PrunerExpressionOperatorFactory.DefaultExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
MergeJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
MapJoinProcessor.CurrentMapJoin.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Store the current mapjoin in the context.
|
Object |
MapJoinProcessor.MapJoinFS.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Store the current mapjoin in a list of mapjoins followed by a filesink.
|
Object |
MapJoinProcessor.MapJoinDefault.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Store the mapjoin in a rejected list.
|
Object |
MapJoinProcessor.Default.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Nothing to do.
|
Object |
GroupByOptimizer.SortGroupByProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GroupByOptimizer.SortGroupBySkewProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenMRUnion1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Union Operator encountered .
|
Object |
GenMRTableScan1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Table Sink encountered.
|
Object |
GenMRRedSink3.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
Object |
GenMRRedSink2.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
Object |
GenMRRedSink1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Sink encountered.
|
Object |
GenMROperator.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
Object |
GenMRFileSink1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
File Sink Operator encountered.
|
Object |
FixedBucketPruningOptimizer.NoopWalker.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
DynamicPartitionPruningOptimization.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ConvertJoinMapJoin.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateFilterProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateGroupByProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateDefaultProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateSelectProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateFileSinkProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateStopProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateReduceSinkProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ConstantPropagateProcFactory.ConstantPropagateTableScanProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerFilterProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerGroupByProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerScriptProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerLimitProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerPTFProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerDefaultProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerTableScanProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerReduceSinkProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerLateralViewJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerLateralViewForwardProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerSelectProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerMapJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ColumnPrunerProcFactory.ColumnPrunerUnionProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
BucketMapjoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingReduceSinkOptimizer.BucketSortReduceSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
abstract Object |
AbstractSMBJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
abstract Object |
AbstractBucketJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
protected abstract ExprNodeDesc |
PrunerExpressionOperatorFactory.ColumnExprProcessor.processColumnDesc(NodeProcessorCtx procCtx,
ExprNodeColumnDesc cd)
Process column desc.
|
static Map<Node,Object> |
PrunerUtils.walkExprTree(ExprNodeDesc pred,
NodeProcessorCtx ctx,
NodeProcessor colProc,
NodeProcessor fieldProc,
NodeProcessor genFuncProc,
NodeProcessor defProc)
Walk expression tree for pruner generation.
|
static void |
PrunerUtils.walkOperatorTree(ParseContext pctx,
NodeProcessorCtx opWalkerCtx,
NodeProcessor filterProc,
NodeProcessor defaultProc)
Walk operator tree for pruner generation.
|
Modifier and Type | Class and Description |
---|---|
class |
JoinTypeCheckCtx
TODO:
1. |
Modifier and Type | Method and Description |
---|---|
Object |
JoinCondTypeCheckProcFactory.JoinCondColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
protected class |
CorrelationOptimizer.CorrelationNodeProcCtx |
protected class |
ReduceSinkDeDuplication.ReduceSinkDeduplicateProcCtx |
Modifier and Type | Method and Description |
---|---|
Object |
ReduceSinkDeDuplication.AbsctractReducerReducerProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
RewriteCanApplyCtx
RewriteCanApplyCtx class stores the context for the
RewriteCanApplyProcFactory
to determine if any index can be used and if the input query
meets all the criteria for rewrite optimization. |
class |
RewriteQueryUsingAggregateIndexCtx
RewriteQueryUsingAggregateIndexCtx class stores the
context for the
RewriteQueryUsingAggregateIndex
used to rewrite operator plan with index table instead of base table. |
Modifier and Type | Class and Description |
---|---|
class |
ExprProcCtx
The processor context for the lineage information.
|
class |
LineageCtx
This class contains the lineage context that is passed
while walking the operator tree in Lineage.
|
Modifier and Type | Method and Description |
---|---|
Object |
OpProcFactory.TransformLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.TableScanLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.JoinLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.LateralViewJoinLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.SelectLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.GroupByLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.UnionLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.ReduceSinkLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.FilterLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.DefaultLineage.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ExprProcFactory.ColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ExprProcFactory.GenericExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ExprProcFactory.DefaultExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
LBExprProcCtx
The processor context for list bucketing pruner.
|
class |
LBOpPartitionWalkerCtx
Context used by list bucketing pruner to get all partitions
|
class |
LBOpWalkerCtx
Context used by list bucketing to walk operator trees to generate expression tree.
|
Modifier and Type | Method and Description |
---|---|
protected void |
LBProcFactory.LBPRFilterPruner.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
protected void |
LBPartitionProcFactory.LBPRPartitionFilterPruner.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
protected ExprNodeDesc |
LBExprProcFactory.LBPRColumnExprProcessor.processColumnDesc(NodeProcessorCtx procCtx,
ExprNodeColumnDesc cd) |
Modifier and Type | Class and Description |
---|---|
class |
AnnotateOpTraitsProcCtx |
Modifier and Type | Method and Description |
---|---|
Object |
OpTraitsRulesProcFactory.DefaultRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpTraitsRulesProcFactory.ReduceSinkRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpTraitsRulesProcFactory.TableScanRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpTraitsRulesProcFactory.GroupByRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpTraitsRulesProcFactory.SelectRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpTraitsRulesProcFactory.JoinRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpTraitsRulesProcFactory.MultiParentRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
PcrExprProcCtx
The processor context for partition condition remover.
|
class |
PcrOpWalkerCtx
Context class for operator tree walker for partition condition remover.
|
Modifier and Type | Method and Description |
---|---|
Object |
PcrOpProcFactory.FilterPCR.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PcrOpProcFactory.DefaultPCR.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PcrExprProcFactory.ColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PcrExprProcFactory.GenericFuncExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PcrExprProcFactory.FieldExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
PcrExprProcFactory.DefaultExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
BucketingSortingCtx
This class contains the bucketing sorting context that is passed
while walking the operator tree in inferring bucket/sort columns.
|
static class |
CrossProductCheck.ExtractReduceSinkInfo |
static class |
CrossProductCheck.MapJoinCheck |
static class |
MapJoinResolver.LocalMapJoinProcCtx
A container of current task and parse context.
|
static class |
SkewJoinResolver.SkewJoinProcCtx
A container of current task and parse context.
|
Modifier and Type | Method and Description |
---|---|
Object |
SkewJoinProcFactory.SkewJoinJoinProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
SkewJoinProcFactory.SkewJoinDefaultProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
SerializeFilter.Serializer.DefaultRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
MemoryDecider.MemoryCalculator.DefaultRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
LocalMapJoinProcFactory.MapJoinFollowedByGroupByProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
LocalMapJoinProcFactory.LocalMapJoinProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
CrossProductCheck.MapJoinCheck.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
CrossProductCheck.ExtractReduceSinkInfo.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingOpProcFactory.DefaultInferrer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingOpProcFactory.JoinInferrer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingOpProcFactory.SelectInferrer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingOpProcFactory.FileSinkInferrer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingOpProcFactory.MultiGroupByInferrer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingOpProcFactory.GroupByInferrer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketingSortingOpProcFactory.ForwardingInferrer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
IndexWhereProcCtx |
Modifier and Type | Method and Description |
---|---|
Object |
IndexWhereProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
ExprPrunerInfo
The processor context for partition pruner.
|
class |
OpWalkerCtx
Context class for operator tree walker for partition pruner.
|
Modifier and Type | Method and Description |
---|---|
protected void |
OpProcFactory.FilterPPR.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
protected ExprNodeDesc |
ExprProcFactory.PPRColumnExprProcessor.processColumnDesc(NodeProcessorCtx procCtx,
ExprNodeColumnDesc cd) |
Modifier and Type | Class and Description |
---|---|
static class |
SparkSkewJoinResolver.SparkSkewJoinProcCtx |
Modifier and Type | Method and Description |
---|---|
Object |
SparkSortMergeJoinOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkSMBJoinHintOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkSkewJoinProcFactory.SparkSkewJoinJoinProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkReduceSinkMapJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SparkReduceSinkMapJoinProc.SparkMapJoinFollowedByGroupByProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkMapJoinOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkJoinOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkJoinHintOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SetSparkReducerParallelism.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
AnnotateStatsProcCtx |
Modifier and Type | Method and Description |
---|---|
Object |
StatsRulesProcFactory.TableScanStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
StatsRulesProcFactory.SelectStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
StatsRulesProcFactory.FilterStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
StatsRulesProcFactory.GroupByStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
StatsRulesProcFactory.JoinStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
StatsRulesProcFactory.LimitStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
StatsRulesProcFactory.ReduceSinkStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
StatsRulesProcFactory.DefaultStatsRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
UnionProcContext
UnionProcContext.
|
Modifier and Type | Method and Description |
---|---|
Object |
UnionProcFactory.MapRedUnion.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
UnionProcFactory.MapUnion.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
UnionProcFactory.UnknownUnion.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
UnionProcFactory.UnionNoProcessFile.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
UnionProcFactory.NoUnion.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
GenTezProcContext
GenTezProcContext.
|
class |
OptimizeTezProcContext
OptimizeTezProcContext.
|
class |
TableAccessCtx
This class implements the context information that is used for typechecking
phase in query compilation.
|
class |
TypeCheckCtx
This class implements the context information that is used for typechecking
phase in query compilation.
|
Modifier and Type | Method and Description |
---|---|
Object |
UnionProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.NullExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.NumExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.StrExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.BoolExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.DateTimeExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.IntervalExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.ColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.DefaultExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TypeCheckProcFactory.SubQueryExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TableAccessAnalyzer.GroupByProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
TableAccessAnalyzer.JoinProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ProcessAnalyzeTable.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
PrintOpTreeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
GenTezWork.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
FileSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
AppMasterEventProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
GenSparkProcContext
GenSparkProcContext maintains information about the tasks and operators
as we walk the operator tree to break them into SparkTasks.
|
class |
OptimizeSparkProcContext
OptimizeSparkProcContext.
|
Modifier and Type | Method and Description |
---|---|
Object |
SplitOpTreeForDPP.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkProcessAnalyzeTable.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SparkFileSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenSparkWork.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
ExprWalkerInfo
Context for Expression Walker for determining predicate pushdown candidates
It contains a ExprInfo object for each expression that is processed.
|
class |
OpWalkerInfo
Context class for operator walker of predicate pushdown.
|
Modifier and Type | Method and Description |
---|---|
Object |
OpProcFactory.ScriptPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.PTFPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.UDTFPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.LateralViewForwardPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.TableScanPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.FilterPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.SimpleFilterPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.JoinerPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.ReduceSinkPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
OpProcFactory.DefaultPPD.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ExprWalkerProcFactory.ColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Converts the reference from child row resolver to current row resolver.
|
Object |
ExprWalkerProcFactory.FieldExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ExprWalkerProcFactory.GenericFuncExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ExprWalkerProcFactory.DefaultExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
LineageInfo.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Implements the process method for the NodeProcessor interface.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.