org.apache.hadoop.hive.ql.optimizer.physical
Class BucketingSortingOpProcFactory

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.physical.BucketingSortingOpProcFactory

public class BucketingSortingOpProcFactory
extends Object

Operator factory for the rule processors for inferring bucketing/sorting columns.

Nested Class Summary

static class	BucketingSortingOpProcFactory.DefaultInferrer
static class	BucketingSortingOpProcFactory.ExtractInferrer Processor for Extract operator.
static class	BucketingSortingOpProcFactory.FileSinkInferrer Processor for FileSink operator.
static class	BucketingSortingOpProcFactory.ForwardingInferrer Filter processor
static class	BucketingSortingOpProcFactory.GroupByInferrer Processor for GroupBy operator.
static class	BucketingSortingOpProcFactory.JoinInferrer Processor for Join Operator.
static class	BucketingSortingOpProcFactory.MultiGroupByInferrer Processor for GroupByOperator, the special case where it follows a ForwardOperator There is a multi group by optimization which puts multiple group by operators in a reducer when they share the same keys and are part of a multi insert query.
static class	BucketingSortingOpProcFactory.SelectInferrer Processor for Select operator.

Constructor Summary

BucketingSortingOpProcFactory()

Method Summary

static NodeProcessor	getDefaultProc()
static NodeProcessor	getExtractProc()
static NodeProcessor	getFileSinkProc()
static NodeProcessor	getFilterProc()
static NodeProcessor	getForwardProc()
static NodeProcessor	getGroupByProc()
static NodeProcessor	getJoinProc()
static NodeProcessor	getLateralViewForwardProc()
static NodeProcessor	getLateralViewJoinProc()
static NodeProcessor	getLimitProc()
static NodeProcessor	getMultiGroupByProc()
static NodeProcessor	getSelProc()

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketingSortingOpProcFactory

public BucketingSortingOpProcFactory()

Method Detail

getDefaultProc

public static NodeProcessor getDefaultProc()

getJoinProc

public static NodeProcessor getJoinProc()

getSelProc

public static NodeProcessor getSelProc()

getGroupByProc

public static NodeProcessor getGroupByProc()

getFileSinkProc

public static NodeProcessor getFileSinkProc()

getExtractProc

public static NodeProcessor getExtractProc()

getFilterProc

public static NodeProcessor getFilterProc()

getLimitProc

public static NodeProcessor getLimitProc()

getLateralViewForwardProc

public static NodeProcessor getLateralViewForwardProc()

getLateralViewJoinProc

public static NodeProcessor getLateralViewJoinProc()

getForwardProc

public static NodeProcessor getForwardProc()

getMultiGroupByProc

public static NodeProcessor getMultiGroupByProc()