org.apache.hadoop.hive.ql.lib

Interface NodeProcessor

All Known Implementing Classes:

AbstractBucketJoinProc, AbstractSMBJoinProc, AccumuloRangeGenerator, AppMasterEventProcessor, BucketingSortingOpProcFactory.DefaultInferrer, BucketingSortingOpProcFactory.FileSinkInferrer, BucketingSortingOpProcFactory.ForwardingInferrer, BucketingSortingOpProcFactory.GroupByInferrer, BucketingSortingOpProcFactory.JoinInferrer, BucketingSortingOpProcFactory.MultiGroupByInferrer, BucketingSortingOpProcFactory.SelectInferrer, BucketingSortingReduceSinkOptimizer.BucketSortReduceSinkProcessor, BucketMapjoinProc, ColumnPrunerProcFactory.ColumnPrunerDefaultProc, ColumnPrunerProcFactory.ColumnPrunerFilterProc, ColumnPrunerProcFactory.ColumnPrunerGroupByProc, ColumnPrunerProcFactory.ColumnPrunerJoinProc, ColumnPrunerProcFactory.ColumnPrunerLateralViewForwardProc, ColumnPrunerProcFactory.ColumnPrunerLateralViewJoinProc, ColumnPrunerProcFactory.ColumnPrunerLimitProc, ColumnPrunerProcFactory.ColumnPrunerMapJoinProc, ColumnPrunerProcFactory.ColumnPrunerPTFProc, ColumnPrunerProcFactory.ColumnPrunerReduceSinkProc, ColumnPrunerProcFactory.ColumnPrunerScriptProc, ColumnPrunerProcFactory.ColumnPrunerSelectProc, ColumnPrunerProcFactory.ColumnPrunerTableScanProc, ColumnPrunerProcFactory.ColumnPrunerUnionProc, CompositeProcessor, ConstantPropagateProcFactory.ConstantPropagateDefaultProc, ConstantPropagateProcFactory.ConstantPropagateFileSinkProc, ConstantPropagateProcFactory.ConstantPropagateFilterProc, ConstantPropagateProcFactory.ConstantPropagateGroupByProc, ConstantPropagateProcFactory.ConstantPropagateJoinProc, ConstantPropagateProcFactory.ConstantPropagateReduceSinkProc, ConstantPropagateProcFactory.ConstantPropagateSelectProc, ConstantPropagateProcFactory.ConstantPropagateStopProc, ConstantPropagateProcFactory.ConstantPropagateTableScanProc, ConvertJoinMapJoin, CountDistinctRewriteProc.CountDistinctProcessor, CrossProductHandler.ExtractReduceSinkInfo, CrossProductHandler.MapJoinCheck, DynamicPartitionPruningOptimization, ExprProcFactory.ColumnExprProcessor, ExprProcFactory.DefaultExprProcessor, ExprProcFactory.GenericExprProcessor, ExprProcFactory.PPRColumnExprProcessor, ExprWalkerProcFactory.ColumnExprProcessor, ExprWalkerProcFactory.DefaultExprProcessor, ExprWalkerProcFactory.FieldExprProcessor, ExprWalkerProcFactory.GenericFuncExprProcessor, FileSinkProcessor, FixedBucketPruningOptimizer.BucketBitsetGenerator, FixedBucketPruningOptimizer.FixedBucketPartitionWalker, FixedBucketPruningOptimizer.NoopWalker, GenMRFileSink1, GenMROperator, GenMRRedSink1, GenMRRedSink2, GenMRRedSink3, GenMRTableScan1, GenMRUnion1, GenSparkWork, GenTezUtils.DynamicPartitionPrunerProc, GenTezWork, GroupByOptimizer.SortGroupByProcessor, GroupByOptimizer.SortGroupBySkewProcessor, JoinCondTypeCheckProcFactory.JoinCondColumnExprProcessor, JoinCondTypeCheckProcFactory.JoinCondDefaultExprProcessor, LBExprProcFactory.LBPRColumnExprProcessor, LBPartitionProcFactory.LBPRPartitionFilterPruner, LBProcFactory.LBPRFilterPruner, LineageInfo, LocalMapJoinProcFactory.LocalMapJoinProcessor, LocalMapJoinProcFactory.MapJoinFollowedByGroupByProcessor, MapJoinProcessor.CurrentMapJoin, MapJoinProcessor.Default, MapJoinProcessor.MapJoinDefault, MapJoinProcessor.MapJoinFS, MemoryDecider.MemoryCalculator.DefaultRule, MergeJoinProc, OpProcFactory.DefaultLineage, OpProcFactory.DefaultPPD, OpProcFactory.FilterLineage, OpProcFactory.FilterPPD, OpProcFactory.FilterPPR, OpProcFactory.GroupByLineage, OpProcFactory.JoinerPPD, OpProcFactory.JoinLineage, OpProcFactory.JoinPPD, OpProcFactory.LateralViewForwardPPD, OpProcFactory.LateralViewJoinLineage, OpProcFactory.PTFPPD, OpProcFactory.ReduceSinkLineage, OpProcFactory.ReduceSinkPPD, OpProcFactory.ScriptPPD, OpProcFactory.SelectLineage, OpProcFactory.SimpleFilterPPD, OpProcFactory.TableScanLineage, OpProcFactory.TableScanPPD, OpProcFactory.TransformLineage, OpProcFactory.UDTFPPD, OpProcFactory.UnionLineage, OpTraitsRulesProcFactory.DefaultRule, OpTraitsRulesProcFactory.GroupByRule, OpTraitsRulesProcFactory.JoinRule, OpTraitsRulesProcFactory.MultiParentRule, OpTraitsRulesProcFactory.ReduceSinkRule, OpTraitsRulesProcFactory.SelectRule, OpTraitsRulesProcFactory.TableScanRule, PcrExprProcFactory.ColumnExprProcessor, PcrExprProcFactory.DefaultExprProcessor, PcrExprProcFactory.FieldExprProcessor, PcrExprProcFactory.GenericFuncExprProcessor, PcrOpProcFactory.DefaultPCR, PcrOpProcFactory.FilterPCR, PrintOpTreeProcessor, ProcessAnalyzeTable, PrunerExpressionOperatorFactory.ColumnExprProcessor, PrunerExpressionOperatorFactory.DefaultExprProcessor, PrunerExpressionOperatorFactory.FieldExprProcessor, PrunerExpressionOperatorFactory.GenericFuncExprProcessor, PrunerOperatorFactory.DefaultPruner, PrunerOperatorFactory.FilterPruner, ReduceSinkDeDuplication.AbsctractReducerReducerProc, ReduceSinkMapJoinProc, RemoveDynamicPruningBySize, SamplePruner.DefaultPPR, SamplePruner.FilterPPR, SerializeFilter.Serializer.DefaultRule, SetReducerParallelism, SetSparkReducerParallelism, SkewJoinOptimizer.SkewJoinProc, SkewJoinProcFactory.SkewJoinDefaultProcessor, SkewJoinProcFactory.SkewJoinJoinProcessor, SortedMergeBucketMapjoinProc, SortedMergeJoinProc, SparkFileSinkProcessor, SparkJoinHintOptimizer, SparkJoinOptimizer, SparkMapJoinOptimizer, SparkProcessAnalyzeTable, SparkReduceSinkMapJoinProc, SparkReduceSinkMapJoinProc.SparkMapJoinFollowedByGroupByProcessor, SparkRemoveDynamicPruning, SparkSkewJoinProcFactory.SparkSkewJoinJoinProcessor, SparkSMBJoinHintOptimizer, SparkSortMergeJoinOptimizer, SplitOpTreeForDPP, StatsRulesProcFactory.DefaultStatsRule, StatsRulesProcFactory.FilterStatsRule, StatsRulesProcFactory.GroupByStatsRule, StatsRulesProcFactory.JoinStatsRule, StatsRulesProcFactory.LimitStatsRule, StatsRulesProcFactory.ReduceSinkStatsRule, StatsRulesProcFactory.SelectStatsRule, StatsRulesProcFactory.TableScanStatsRule, TableAccessAnalyzer.GroupByProcessor, TableAccessAnalyzer.JoinProcessor, TypeCheckProcFactory.BoolExprProcessor, TypeCheckProcFactory.ColumnExprProcessor, TypeCheckProcFactory.DateTimeExprProcessor, TypeCheckProcFactory.DefaultExprProcessor, TypeCheckProcFactory.IntervalExprProcessor, TypeCheckProcFactory.NullExprProcessor, TypeCheckProcFactory.NumExprProcessor, TypeCheckProcFactory.StrExprProcessor, TypeCheckProcFactory.SubQueryExprProcessor, UnionProcessor, UnionProcFactory.MapRedUnion, UnionProcFactory.MapUnion, UnionProcFactory.NoUnion, UnionProcFactory.UnionNoProcessFile, UnionProcFactory.UnknownUnion

public interface NodeProcessor

Base class for processing operators which is no-op. The specific processors can register their own context with the dispatcher.

Method Summary

Modifier and Type	Method and Description
Object	process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx, Object... nodeOutputs) Generic process for all ops that don't have specific implementations.

Method Detail

process

Object process(Node nd,
               Stack<Node> stack,
               NodeProcessorCtx procCtx,
               Object... nodeOutputs)
        throws SemanticException

Generic process for all ops that don't have specific implementations.

Parameters:

nd - operator to process

procCtx - operator processor context

nodeOutputs - A variable argument list of outputs from other nodes in the walk

Returns:

Object to be returned by the process call

Throws:

SemanticException