Package | Description |
---|---|
io.druid.collections | |
io.druid.query.groupby.epinephelinae | |
io.druid.query.groupby.resource | |
io.druid.query.topn | |
io.druid.segment | |
io.druid.segment.data |
Modifier and Type | Class and Description |
---|---|
class |
ReferenceCountingResourceHolder<T> |
class |
StupidResourceHolder<T> |
Modifier and Type | Method and Description |
---|---|
ResourceHolder<T> |
StupidPool.take() |
ResourceHolder<T> |
NonBlockingPool.take() |
ResourceHolder<T> |
DummyNonBlockingPool.take() |
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
com.google.common.util.concurrent.ListeningExecutorService grouperSorter,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt,
int mergeBufferSize)
If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not
been applied to the input rows yet, for example, in a nested query, if an extraction function is being
applied in the outer query to a field of the inner query.
|
Constructor and Description |
---|
ConcurrentGrouper(GroupByQueryConfig groupByQueryConfig,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
Grouper.KeySerdeFactory<KeyType> keySerdeFactory,
Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
int concurrencyHint,
DefaultLimitSpec limitSpec,
boolean sortHasNonGroupingFields,
com.google.common.util.concurrent.ListeningExecutorService executor,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt) |
ParallelCombiner(com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
AggregatorFactory[] combiningFactories,
Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory,
com.google.common.util.concurrent.ListeningExecutorService executor,
boolean sortHasNonGroupingFields,
int concurrencyHint,
int priority,
long queryTimeoutAt,
int intermediateCombineDegree) |
Modifier and Type | Method and Description |
---|---|
ResourceHolder<ByteBuffer> |
GroupByQueryResource.getMergeBuffer()
Get a merge buffer from the pre-acquired resources.
|
Constructor and Description |
---|
GroupByQueryResource(ResourceHolder<List<ByteBuffer>> mergeBuffersHolder) |
Modifier and Type | Method and Description |
---|---|
ResourceHolder<ByteBuffer> |
PooledTopNAlgorithm.PooledTopNParams.getResultsBufHolder() |
Modifier and Type | Method and Description |
---|---|
PooledTopNAlgorithm.PooledTopNParams.Builder |
PooledTopNAlgorithm.PooledTopNParams.Builder.withResultsBufHolder(ResourceHolder<ByteBuffer> resultsBufHolder) |
Constructor and Description |
---|
PooledTopNParams(ColumnSelectorPlus selectorPlus,
Cursor cursor,
ResourceHolder<ByteBuffer> resultsBufHolder,
ByteBuffer resultsBuf,
int[] aggregatorSizes,
int numBytesPerRecord,
int numValuesPerPass,
TopNMetricSpecBuilder<int[]> arrayProvider) |
Modifier and Type | Method and Description |
---|---|
static ResourceHolder<com.ning.compress.BufferRecycler> |
CompressedPools.getBufferRecycler() |
static ResourceHolder<ByteBuffer> |
CompressedPools.getByteBuf(ByteOrder order) |
static ResourceHolder<byte[]> |
CompressedPools.getOutputBytes() |
Modifier and Type | Method and Description |
---|---|
ResourceHolder<ByteBuffer> |
DecompressingByteBufferObjectStrategy.fromByteBuffer(ByteBuffer buffer,
int numBytes) |
Modifier and Type | Method and Description |
---|---|
Class<? extends ResourceHolder<ByteBuffer>> |
DecompressingByteBufferObjectStrategy.getClazz() |
Modifier and Type | Method and Description |
---|---|
int |
DecompressingByteBufferObjectStrategy.compare(ResourceHolder<ByteBuffer> o1,
ResourceHolder<ByteBuffer> o2) |
int |
DecompressingByteBufferObjectStrategy.compare(ResourceHolder<ByteBuffer> o1,
ResourceHolder<ByteBuffer> o2) |
byte[] |
DecompressingByteBufferObjectStrategy.toBytes(ResourceHolder<ByteBuffer> holder) |
Copyright © 2011–2018. All rights reserved.