| Package | Description |
|---|---|
| io.druid.query.groupby.epinephelinae |
| Modifier and Type | Field and Description |
|---|---|
protected Grouper.KeySerde<KeyType> |
AbstractBufferHashGrouper.keySerde |
| Modifier and Type | Method and Description |
|---|---|
Grouper.KeySerde<T> |
Grouper.KeySerdeFactory.factorize()
Create a new
Grouper.KeySerde, which may be stateful. |
Grouper.KeySerde<T> |
Grouper.KeySerdeFactory.factorizeWithDictionary(List<String> dictionary)
Create a new
Grouper.KeySerde with the given dictionary. |
| Modifier and Type | Method and Description |
|---|---|
static <KeyType> int |
StreamingMergeSortedGrouper.requiredBufferCapacity(Grouper.KeySerde<KeyType> keySerde,
AggregatorFactory[] aggregatorFactories)
Returns the minimum buffer capacity required for this grouper.
|
| Constructor and Description |
|---|
AbstractBufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerde<KeyType> keySerde,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize) |
BufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerde<KeyType> keySerde,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize,
float maxLoadFactor,
int initialBuckets,
boolean useDefaultSorting) |
LimitedBufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerde<KeyType> keySerde,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize,
float maxLoadFactor,
int initialBuckets,
int limit,
boolean sortHasNonGroupingFields) |
Copyright © 2011–2018. All rights reserved.