Modifier and Type | Method and Description |
---|---|
Object |
AccumuloRangeGenerator.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
protected Object |
AccumuloRangeGenerator.processAndOpNode(Node nd,
Object[] nodeOutputs) |
protected Object |
AccumuloRangeGenerator.processOrOpNode(Node nd,
Object[] nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
AccumuloRangeGenerator.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileMergeOperator<T extends FileMergeDesc>
Fast file merge operator for ORC and RCfile.
|
class |
AbstractMapJoinOperator<T extends MapJoinDesc> |
class |
AbstractMapOperator
Abstract Map operator.
|
class |
AppMasterEventOperator
AppMasterEventOperator sends any rows it receives to the Tez AM.
|
class |
CollectOperator
Buffers rows emitted by other operators.
|
class |
ColumnStatsUpdateTask
ColumnStatsUpdateTask implementation.
|
class |
CommonJoinOperator<T extends JoinDesc>
Join operator implementation.
|
class |
CommonMergeJoinOperator |
class |
ConditionalTask
Conditional Task implementation.
|
class |
CopyTask
CopyTask implementation.
|
class |
DDLTask
DDLTask implementation.
|
class |
DemuxOperator
DemuxOperator is an operator used by MapReduce Jobs optimized by
CorrelationOptimizer.
|
class |
DependencyCollectionTask
DependencyCollectionTask.
|
class |
DummyStoreOperator
For SortMerge joins, this is a dummy operator, which stores the row for the
small table before it reaches the sort merge join operator.
|
class |
ExplainSQRewriteTask |
class |
ExplainTask
ExplainTask implementation.
|
class |
ExportTask |
class |
FetchTask
FetchTask implementation.
|
class |
FileSinkOperator
File Sink operator implementation.
|
class |
FilterOperator
Filter operator implementation.
|
class |
ForwardOperator
Forward Operator Just forwards.
|
class |
FunctionTask
FunctionTask.
|
class |
GroupByOperator
GroupBy operator implementation.
|
class |
HashTableDummyOperator |
class |
HashTableSinkOperator |
class |
JoinOperator
Join operator implementation.
|
class |
LateralViewForwardOperator
LateralViewForwardOperator.
|
class |
LateralViewJoinOperator
The lateral view join operator is used for FROM src LATERAL VIEW udtf()...
|
class |
LimitOperator
Limit operator implementation Limits the number of rows to be passed on.
|
class |
ListSinkOperator
For fetch task with operator tree, row read from FetchOperator is processed via operator tree
and finally arrives to this operator.
|
class |
MapJoinOperator
Map side Join operator implementation.
|
class |
MapOperator
Map operator.
|
class |
MaterializedViewTask
This task does some work related to materialized views.
|
class |
MoveTask
MoveTask implementation.
|
class |
MuxOperator
MuxOperator is used in the Reduce side of MapReduce jobs optimized by Correlation Optimizer.
|
class |
Operator<T extends OperatorDesc>
Base operator implementation.
|
class |
OrcFileMergeOperator
Fast file merge operator for ORC files.
|
class |
PTFOperator |
class |
RCFileMergeOperator
Fast file merge operator for RC files.
|
class |
ReduceSinkOperator
Reduce Sink Operator sends output to the reduce stage.
|
class |
ReplCopyTask |
class |
ReplTxnTask
ReplTxnTask.
|
class |
ScriptOperator
ScriptOperator.
|
class |
SelectOperator
Select operator implementation.
|
class |
SMBMapJoinOperator
Sorted Merge Map Join Operator.
|
class |
SparkHashTableSinkOperator |
class |
StatsTask
StatsTask implementation.
|
class |
TableScanOperator
Table Scan Operator If the data is coming from the map-reduce framework, just
forward it.
|
class |
Task<T extends Serializable>
Task implementation.
|
class |
TemporaryHashSinkOperator |
class |
TerminalOperator<T extends OperatorDesc>
Terminal Operator Base Class.
|
class |
TezDummyStoreOperator
A dummy store operator same as the dummy store operator but for tez.
|
class |
UDTFOperator
UDTFOperator.
|
class |
UnionOperator
Union Operator Just forwards.
|
Modifier and Type | Method and Description |
---|---|
List<? extends Node> |
Task.getChildren() |
ArrayList<Node> |
Operator.getChildren()
Implements the getChildren function for the Node Interface.
|
Modifier and Type | Method and Description |
---|---|
static <T> void |
NodeUtils.iterate(Collection<? extends Node> nodes,
Class<T> clazz,
NodeUtils.Function<T> function) |
Modifier and Type | Class and Description |
---|---|
class |
ExecDriver
ExecDriver is the central class in co-ordinating execution of any map-reduce task.
|
class |
MapredLocalTask
MapredLocalTask represents any local work (i.e.: client side work) that hive needs to
execute.
|
class |
MapRedTask
Extension of ExecDriver:
- can optionally spawn a map-reduce task from a separate jvm
- will make last minute adjustments to map-reduce job parameters, viz:
* estimating number of reducers
* estimating whether job should run locally
|
Modifier and Type | Class and Description |
---|---|
class |
ReplDumpTask |
class |
ReplStateLogTask
ReplStateLogTask.
|
Modifier and Type | Class and Description |
---|---|
class |
ReplLoadTask |
Modifier and Type | Class and Description |
---|---|
class |
SparkTask |
Modifier and Type | Class and Description |
---|---|
class |
TezTask
TezTask handles the execution of TezWork.
|
Modifier and Type | Class and Description |
---|---|
class |
VectorAppMasterEventOperator
App Master Event operator implementation.
|
class |
VectorFileSinkOperator
File Sink operator implementation.
|
class |
VectorFilterOperator
Filter operator implementation.
|
class |
VectorGroupByOperator
Vectorized GROUP BY operator implementation.
|
class |
VectorLimitOperator
Limit operator implementation Limits the number of rows to be passed on.
|
class |
VectorMapJoinBaseOperator
The *NON-NATIVE* base vector map join operator class used by VectorMapJoinOperator and
VectorMapJoinOuterFilteredOperator.
|
class |
VectorMapJoinOperator
The vectorized version of the MapJoinOperator.
|
class |
VectorMapJoinOuterFilteredOperator
This is the *NON-NATIVE* vector map join operator for just LEFT OUTER JOIN and filtered.
|
class |
VectorMapOperator |
class |
VectorReduceSinkOperator |
class |
VectorSelectOperator
Select operator implementation.
|
class |
VectorSMBMapJoinOperator
VectorSMBJoinOperator.
|
class |
VectorSparkHashTableSinkOperator
Vectorized version of SparkHashTableSinkOperator
Currently the implementation just delegates all the work to super class
Copied from VectorFileSinkOperator
|
class |
VectorSparkPartitionPruningSinkOperator
Vectorized version for SparkPartitionPruningSinkOperator.
|
Modifier and Type | Class and Description |
---|---|
class |
VectorMapJoinCommonOperator
This class is common operator class for native vectorized map join.
|
class |
VectorMapJoinGenerateResultOperator
This class has methods for generating vectorized join results and forwarding batchs.
|
class |
VectorMapJoinInnerBigOnlyGenerateResultOperator
This class has methods for generating vectorized join results for the big table only
variation of inner joins.
|
class |
VectorMapJoinInnerBigOnlyLongOperator |
class |
VectorMapJoinInnerBigOnlyMultiKeyOperator |
class |
VectorMapJoinInnerBigOnlyStringOperator |
class |
VectorMapJoinInnerGenerateResultOperator
This class has methods for generating vectorized join results for inner joins.
|
class |
VectorMapJoinInnerLongOperator |
class |
VectorMapJoinInnerMultiKeyOperator |
class |
VectorMapJoinInnerStringOperator |
class |
VectorMapJoinLeftSemiGenerateResultOperator
This class has methods for generating vectorized join results for left semi joins.
|
class |
VectorMapJoinLeftSemiLongOperator |
class |
VectorMapJoinLeftSemiMultiKeyOperator |
class |
VectorMapJoinLeftSemiStringOperator |
class |
VectorMapJoinOuterGenerateResultOperator
This class has methods for generating vectorized join results for outer joins.
|
class |
VectorMapJoinOuterLongOperator |
class |
VectorMapJoinOuterMultiKeyOperator |
class |
VectorMapJoinOuterStringOperator |
Modifier and Type | Class and Description |
---|---|
class |
VectorPTFOperator
This class is native vectorized PTF operator class.
|
Modifier and Type | Class and Description |
---|---|
class |
VectorReduceSinkCommonOperator
This class is common operator class for native vectorized reduce sink.
|
class |
VectorReduceSinkEmptyKeyOperator
This class is the UniformHash empty key operator class for native vectorized reduce sink.
|
class |
VectorReduceSinkLongOperator |
class |
VectorReduceSinkMultiKeyOperator |
class |
VectorReduceSinkObjectHashOperator
This class is the object hash (not Uniform Hash) operator class for native vectorized reduce sink.
|
class |
VectorReduceSinkStringOperator |
class |
VectorReduceSinkUniformHashOperator
This class is uniform hash (common) operator class for native vectorized reduce sink.
|
Modifier and Type | Class and Description |
---|---|
class |
MergeFileTask
Task for fast merging of ORC and RC files.
|
Modifier and Type | Class and Description |
---|---|
class |
ColumnTruncateTask |
Modifier and Type | Field and Description |
---|---|
protected Queue<Node> |
DefaultGraphWalker.opQueue
opQueue keeps the nodes in the order that the were dispatched.
|
protected Stack<Node> |
TaskGraphWalker.opStack |
protected Stack<Node> |
DefaultGraphWalker.opStack
opStack keeps the nodes that have been visited, but have not been
dispatched yet
|
protected IdentityHashMap<Node,Object> |
DefaultGraphWalker.retMap |
protected List<Node> |
DefaultGraphWalker.toWalk
toWalk stores the starting nodes for the graph that needs to be
traversed
|
Modifier and Type | Method and Description |
---|---|
static Node |
Utils.getNthAncestor(Stack<Node> st,
int n)
Gets the nth ancestor (the parent being the 1st ancestor) in the traversal
path.
|
Modifier and Type | Method and Description |
---|---|
List<? extends Node> |
Node.getChildren()
Gets the vector of children nodes.
|
Set<Node> |
TaskGraphWalker.getDispatchedList() |
protected Set<Node> |
DefaultGraphWalker.getDispatchedList() |
List<Node> |
TaskGraphWalker.getToWalk() |
Modifier and Type | Method and Description |
---|---|
protected void |
ForwardWalker.addAllParents(Node nd) |
void |
TaskGraphWalker.TaskGraphWalkerContext.addToDispatchList(Node dispatchedObj) |
protected boolean |
ForwardWalker.allParentsDispatched(Node nd) |
void |
DefaultGraphWalker.dispatch(Node nd,
Stack<Node> ndStack)
Dispatch the current operator.
|
Object |
DefaultRuleDispatcher.dispatch(Node nd,
Stack<Node> ndStack,
Object... nodeOutputs)
Dispatcher function.
|
Object |
Dispatcher.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs)
Dispatcher function.
|
void |
TaskGraphWalker.dispatch(Node nd,
Stack<Node> ndStack,
TaskGraphWalker.TaskGraphWalkerContext walkerCtx)
Dispatch the current operator.
|
<T> T |
DefaultGraphWalker.dispatchAndReturn(Node nd,
Stack<Node> ndStack)
Returns dispatch result
|
Object |
CompositeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
NodeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
void |
PreOrderOnceWalker.walk(Node nd)
Walk the current operator and its descendants.
|
protected void |
PreOrderWalker.walk(Node nd)
Walk the current operator and its descendants.
|
void |
TaskGraphWalker.walk(Node nd)
walk the current operator and its descendants.
|
protected void |
ExpressionWalker.walk(Node nd)
walk the current operator and its descendants.
|
protected void |
ForwardWalker.walk(Node nd)
walk the current operator and its descendants.
|
protected void |
DefaultGraphWalker.walk(Node nd)
walk the current operator and its descendants.
|
Modifier and Type | Method and Description |
---|---|
int |
RuleRegExp.cost(Stack<Node> stack)
This function returns the cost of the rule for the specified stack.
|
int |
TypeRule.cost(Stack<Node> stack) |
int |
Rule.cost(Stack<Node> stack) |
int |
RuleExactMatch.cost(Stack<Node> stack)
This function returns the cost of the rule for the specified stack.
|
void |
DefaultGraphWalker.dispatch(Node nd,
Stack<Node> ndStack)
Dispatch the current operator.
|
Object |
DefaultRuleDispatcher.dispatch(Node nd,
Stack<Node> ndStack,
Object... nodeOutputs)
Dispatcher function.
|
Object |
Dispatcher.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs)
Dispatcher function.
|
void |
TaskGraphWalker.dispatch(Node nd,
Stack<Node> ndStack,
TaskGraphWalker.TaskGraphWalkerContext walkerCtx)
Dispatch the current operator.
|
<T> T |
DefaultGraphWalker.dispatchAndReturn(Node nd,
Stack<Node> ndStack)
Returns dispatch result
|
static <T> T |
Utils.findNode(Stack<Node> stack,
Class<T> target)
Find the first node of a type from ancestor stack, starting from parents.
|
static Node |
Utils.getNthAncestor(Stack<Node> st,
int n)
Gets the nth ancestor (the parent being the 1st ancestor) in the traversal
path.
|
Object |
CompositeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
NodeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
void |
GraphWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
GraphWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
TaskGraphWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
TaskGraphWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
LevelOrderWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
LevelOrderWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
DefaultGraphWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
DefaultGraphWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
Constructor and Description |
---|
TaskGraphWalkerContext(HashMap<Node,Object> reMap) |
Modifier and Type | Method and Description |
---|---|
static Map<Node,Object> |
PrunerUtils.walkExprTree(ExprNodeDesc pred,
NodeProcessorCtx ctx,
NodeProcessor colProc,
NodeProcessor fieldProc,
NodeProcessor genFuncProc,
NodeProcessor defProc)
Walk expression tree for pruner generation.
|
Modifier and Type | Method and Description |
---|---|
Object |
RemoveDynamicPruningBySize.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
ConvertJoinMapJoin.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenMRTableScan1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Table Sink encountered.
|
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 |
GenMRRedSink2.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
Object |
MergeJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
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 |
BucketingSortingReduceSinkOptimizer.BucketSortReduceSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketMapjoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenMROperator.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
Object |
SetReducerParallelism.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
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 |
GenMRRedSink3.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
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 |
SkewJoinOptimizer.SkewJoinProc.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 |
GenMRRedSink1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Sink encountered.
|
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 |
SortedMergeBucketMapjoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenMRFileSink1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
File Sink Operator encountered.
|
Object |
GenMRUnion1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Union Operator encountered .
|
Object |
FixedBucketPruningOptimizer.NoopWalker.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
abstract Object |
AbstractBucketJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ReduceSinkMapJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SortedMergeJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
CountDistinctRewriteProc.CountDistinctProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
abstract Object |
AbstractSMBJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
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 |
DynamicPartitionPruningOptimization.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkRemoveDynamicPruning.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
protected void |
ColumnPruner.ColumnPrunerWalker.walk(Node nd)
Walk the given operator.
|
protected void |
ConstantPropagate.ConstantPropagateWalker.walk(Node nd) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractSMBJoinProc.canConvertBucketMapJoinToSMBJoin(MapJoinOperator mapJoinOp,
Stack<Node> stack,
SortBucketJoinProcCtx smbJoinContext,
Object... nodeOutputs) |
protected GroupByOptimizer.GroupByOptimizerSortMatch |
GroupByOptimizer.SortGroupByProcessor.checkSortGroupBy(Stack<Node> stack,
GroupByOperator groupByOp) |
static int |
MapJoinFactory.getPositionParent(AbstractMapJoinOperator<? extends MapJoinDesc> op,
Stack<Node> stack) |
Object |
RemoveDynamicPruningBySize.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
ConvertJoinMapJoin.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenMRTableScan1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Table Sink encountered.
|
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 |
GenMRRedSink2.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
Object |
MergeJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
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 |
BucketingSortingReduceSinkOptimizer.BucketSortReduceSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
BucketMapjoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenMROperator.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
Object |
SetReducerParallelism.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
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 |
GenMRRedSink3.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Scan encountered.
|
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 |
SkewJoinOptimizer.SkewJoinProc.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 |
GenMRRedSink1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Sink encountered.
|
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 |
SortedMergeBucketMapjoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenMRFileSink1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
File Sink Operator encountered.
|
Object |
GenMRUnion1.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Union Operator encountered .
|
Object |
FixedBucketPruningOptimizer.NoopWalker.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
abstract Object |
AbstractBucketJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
ReduceSinkMapJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SortedMergeJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
CountDistinctRewriteProc.CountDistinctProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
abstract Object |
AbstractSMBJoinProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
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 |
DynamicPartitionPruningOptimization.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkRemoveDynamicPruning.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
protected void |
GroupByOptimizer.SortGroupByProcessor.processGroupBy(GroupByOptimizer.GroupByOptimizerContext ctx,
Stack<Node> stack,
GroupByOperator groupByOp,
int depth) |
Modifier and Type | Method and Description |
---|---|
Object |
JoinCondTypeCheckProcFactory.JoinCondColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
JoinCondTypeCheckProcFactory.JoinCondColumnExprProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
ReduceSinkDeDuplication.AbsctractReducerReducerProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
ReduceSinkDeDuplication.AbsctractReducerReducerProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
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 | Method and Description |
---|---|
static LineageInfo.Dependency |
ExprProcFactory.getExprDependency(LineageCtx lctx,
Operator<? extends OperatorDesc> inpOp,
ExprNodeDesc expr,
HashMap<Node,Object> outputMap)
Gets the expression dependencies for the expression.
|
protected static Operator<? extends OperatorDesc> |
OpProcFactory.getParent(Stack<Node> stack)
Returns the parent operator in the walk path to the current operator.
|
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 | 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 | 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 | 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 | 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 | Method and Description |
---|---|
Object |
SerializeFilter.Serializer.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
NullScanTaskDispatcher.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
SparkCrossProductCheck.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
CrossProductHandler.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
MemoryDecider.MemoryCalculator.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
AbstractJoinTaskDispatcher.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
SerializeFilter.Serializer.DefaultRule.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) |
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 |
CrossProductHandler.MapJoinCheck.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
CrossProductHandler.ExtractReduceSinkInfo.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
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 |
MemoryDecider.MemoryCalculator.DefaultRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
SerializeFilter.Serializer.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
NullScanTaskDispatcher.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
SparkCrossProductCheck.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
CrossProductHandler.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
MemoryDecider.MemoryCalculator.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
Object |
AbstractJoinTaskDispatcher.dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs) |
protected static Operator<? extends OperatorDesc> |
BucketingSortingOpProcFactory.getParent(Stack<Node> stack)
Returns the parent operator in the walk path to the current operator.
|
Object |
SerializeFilter.Serializer.DefaultRule.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) |
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 |
CrossProductHandler.MapJoinCheck.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
CrossProductHandler.ExtractReduceSinkInfo.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
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 |
MemoryDecider.MemoryCalculator.DefaultRule.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Modifier and Type | Method and Description |
---|---|
Object |
SparkSMBJoinHintOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SetSparkReducerParallelism.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SparkSortMergeJoinOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkSkewJoinProcFactory.SparkSkewJoinJoinProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkJoinHintOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkJoinOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkMapJoinOptimizer.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) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SparkSortMergeJoinOptimizer.canConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext,
ParseContext pGraphContext,
Stack<Node> stack) |
Object |
SparkSMBJoinHintOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SetSparkReducerParallelism.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SparkSortMergeJoinOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkSkewJoinProcFactory.SparkSkewJoinJoinProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkJoinHintOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkJoinOptimizer.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
SparkMapJoinOptimizer.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) |
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 | 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 | 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 | Method and Description |
---|---|
static int |
UnionProcFactory.getPositionParent(UnionOperator union,
Stack<Node> stack) |
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 |
ASTErrorNode |
class |
ASTNode |
Modifier and Type | Method and Description |
---|---|
static Map<Node,Object> |
GenTezUtils.collectDynamicPruningConditions(ExprNodeDesc pred,
NodeProcessorCtx ctx) |
ArrayList<Node> |
ASTNode.getChildren() |
Modifier and Type | Method and Description |
---|---|
protected List<String> |
BaseSemanticAnalyzer.getSkewedValuesFromASTNode(Node node)
Retrieve skewed values from ASTNode.
|
Object |
FileSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenTezWork.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
PrintOpTreeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ProcessAnalyzeTable.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
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 |
GenTezUtils.DynamicPartitionPrunerProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
process simply remembers all the dynamic partition pruning expressions
found
|
Object |
AppMasterEventProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
UnionProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
static ExprNodeDesc |
TypeCheckProcFactory.processGByExpr(Node nd,
Object procCtx)
Function to do groupby subexpression elimination.
|
protected void |
TezWalker.walk(Node nd)
Walk the given operator.
|
protected void |
GenMapRedWalker.walk(Node nd)
Walk the given operator.
|
protected void |
GenTezWorkWalker.walk(Node nd)
Walk the given operator.
|
Modifier and Type | Method and Description |
---|---|
Object |
FileSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
GenTezWork.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
PrintOpTreeProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx ctx,
Object... nodeOutputs) |
Object |
ProcessAnalyzeTable.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
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 |
GenTezUtils.DynamicPartitionPrunerProc.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
process simply remembers all the dynamic partition pruning expressions
found
|
Object |
AppMasterEventProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
Object |
UnionProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
void |
GenTezWorkWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
GenTezWorkWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
Modifier and Type | Class and Description |
---|---|
class |
SparkPartitionPruningSinkOperator
This operator gets partition info from the upstream operators, and write them
to HDFS.
|
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 |
GenSparkWork.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SparkFileSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
protected void |
GenSparkWorkWalker.walk(Node nd)
Walk the given operator.
|
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 |
GenSparkWork.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs) |
Object |
SparkFileSinkProcessor.process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs) |
void |
GenSparkWorkWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
void |
GenSparkWorkWalker.startWalking(Collection<Node> startNodes,
HashMap<Node,Object> nodeOutput)
starting point for walking.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprNodeColumnDesc
ExprNodeColumnDesc.
|
class |
ExprNodeColumnListDesc
Dummy desc only for populating TOK_ALLCOLREF and should not be used
outside of TypeCheckProcFactory
|
class |
ExprNodeConstantDesc
A constant expression.
|
class |
ExprNodeDesc
ExprNodeDesc.
|
class |
ExprNodeDynamicListDesc
This expression represents a list that will be available at runtime.
|
class |
ExprNodeDynamicValueDesc
This expression represents a value that will be available at runtime.
|
class |
ExprNodeFieldDesc
ExprNodeFieldDesc.
|
class |
ExprNodeGenericFuncDesc
Describes a GenericFunc node.
|
class |
ExprNodeSubQueryDesc
This encapsulate subquery expression which consists of
Relnode for subquery.
|
Modifier and Type | Method and Description |
---|---|
protected Set<String> |
OpProcFactory.JoinerPPD.getAliases(Node nd) |
protected Set<String> |
OpProcFactory.JoinPPD.getAliases(Node nd) |
protected Object |
OpProcFactory.JoinerPPD.handlePredicates(Node nd,
ExprWalkerInfo prunePreds,
OpWalkerInfo owi) |
protected void |
OpProcFactory.DefaultPPD.logExpr(Node nd,
ExprWalkerInfo ewi) |
protected ExprWalkerInfo |
OpProcFactory.DefaultPPD.mergeChildrenPred(Node nd,
OpWalkerInfo owi,
Set<String> excludedAliases,
boolean ignoreAliases) |
protected boolean |
OpProcFactory.DefaultPPD.mergeWithChildrenPred(Node nd,
OpWalkerInfo owi,
ExprWalkerInfo ewi,
Set<String> aliases)
Take current operators pushdown predicates and merges them with
children's pushdown predicates.
|
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 |
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.
|
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 © 2022 The Apache Software Foundation. All rights reserved.