io.druid.query.groupby.orderby

Interface LimitSpec

All Superinterfaces:

Cacheable

All Known Implementing Classes:

DefaultLimitSpec, NoopLimitSpec

public interface LimitSpec
extends Cacheable

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.
LimitSpec	merge(LimitSpec other)
static LimitSpec	nullToNoopLimitSpec(LimitSpec limitSpec)

Methods inherited from interface io.druid.java.util.common.Cacheable

getCacheKey

Method Detail

nullToNoopLimitSpec

static LimitSpec nullToNoopLimitSpec(@Nullable
                                     LimitSpec limitSpec)

build

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.

Parameters:

dimensions - query dimensions

aggs - query aggregators

postAggs - query postAggregators

granularity - query granularity

sortByDimsFirst - 'sortByDimsFirst' value in queryContext

Returns:

limit function

merge

LimitSpec merge(LimitSpec other)