Package | Description |
---|---|
io.druid.query | |
io.druid.query.topn | |
io.druid.query.topn.types | |
io.druid.segment | |
io.druid.segment.incremental |
Modifier and Type | Method and Description |
---|---|
static <T> Sequence<Result<T>> |
QueryRunnerHelper.makeCursorBasedQuery(StorageAdapter adapter,
List<org.joda.time.Interval> queryIntervals,
Filter filter,
VirtualColumns virtualColumns,
boolean descending,
Granularity granularity,
com.google.common.base.Function<Cursor,Result<T>> mapFn) |
Modifier and Type | Method and Description |
---|---|
Cursor |
TopNParams.getCursor() |
Constructor and Description |
---|
PooledTopNParams(ColumnSelectorPlus selectorPlus,
Cursor cursor,
ResourceHolder<ByteBuffer> resultsBufHolder,
ByteBuffer resultsBuf,
int[] aggregatorSizes,
int numBytesPerRecord,
int numValuesPerPass,
TopNMetricSpecBuilder<int[]> arrayProvider) |
TopNParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
Cursor cursor,
int numValuesPerPass) |
Modifier and Type | Method and Description |
---|---|
void |
StringTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
DimensionSelector selector,
Cursor cursor,
Aggregator[][] rowSelector,
Map<String,Aggregator[]> aggregatesStore) |
void |
FloatTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
FloatColumnSelector selector,
Cursor cursor,
Aggregator[][] rowSelector,
it.unimi.dsi.fastutil.ints.Int2ObjectMap<Aggregator[]> aggregatesStore) |
void |
LongTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
LongColumnSelector selector,
Cursor cursor,
Aggregator[][] rowSelector,
it.unimi.dsi.fastutil.longs.Long2ObjectMap<Aggregator[]> aggregatesStore) |
void |
TopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
ValueSelectorType selector,
Cursor cursor,
Aggregator[][] rowSelector,
DimExtractionAggregateStoreType aggregatesStore)
Used by DimExtractionTopNAlgorithm.
|
Modifier and Type | Method and Description |
---|---|
Sequence<Cursor> |
QueryableIndexStorageAdapter.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending) |
Sequence<Cursor> |
CursorFactory.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending) |
Modifier and Type | Method and Description |
---|---|
Sequence<Cursor> |
IncrementalIndexStorageAdapter.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending) |
Copyright © 2011–2017. All rights reserved.