io.druid.query.aggregation.datasketches.theta

Class SketchAggregatorFactory

java.lang.Object

io.druid.query.aggregation.AggregatorFactory

io.druid.query.aggregation.datasketches.theta.SketchAggregatorFactory

Direct Known Subclasses:

SketchMergeAggregatorFactory

public abstract class SketchAggregatorFactory
extends AggregatorFactory

Field Summary

Fields

Modifier and Type	Field and Description
static Comparator<com.yahoo.sketches.theta.Sketch>	COMPARATOR
static int	DEFAULT_MAX_SKETCH_SIZE
protected String	fieldName
protected String	name
protected int	size

Constructor Summary

Constructors

Constructor and Description
SketchAggregatorFactory(String name, String fieldName, Integer size, byte cacheId)

Method Summary

Modifier and Type	Method and Description
Object	combine(Object lhs, Object rhs) A method that knows how to combine the outputs of the getIntermediate() method from the Aggregators produced via factorize().
Object	deserialize(Object object) A method that knows how to "deserialize" the object from whatever form it might have been put into in order to transfer via JSON.
boolean	equals(Object o)
Aggregator	factorize(ColumnSelectorFactory metricFactory)
BufferAggregator	factorizeBuffered(ColumnSelectorFactory metricFactory)
Object	getAggregatorStartValue() Returns the starting value for a corresponding aggregator.
byte[]	getCacheKey()
Comparator<com.yahoo.sketches.theta.Sketch>	getComparator()
String	getFieldName()
int	getMaxIntermediateSize() Returns the maximum size that this aggregator will require in bytes for intermediate storage of results.
String	getName()
int	getSize()
int	hashCode()
List<String>	requiredFields()
String	toString()

Methods inherited from class io.druid.query.aggregation.AggregatorFactory

finalizeComputation, getCombiningFactory, getMergingFactory, getRequiredColumns, getTypeName, mergeAggregators

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

DEFAULT_MAX_SKETCH_SIZE

public static final int DEFAULT_MAX_SKETCH_SIZE

See Also:

Constant Field Values

name

protected final String name

fieldName

protected final String fieldName

size

protected final int size

COMPARATOR

public static final Comparator<com.yahoo.sketches.theta.Sketch> COMPARATOR

Constructor Detail

SketchAggregatorFactory

public SketchAggregatorFactory(String name,
                               String fieldName,
                               Integer size,
                               byte cacheId)

Method Detail

factorize

public Aggregator factorize(ColumnSelectorFactory metricFactory)

Specified by:

factorize in class AggregatorFactory

factorizeBuffered

public BufferAggregator factorizeBuffered(ColumnSelectorFactory metricFactory)

Specified by:

factorizeBuffered in class AggregatorFactory

deserialize

public Object deserialize(Object object)

Description copied from class: AggregatorFactory

A method that knows how to "deserialize" the object from whatever form it might have been put into in order to transfer via JSON.

Specified by:

deserialize in class AggregatorFactory

Parameters:

object - the object to deserialize

Returns:

the deserialized object

getComparator

public Comparator<com.yahoo.sketches.theta.Sketch> getComparator()

Specified by:

getComparator in class AggregatorFactory

combine

public Object combine(Object lhs,
                      Object rhs)

Description copied from class: AggregatorFactory

A method that knows how to combine the outputs of the getIntermediate() method from the Aggregators produced via factorize(). Note, even though this is called combine, this method's contract *does* allow for mutation of the input objects. Thus, any use of lhs or rhs after calling this method is highly discouraged.

Specified by:

combine in class AggregatorFactory

Parameters:

lhs - The left hand side of the combine

rhs - The right hand side of the combine

Returns:

an object representing the combination of lhs and rhs, this can be a new object or a mutation of the inputs

getName

public String getName()

Specified by:

getName in class AggregatorFactory

getFieldName

public String getFieldName()

getSize

public int getSize()

getMaxIntermediateSize

public int getMaxIntermediateSize()

Description copied from class: AggregatorFactory

Returns the maximum size that this aggregator will require in bytes for intermediate storage of results.

Specified by:

getMaxIntermediateSize in class AggregatorFactory

Returns:

the maximum number of bytes that an aggregator of this type will require for intermediate result storage.

getAggregatorStartValue

public Object getAggregatorStartValue()

Description copied from class: AggregatorFactory

Returns the starting value for a corresponding aggregator. For example, 0 for sums, - Infinity for max, an empty mogrifier

Specified by:

getAggregatorStartValue in class AggregatorFactory

Returns:

the starting value for a corresponding aggregator.

requiredFields

public List<String> requiredFields()

Specified by:

requiredFields in class AggregatorFactory

getCacheKey

public byte[] getCacheKey()

Specified by:

getCacheKey in class AggregatorFactory

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object