org.apache.hadoop.hive.ql.plan

Class GroupByDesc

java.lang.Object

org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

org.apache.hadoop.hive.ql.plan.GroupByDesc

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

public class GroupByDesc
extends AbstractOperatorDesc

GroupByDesc.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	GroupByDesc.GroupByOperatorExplainVectorization
static class	GroupByDesc.Mode Mode.

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode

Constructor Summary

Constructors

Constructor and Description
GroupByDesc()
GroupByDesc(GroupByDesc.Mode mode, ArrayList<String> outputColumnNames, ArrayList<ExprNodeDesc> keys, ArrayList<AggregationDesc> aggregators, boolean bucketGroup, float groupByMemoryUsage, float memoryThreshold, List<Long> listGroupingSets, boolean groupingSetsPresent, int groupingSetsPosition, boolean isDistinct)
GroupByDesc(GroupByDesc.Mode mode, ArrayList<String> outputColumnNames, ArrayList<ExprNodeDesc> keys, ArrayList<AggregationDesc> aggregators, float groupByMemoryUsage, float memoryThreshold, List<Long> listGroupingSets, boolean groupingSetsPresent, int groupingSetsPosition, boolean isDistinct)

Method Summary

Modifier and Type	Method and Description
Object	clone()
ArrayList<AggregationDesc>	getAggregators()
List<String>	getAggregatorStrings()
boolean	getBucketGroup()
static String	getComplexTypeEnabledCondition(boolean isVectorizationComplexTypesEnabled)
static String	getComplexTypeWithGroupByEnabledCondition(boolean isVectorizationComplexTypesEnabled, boolean isVectorizationGroupByComplexTypesEnabled)
float	getGroupByMemoryUsage()
GroupByDesc.GroupByOperatorExplainVectorization	getGroupByVectorization()
int	getGroupingSetPosition()
ArrayList<ExprNodeDesc>	getKeys()
String	getKeyString()
List<Long>	getListGroupingSets()
float	getMemoryThreshold()
GroupByDesc.Mode	getMode()
String	getModeString()
ArrayList<String>	getOutputColumnNames()
String	getUserLevelExplainKeyString()
ArrayList<String>	getUserLevelExplainOutputColumnNames()
boolean	isAggregate()
boolean	isDistinct()
boolean	isDistinctLike() Checks if this grouping is like distinct, which means that all non-distinct grouping columns behave like they were distinct - for example min and max operators.
boolean	isDontResetAggrsDistinct()
boolean	isGroupingSetsPresent()
boolean	isSame(OperatorDesc other) The default implementation delegates to Object.equals(Object).
boolean	pruneGroupingSetId()
void	setAggregators(ArrayList<AggregationDesc> aggregators)
void	setBucketGroup(boolean bucketGroup)
void	setDistinct(boolean isDistinct)
void	setDontResetAggrsDistinct(boolean dontResetAggrsDistinct)
void	setGroupByMemoryUsage(float groupByMemoryUsage)
void	setGroupingSetPosition(int groupingSetPosition)
void	setGroupingSetsPresent(boolean groupingSetsPresent)
void	setKeys(ArrayList<ExprNodeDesc> keys)
void	setListGroupingSets(List<Long> listGroupingSets)
void	setMemoryThreshold(float memoryThreshold)
void	setMode(GroupByDesc.Mode mode)
void	setOutputColumnNames(ArrayList<String> outputColumnNames)

Methods inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupByDesc

public GroupByDesc()

GroupByDesc

public GroupByDesc(GroupByDesc.Mode mode,
                   ArrayList<String> outputColumnNames,
                   ArrayList<ExprNodeDesc> keys,
                   ArrayList<AggregationDesc> aggregators,
                   float groupByMemoryUsage,
                   float memoryThreshold,
                   List<Long> listGroupingSets,
                   boolean groupingSetsPresent,
                   int groupingSetsPosition,
                   boolean isDistinct)

GroupByDesc

public GroupByDesc(GroupByDesc.Mode mode,
                   ArrayList<String> outputColumnNames,
                   ArrayList<ExprNodeDesc> keys,
                   ArrayList<AggregationDesc> aggregators,
                   boolean bucketGroup,
                   float groupByMemoryUsage,
                   float memoryThreshold,
                   List<Long> listGroupingSets,
                   boolean groupingSetsPresent,
                   int groupingSetsPosition,
                   boolean isDistinct)

Method Detail

getMode

public GroupByDesc.Mode getMode()

getModeString

public String getModeString()

setMode

public void setMode(GroupByDesc.Mode mode)

getKeyString

public String getKeyString()

getUserLevelExplainKeyString

public String getUserLevelExplainKeyString()

getKeys

public ArrayList<ExprNodeDesc> getKeys()

setKeys

public void setKeys(ArrayList<ExprNodeDesc> keys)

getOutputColumnNames

public ArrayList<String> getOutputColumnNames()

getUserLevelExplainOutputColumnNames

public ArrayList<String> getUserLevelExplainOutputColumnNames()

pruneGroupingSetId

public boolean pruneGroupingSetId()

setOutputColumnNames

public void setOutputColumnNames(ArrayList<String> outputColumnNames)

getGroupByMemoryUsage

public float getGroupByMemoryUsage()

setGroupByMemoryUsage

public void setGroupByMemoryUsage(float groupByMemoryUsage)

getMemoryThreshold

public float getMemoryThreshold()

setMemoryThreshold

public void setMemoryThreshold(float memoryThreshold)

getAggregatorStrings

public List<String> getAggregatorStrings()

getAggregators

public ArrayList<AggregationDesc> getAggregators()

setAggregators

public void setAggregators(ArrayList<AggregationDesc> aggregators)

isAggregate

public boolean isAggregate()

getBucketGroup

public boolean getBucketGroup()

setBucketGroup

public void setBucketGroup(boolean bucketGroup)

isDistinctLike

public boolean isDistinctLike()

Checks if this grouping is like distinct, which means that all non-distinct grouping columns behave like they were distinct - for example min and max operators.

getListGroupingSets

public List<Long> getListGroupingSets()

setListGroupingSets

public void setListGroupingSets(List<Long> listGroupingSets)

isGroupingSetsPresent

public boolean isGroupingSetsPresent()

setGroupingSetsPresent

public void setGroupingSetsPresent(boolean groupingSetsPresent)

getGroupingSetPosition

public int getGroupingSetPosition()

setGroupingSetPosition

public void setGroupingSetPosition(int groupingSetPosition)

isDontResetAggrsDistinct

public boolean isDontResetAggrsDistinct()

setDontResetAggrsDistinct

public void setDontResetAggrsDistinct(boolean dontResetAggrsDistinct)

isDistinct

public boolean isDistinct()

setDistinct

public void setDistinct(boolean isDistinct)

clone

public Object clone()

Specified by:

clone in interface OperatorDesc

Overrides:

clone in class AbstractOperatorDesc

getGroupByVectorization

public GroupByDesc.GroupByOperatorExplainVectorization getGroupByVectorization()

getComplexTypeEnabledCondition

public static String getComplexTypeEnabledCondition(boolean isVectorizationComplexTypesEnabled)

getComplexTypeWithGroupByEnabledCondition

public static String getComplexTypeWithGroupByEnabledCondition(boolean isVectorizationComplexTypesEnabled,
                                                               boolean isVectorizationGroupByComplexTypesEnabled)

isSame

public boolean isSame(OperatorDesc other)

Description copied from class: AbstractOperatorDesc

The default implementation delegates to Object.equals(Object). Intended to be overridden by sub classes.

Specified by:

isSame in interface OperatorDesc

Overrides:

isSame in class AbstractOperatorDesc