io.druid.query.groupby.epinephelinae

Interface Grouper<KeyType>

Type Parameters:

KeyType - type of the key that will be passed in

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

BufferGrouper, ConcurrentGrouper, SpillingGrouper

public interface Grouper<KeyType>
extends Closeable

Groupers aggregate metrics from rows that they typically get from a ColumnSelectorFactory, under grouping keys that some outside driver is passing in. They can also iterate over the grouped rows after the aggregation is done.

They work sort of like a map of KeyType to aggregated values, except they don't support random lookups.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Grouper.Entry<T>
static interface	Grouper.KeyComparator
static interface	Grouper.KeySerde<T> Possibly-stateful object responsible for serde and comparison of keys.
static interface	Grouper.KeySerdeFactory<T>

Method Summary

Modifier and Type	Method and Description
boolean	aggregate(KeyType key) Aggregate the current row with the provided key.
boolean	aggregate(KeyType key, int keyHash) Aggregate the current row with the provided key.
void	close() Close the grouper and release associated resources.
void	init() Initialize the grouper.
boolean	isInitialized() Check this grouper is initialized or not.
Iterator<Grouper.Entry<KeyType>>	iterator(boolean sorted) Iterate through entries.
void	reset() Reset the grouper to its initial state.

Method Detail

init

void init()

Initialize the grouper. This method needs to be called before calling aggregate(Object) and aggregate(Object, int).

isInitialized

boolean isInitialized()

Check this grouper is initialized or not.

Returns:

true if the grouper is already initialized, otherwise false.

aggregate

boolean aggregate(KeyType key,
                  int keyHash)

Aggregate the current row with the provided key. Some implementations are thread-safe and some are not.

Parameters:

key - key object

keyHash - result of Groupers.hash(Object) on the key

Returns:

true if the row was aggregated, false if not due to hitting resource limits

aggregate

boolean aggregate(KeyType key)

Aggregate the current row with the provided key. Some implementations are thread-safe and some are not.

Parameters:

key - key

Returns:

true if the row was aggregated, false if not due to hitting resource limits

reset

void reset()

Reset the grouper to its initial state.

close

void close()

Close the grouper and release associated resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

iterator

Iterator<Grouper.Entry<KeyType>> iterator(boolean sorted)

Iterate through entries. If a comparator is provided, do a sorted iteration.

Once this method is called, writes are no longer safe. After you are done with the iterator returned by this method, you should either call close() (if you are done with the Grouper), reset() (if you want to reuse it), or iterator(boolean) again if you want another iterator.

If "sorted" is true then the iterator will return sorted results. It will use KeyType's natural ordering on deserialized objects, and will use the KeySerde#comparator() on serialized objects. Woe be unto you if these comparators are not equivalent.

Parameters:

sorted - return sorted results

Returns:

entry iterator