Package | Description |
---|---|
io.druid.query | |
io.druid.query.topn | |
io.druid.query.topn.types | |
io.druid.segment | |
io.druid.segment.historical | |
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() |
Modifier and Type | Method and Description |
---|---|
Result<TopNResultValue> |
TopNMapFn.apply(Cursor cursor,
TopNQueryMetrics queryMetrics) |
void |
TopNQueryMetrics.cursor(Cursor cursor)
This method is called exactly once with each cursor, processed for the query.
|
void |
DefaultTopNQueryMetrics.cursor(Cursor cursor) |
static Aggregator[] |
BaseTopNAlgorithm.makeAggregators(Cursor cursor,
List<AggregatorFactory> aggregatorSpecs) |
protected static BufferAggregator[] |
BaseTopNAlgorithm.makeBufferAggregators(Cursor cursor,
List<AggregatorFactory> aggregatorSpecs) |
TopNParams |
TopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
Cursor cursor) |
TopNParams |
DimExtractionTopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
Cursor cursor) |
TopNParams |
TimeExtractionTopNAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
Cursor cursor) |
PooledTopNAlgorithm.PooledTopNParams |
PooledTopNAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
Cursor cursor) |
TopNParams |
AggregateTopNMetricFirstAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
Cursor cursor) |
long |
Generic2AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector,
BufferAggregator aggregator1,
int aggregator1Size,
BufferAggregator aggregator2,
int aggregator2Size,
Cursor cursor,
int[] positions,
ByteBuffer resultsBuffer)
Any changes to this method should be coordinated with
TopNUtils , PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations() and downstream methods. |
long |
Generic2AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector,
BufferAggregator aggregator1,
int aggregator1Size,
BufferAggregator aggregator2,
int aggregator2Size,
Cursor cursor,
int[] positions,
ByteBuffer resultsBuffer) |
long |
Generic1AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector,
BufferAggregator aggregator,
int aggregatorSize,
Cursor cursor,
int[] positions,
ByteBuffer resultsBuffer)
Any changes to this method should be coordinated with
TopNUtils , PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations() and downstream methods. |
long |
Generic1AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector,
BufferAggregator aggregator,
int aggregatorSize,
Cursor cursor,
int[] positions,
ByteBuffer resultsBuffer) |
PooledTopNAlgorithm.PooledTopNParams.Builder |
PooledTopNAlgorithm.PooledTopNParams.Builder.withCursor(Cursor cursor) |
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 |
---|---|
long |
StringTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
DimensionSelector selector,
Cursor cursor,
Aggregator[][] rowSelector,
Map<String,Aggregator[]> aggregatesStore) |
long |
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,
QueryMetrics<?> queryMetrics) |
Sequence<Cursor> |
CursorFactory.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending,
QueryMetrics<?> queryMetrics) |
Modifier and Type | Interface and Description |
---|---|
interface |
HistoricalCursor |
Modifier and Type | Method and Description |
---|---|
Sequence<Cursor> |
IncrementalIndexStorageAdapter.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending,
QueryMetrics<?> queryMetrics) |
Copyright © 2011–2018. All rights reserved.