org.apache.hadoop.hive.ql.optimizer
Class GroupByOptimizer.SortGroupBySkewProcessor

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.GroupByOptimizer.SortGroupByProcessor
      org.apache.hadoop.hive.ql.optimizer.GroupByOptimizer.SortGroupBySkewProcessor

All Implemented Interfaces:

NodeProcessor

Enclosing class:

GroupByOptimizer

public class GroupByOptimizer.SortGroupBySkewProcessor
extends GroupByOptimizer.SortGroupByProcessor

SortGroupByProcessor.

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.optimizer.GroupByOptimizer.SortGroupByProcessor

pGraphContext

Constructor Summary

GroupByOptimizer.SortGroupBySkewProcessor(ParseContext pGraphContext)

Method Summary

Object

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

Methods inherited from class org.apache.hadoop.hive.ql.optimizer.GroupByOptimizer.SortGroupByProcessor

checkGroupByOperatorProcessed, checkSortGroupBy, convertGroupByMapSideSortedGroupBy, processGroupBy

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GroupByOptimizer.SortGroupBySkewProcessor

public GroupByOptimizer.SortGroupBySkewProcessor(ParseContext pGraphContext)

Method Detail

process

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

Description copied from interface: NodeProcessor

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

Specified by:

process in interface NodeProcessor

Overrides:

process in class GroupByOptimizer.SortGroupByProcessor

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