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

Class BucketingSortingCtx

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.physical.BucketingSortingCtx

All Implemented Interfaces:

NodeProcessorCtx

public class BucketingSortingCtx
extends Object
implements NodeProcessorCtx

This class contains the bucketing sorting context that is passed while walking the operator tree in inferring bucket/sort columns. The context contains the mappings from operators and files to the columns their output is bucketed/sorted on.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BucketingSortingCtx.BucketCol BucketCol.
static interface	BucketingSortingCtx.BucketSortCol BucketSortCol.
static class	BucketingSortingCtx.SortCol SortCol.

Constructor Summary

Constructors

Constructor and Description
BucketingSortingCtx(boolean disableBucketing)

Method Summary

Methods

Modifier and Type	Method and Description
List<BucketingSortingCtx.BucketCol>	getBucketedCols(Operator<? extends OperatorDesc> op)
Map<String,List<BucketingSortingCtx.BucketCol>>	getBucketedColsByDirectory()
List<BucketingSortingCtx.SortCol>	getSortedCols(Operator<? extends OperatorDesc> op)
Map<String,List<BucketingSortingCtx.SortCol>>	getSortedColsByDirectory()
void	setBucketedCols(Operator<? extends OperatorDesc> op, List<BucketingSortingCtx.BucketCol> bucketCols)
void	setBucketedColsByDirectory(Map<String,List<BucketingSortingCtx.BucketCol>> bucketedColsByDirectory)
void	setSortedCols(Operator<? extends OperatorDesc> op, List<BucketingSortingCtx.SortCol> sortedCols)
void	setSortedColsByDirectory(Map<String,List<BucketingSortingCtx.SortCol>> sortedColsByDirectory)

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketingSortingCtx

public BucketingSortingCtx(boolean disableBucketing)

Method Detail

getBucketedCols

public List<BucketingSortingCtx.BucketCol> getBucketedCols(Operator<? extends OperatorDesc> op)

setBucketedCols

public void setBucketedCols(Operator<? extends OperatorDesc> op,
                   List<BucketingSortingCtx.BucketCol> bucketCols)

getBucketedColsByDirectory

public Map<String,List<BucketingSortingCtx.BucketCol>> getBucketedColsByDirectory()

setBucketedColsByDirectory

public void setBucketedColsByDirectory(Map<String,List<BucketingSortingCtx.BucketCol>> bucketedColsByDirectory)

getSortedCols

public List<BucketingSortingCtx.SortCol> getSortedCols(Operator<? extends OperatorDesc> op)

setSortedCols

public void setSortedCols(Operator<? extends OperatorDesc> op,
                 List<BucketingSortingCtx.SortCol> sortedCols)

getSortedColsByDirectory

public Map<String,List<BucketingSortingCtx.SortCol>> getSortedColsByDirectory()

setSortedColsByDirectory

public void setSortedColsByDirectory(Map<String,List<BucketingSortingCtx.SortCol>> sortedColsByDirectory)