public class DoubleSumAggregatorFactory extends AggregatorFactory
| Constructor and Description |
|---|
DoubleSumAggregatorFactory(String name,
String fieldName) |
DoubleSumAggregatorFactory(String name,
String fieldName,
String expression) |
| 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 |
finalizeComputation(Object object)
"Finalizes" the computation of an object.
|
byte[] |
getCacheKey()
Get a byte array used as a cache key.
|
AggregatorFactory |
getCombiningFactory()
Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory.
|
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() |
List<AggregatorFactory> |
getRequiredColumns()
Gets a list of all columns that this AggregatorFactory will scan
|
String |
getTypeName() |
int |
hashCode() |
List<String> |
requiredFields() |
String |
toString() |
mergeAggregatorspublic DoubleSumAggregatorFactory(String name, String fieldName, String expression)
public Aggregator factorize(ColumnSelectorFactory metricFactory)
factorize in class AggregatorFactorypublic BufferAggregator factorizeBuffered(ColumnSelectorFactory metricFactory)
factorizeBuffered in class AggregatorFactorypublic Comparator getComparator()
getComparator in class AggregatorFactorypublic Object combine(Object lhs, Object rhs)
AggregatorFactorycombine in class AggregatorFactorylhs - The left hand side of the combinerhs - The right hand side of the combinepublic AggregatorFactory getCombiningFactory()
AggregatorFactorygetCombiningFactory in class AggregatorFactorypublic AggregatorFactory getMergingFactory(AggregatorFactory other) throws AggregatorFactoryNotMergeableException
AggregatorFactorygetMergingFactory in class AggregatorFactoryAggregatorFactoryNotMergeableExceptionpublic List<AggregatorFactory> getRequiredColumns()
AggregatorFactorygetRequiredColumns in class AggregatorFactorypublic Object deserialize(Object object)
AggregatorFactorydeserialize in class AggregatorFactoryobject - the object to deserializepublic Object finalizeComputation(Object object)
AggregatorFactoryfinalizeComputation in class AggregatorFactoryobject - the object to be finalizedpublic String getFieldName()
public String getExpression()
public String getName()
getName in class AggregatorFactorypublic List<String> requiredFields()
requiredFields in class AggregatorFactorypublic byte[] getCacheKey()
Cacheablepublic String getTypeName()
getTypeName in class AggregatorFactorypublic int getMaxIntermediateSize()
AggregatorFactorygetMaxIntermediateSize in class AggregatorFactoryCopyright © 2011–2017. All rights reserved.