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

Constructors

Constructor and Description
GroupByOptimizer.SortGroupBySkewProcessor(ParseContext pGraphContext)

Method Summary

Methods

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.

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