com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup Class Reference

Collaboration diagram for com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup:

Public Member Functions
	PartitionGroup (SortGroup sortGroup)
boolean	isCompatible (SortGroup sortGroup)
void	add (SortGroup sortGroup)
void	merge (PartitionGroup other)
void	orderSortGroups ()

Public Attributes
List< Expr >	partitionByExprs
List< SortGroup >	sortGroups = Lists.newArrayList()
int	totalOutputTupleSize = -1

Detailed Description

Collection of SortGroups that have compatible partition-by specifications.

Definition at line 751 of file AnalyticPlanner.java.

Constructor & Destructor Documentation

com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.PartitionGroup ( SortGroup  sortGroup )

inline

Definition at line 758 of file AnalyticPlanner.java.

References com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.partitionByExprs, and com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.totalOutputTupleSize.

Member Function Documentation

void com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.add ( SortGroup  sortGroup )

inline

Definition at line 772 of file AnalyticPlanner.java.

References com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.isCompatible(), and com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.totalOutputTupleSize.

boolean com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.isCompatible ( SortGroup  sortGroup )

inline

True if the partition exprs of sortGroup are compatible with ours. For now that means equality.

Definition at line 768 of file AnalyticPlanner.java.

References com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.partitionByExprs.

Referenced by com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.add().

void com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.merge ( PartitionGroup  other )

inline

Merge 'other' into 'this'

• partitionByExprs is the intersection of the two
• sortGroups becomes the union

Definition at line 783 of file AnalyticPlanner.java.

References com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.partitionByExprs.

void com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.orderSortGroups ( )

inline

Order sort groups by increasing totalOutputTupleSize. This minimizes the total volume of data that needs to be sorted.

Definition at line 793 of file AnalyticPlanner.java.

References com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.sortGroups.

Member Data Documentation

List<Expr> com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.partitionByExprs

Definition at line 752 of file AnalyticPlanner.java.

Referenced by com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.isCompatible(), com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.merge(), and com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.PartitionGroup().

List<SortGroup> com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.sortGroups = Lists.newArrayList()

Definition at line 753 of file AnalyticPlanner.java.

Referenced by com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.orderSortGroups().

int com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.totalOutputTupleSize = -1

Definition at line 756 of file AnalyticPlanner.java.

Referenced by com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.add(), and com.cloudera.impala.planner.AnalyticPlanner.PartitionGroup.PartitionGroup().

---

The documentation for this class was generated from the following file:

• fe/src/main/java/com/cloudera/impala/planner/AnalyticPlanner.java