io.druid.query.aggregation.cardinality

Class CardinalityAggregator

java.lang.Object

io.druid.query.aggregation.cardinality.CardinalityAggregator

All Implemented Interfaces:

Aggregator

public class CardinalityAggregator
extends Object
implements Aggregator

Field Summary

Fields

Modifier and Type	Field and Description
static char	SEPARATOR

Constructor Summary

Constructors

Constructor and Description
CardinalityAggregator(String name, List<DimensionSelector> selectorList, boolean byRow)

Method Summary

Methods

Modifier and Type	Method and Description
void	aggregate()
Aggregator	clone()
void	close()
Object	get()
float	getFloat()
long	getLong()
String	getName()
protected static void	hashRow(List<DimensionSelector> selectorList, HyperLogLogCollector collector)
protected static void	hashValues(List<DimensionSelector> selectors, HyperLogLogCollector collector)
void	reset()

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SEPARATOR

public static final char SEPARATOR

See Also:

Constant Field Values

Constructor Detail

CardinalityAggregator

public CardinalityAggregator(String name,
                     List<DimensionSelector> selectorList,
                     boolean byRow)

Method Detail

hashRow

protected static void hashRow(List<DimensionSelector> selectorList,
           HyperLogLogCollector collector)

hashValues

protected static void hashValues(List<DimensionSelector> selectors,
              HyperLogLogCollector collector)

aggregate

public void aggregate()

Specified by:

aggregate in interface Aggregator

reset

public void reset()

Specified by:

reset in interface Aggregator

get

public Object get()

Specified by:

get in interface Aggregator

getFloat

public float getFloat()

Specified by:

getFloat in interface Aggregator

getLong

public long getLong()

Specified by:

getLong in interface Aggregator

getName

public String getName()

Specified by:

getName in interface Aggregator

clone

public Aggregator clone()

Overrides:

clone in class Object

close

public void close()

Specified by:

close in interface Aggregator