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.