io.druid.query.aggregation

Class SimpleDoubleAggregatorFactory

java.lang.Object

io.druid.query.aggregation.AggregatorFactory

io.druid.query.aggregation.SimpleDoubleAggregatorFactory

All Implemented Interfaces:

Cacheable

Direct Known Subclasses:

DoubleMaxAggregatorFactory, DoubleMinAggregatorFactory, DoubleSumAggregatorFactory

public abstract class SimpleDoubleAggregatorFactory
extends AggregatorFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected String	expression
protected String	fieldName
protected ExprMacroTable	macroTable
protected String	name
protected boolean	storeDoubleAsFloat

Constructor Summary

Constructors

Constructor and Description
SimpleDoubleAggregatorFactory(ExprMacroTable macroTable, String fieldName, String name, String expression)

Method Summary

Modifier and Type	Method and Description
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)
Object	finalizeComputation(Object object) "Finalizes" the computation of an object.
Comparator	getComparator()
protected BaseDoubleColumnValueSelector	getDoubleColumnSelector(ColumnSelectorFactory metricFactory, double nullValue)
String	getExpression()
String	getFieldName()
int	getMaxIntermediateSize() Returns the maximum size that this aggregator will require in bytes for intermediate storage of results.
AggregatorFactory	getMergingFactory(AggregatorFactory other) Returns an AggregatorFactory that can be used to merge the output of aggregators from this factory and other factory.
String	getName()
String	getTypeName()
int	hashCode()
List<String>	requiredFields()

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

combine, factorize, factorizeBuffered, getCombiningFactory, getRequiredColumns, makeAggregateCombiner, mergeAggregators

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.java.util.common.Cacheable

getCacheKey

Field Detail

name

protected final String name

fieldName

protected final String fieldName

expression

protected final String expression

macroTable

protected final ExprMacroTable macroTable

storeDoubleAsFloat

protected final boolean storeDoubleAsFloat

Constructor Detail

SimpleDoubleAggregatorFactory

public SimpleDoubleAggregatorFactory(ExprMacroTable macroTable,
                                     String fieldName,
                                     String name,
                                     String expression)

Method Detail

getDoubleColumnSelector

protected BaseDoubleColumnValueSelector getDoubleColumnSelector(ColumnSelectorFactory metricFactory,
                                                                double nullValue)

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

getTypeName

public String getTypeName()

Specified by:

getTypeName in class AggregatorFactory

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.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

getComparator

public Comparator getComparator()

Specified by:

getComparator in class AggregatorFactory

getMergingFactory

public AggregatorFactory getMergingFactory(AggregatorFactory other)
                                    throws AggregatorFactoryNotMergeableException

Description copied from class: AggregatorFactory

Returns an AggregatorFactory that can be used to merge the output of aggregators from this factory and other factory. This method is relevant only for AggregatorFactory which can be used at ingestion time.

Overrides:

getMergingFactory in class AggregatorFactory

Returns:

a new Factory that can be used for merging the output of aggregators from this factory and other.

Throws:

AggregatorFactoryNotMergeableException

requiredFields

public List<String> requiredFields()

Specified by:

requiredFields in class AggregatorFactory

finalizeComputation

public Object finalizeComputation(Object object)

Description copied from class: AggregatorFactory

"Finalizes" the computation of an object. Primarily useful for complex types that have a different mergeable intermediate format than their final resultant output.

Specified by:

finalizeComputation in class AggregatorFactory

Parameters:

object - the object to be finalized

Returns:

the finalized value that should be returned for the initial query

getName

public String getName()

Specified by:

getName in class AggregatorFactory

getFieldName

public String getFieldName()

getExpression

public String getExpression()