org.apache.druid.query.aggregation

Class SimpleLongAggregatorFactory

java.lang.Object

org.apache.druid.query.aggregation.AggregatorFactory

org.apache.druid.query.aggregation.NullableAggregatorFactory<BaseLongColumnValueSelector>

org.apache.druid.query.aggregation.SimpleLongAggregatorFactory

All Implemented Interfaces:

Cacheable

Direct Known Subclasses:

LongMaxAggregatorFactory, LongMinAggregatorFactory, LongSumAggregatorFactory

public abstract class SimpleLongAggregatorFactory
extends NullableAggregatorFactory<BaseLongColumnValueSelector>

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
SimpleLongAggregatorFactory(ExprMacroTable macroTable, String name, String fieldName, 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()
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 org.apache.druid.query.aggregation.NullableAggregatorFactory

factorize, factorize, factorizeBuffered, factorizeBuffered, getMaxIntermediateSizeWithNulls, makeNullableAggregateCombiner, selector

Methods inherited from class org.apache.druid.query.aggregation.AggregatorFactory

combine, getCombiningFactory, getRequiredColumns, makeAggregateCombiner, mergeAggregators, optimizeForSegment

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.java.util.common.Cacheable

getCacheKey

Field Detail

name

protected final String name

fieldName

@Nullable
protected final String fieldName

expression

@Nullable
protected final String expression

macroTable

protected final ExprMacroTable macroTable

Constructor Detail

SimpleLongAggregatorFactory

public SimpleLongAggregatorFactory(ExprMacroTable macroTable,
                                   String name,
                                   @Nullable
                                   String fieldName,
                                   @Nullable
                                   String expression)

Method Detail

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.

getComparator

public Comparator getComparator()

Specified by:

getComparator in class AggregatorFactory

finalizeComputation

@Nullable
public Object finalizeComputation(@Nullable
                                            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

requiredFields

public List<String> requiredFields()

Specified by:

requiredFields 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

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

getName

public String getName()

Specified by:

getName in class AggregatorFactory

getFieldName

@Nullable
public String getFieldName()

getExpression

@Nullable
public String getExpression()