Class AggregationSpecification
- java.lang.Object
-
- org.apache.cassandra.db.aggregation.AggregationSpecification
-
public abstract class AggregationSpecification extends java.lang.Object
Defines how rows should be grouped for creating aggregates.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
AggregationSpecification.Kind
TheAggregationSpecification
kinds.static class
AggregationSpecification.Serializer
-
Field Summary
Fields Modifier and Type Field Description static AggregationSpecification
AGGREGATE_EVERYTHING
AggregationSpecification
that group all the row together.static AggregationSpecification.Serializer
serializer
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description static AggregationSpecification
aggregatePkPrefix(ClusteringComparator comparator, int clusteringPrefixSize)
Creates a newAggregationSpecification
instance that will build aggregates based on primary key columns.AggregationSpecification.Kind
kind()
Returns theAggregationSpecification
kind.GroupMaker
newGroupMaker()
Creates a newGroupMaker
instance.abstract GroupMaker
newGroupMaker(GroupingState state)
Creates a newGroupMaker
instance.
-
-
-
Field Detail
-
serializer
public static final AggregationSpecification.Serializer serializer
-
AGGREGATE_EVERYTHING
public static final AggregationSpecification AGGREGATE_EVERYTHING
AggregationSpecification
that group all the row together.
-
-
Method Detail
-
kind
public AggregationSpecification.Kind kind()
Returns theAggregationSpecification
kind.- Returns:
- the
AggregationSpecification
kind
-
newGroupMaker
public final GroupMaker newGroupMaker()
Creates a newGroupMaker
instance.- Returns:
- a new
GroupMaker
instance
-
newGroupMaker
public abstract GroupMaker newGroupMaker(GroupingState state)
Creates a newGroupMaker
instance.- Parameters:
state
-GroupMaker
state- Returns:
- a new
GroupMaker
instance
-
aggregatePkPrefix
public static AggregationSpecification aggregatePkPrefix(ClusteringComparator comparator, int clusteringPrefixSize)
Creates a newAggregationSpecification
instance that will build aggregates based on primary key columns.- Parameters:
comparator
- the comparator used to compare the clustering prefixesclusteringPrefixSize
- the number of clustering columns used to create the aggregates- Returns:
- a new
AggregationSpecification
instance that will build aggregates based on primary key columns
-
-