io.druid.query.groupby.orderby

Class DefaultLimitSpec

java.lang.Object

io.druid.query.groupby.orderby.DefaultLimitSpec

All Implemented Interfaces:

Cacheable, LimitSpec

public class DefaultLimitSpec
extends Object
implements LimitSpec

Constructor Summary

Constructors

Constructor and Description
DefaultLimitSpec(List<OrderByColumnSpec> columns, Integer limit)

Method Summary

Modifier and Type	Method and Description
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs, Granularity granularity, boolean sortByDimsFirst) Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
boolean	equals(Object o)
byte[]	getCacheKey() Get a byte array used as a cache key.
List<OrderByColumnSpec>	getColumns()
static StringComparator	getComparatorForDimName(DefaultLimitSpec limitSpec, String dimName)
int	getLimit()
int	hashCode()
boolean	isLimited()
LimitSpec	merge(LimitSpec other)
static boolean	sortingOrderHasNonGroupingFields(DefaultLimitSpec limitSpec, List<DimensionSpec> dimensions) Check if a limitSpec has columns in the sorting order that are not part of the grouping fields represented by `dimensions`.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.druid.query.groupby.orderby.LimitSpec

nullToNoopLimitSpec

Constructor Detail

DefaultLimitSpec

public DefaultLimitSpec(List<OrderByColumnSpec> columns,
                        Integer limit)

Method Detail

sortingOrderHasNonGroupingFields

public static boolean sortingOrderHasNonGroupingFields(DefaultLimitSpec limitSpec,
                                                       List<DimensionSpec> dimensions)

Check if a limitSpec has columns in the sorting order that are not part of the grouping fields represented by `dimensions`.

Parameters:

limitSpec - LimitSpec, assumed to be non-null

dimensions - Grouping fields for a groupBy query

Returns:

True if limitSpec has sorting columns not contained in dimensions

getComparatorForDimName

public static StringComparator getComparatorForDimName(DefaultLimitSpec limitSpec,
                                                       String dimName)

getColumns

public List<OrderByColumnSpec> getColumns()

getLimit

public int getLimit()

isLimited

public boolean isLimited()

build

public com.google.common.base.Function<Sequence<Row>,Sequence<Row>> build(List<DimensionSpec> dimensions,
                                                                          List<AggregatorFactory> aggs,
                                                                          List<PostAggregator> postAggs,
                                                                          Granularity granularity,
                                                                          boolean sortByDimsFirst)

Description copied from interface: LimitSpec

Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.

Specified by:

build in interface LimitSpec

Parameters:

dimensions - query dimensions

aggs - query aggregators

postAggs - query postAggregators

granularity - query granularity

sortByDimsFirst - 'sortByDimsFirst' value in queryContext

Returns:

limit function

merge

public LimitSpec merge(LimitSpec other)

Specified by:

merge in interface LimitSpec

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getCacheKey

public byte[] getCacheKey()

Description copied from interface: Cacheable

Get a byte array used as a cache key.

Specified by:

getCacheKey in interface Cacheable

Returns:

a cache key