public class ApproximateHistogramAggregatorFactory extends Object implements AggregatorFactory
| Modifier and Type | Field and Description |
|---|---|
protected String |
fieldName |
protected float |
lowerLimit |
protected String |
name |
protected int |
numBuckets |
protected int |
resolution |
protected float |
upperLimit |
| Constructor and Description |
|---|
ApproximateHistogramAggregatorFactory(String name,
String fieldName,
Integer resolution,
Integer numBuckets,
Float lowerLimit,
Float upperLimit) |
| 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.
|
Object |
getAggregatorStartValue()
Returns the starting value for a corresponding aggregator.
|
byte[] |
getCacheKey() |
AggregatorFactory |
getCombiningFactory()
Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory.
|
Comparator |
getComparator() |
String |
getFieldName() |
float |
getLowerLimit() |
int |
getMaxIntermediateSize()
Returns the maximum size that this aggregator will require in bytes for intermediate storage of results.
|
String |
getName() |
int |
getNumBuckets() |
List<AggregatorFactory> |
getRequiredColumns()
Gets a list of all columns that this AggregatorFactory will scan
|
int |
getResolution() |
String |
getTypeName() |
float |
getUpperLimit() |
int |
hashCode() |
List<String> |
requiredFields() |
String |
toString() |
protected final String name
protected final String fieldName
protected final int resolution
protected final int numBuckets
protected final float lowerLimit
protected final float upperLimit
public Aggregator factorize(ColumnSelectorFactory metricFactory)
factorize in interface AggregatorFactorypublic BufferAggregator factorizeBuffered(ColumnSelectorFactory metricFactory)
factorizeBuffered in interface AggregatorFactorypublic Comparator getComparator()
getComparator in interface AggregatorFactorypublic Object combine(Object lhs, Object rhs)
AggregatorFactorycombine in interface AggregatorFactorylhs - The left hand side of the combinerhs - The right hand side of the combinepublic AggregatorFactory getCombiningFactory()
AggregatorFactorygetCombiningFactory in interface AggregatorFactorypublic List<AggregatorFactory> getRequiredColumns()
AggregatorFactorygetRequiredColumns in interface AggregatorFactorypublic Object deserialize(Object object)
AggregatorFactorydeserialize in interface AggregatorFactoryobject - the object to deserializepublic Object finalizeComputation(Object object)
AggregatorFactoryfinalizeComputation in interface AggregatorFactoryobject - the object to be finalizedpublic String getName()
getName in interface AggregatorFactorypublic String getFieldName()
public int getResolution()
public float getLowerLimit()
public float getUpperLimit()
public int getNumBuckets()
public List<String> requiredFields()
requiredFields in interface AggregatorFactorypublic byte[] getCacheKey()
getCacheKey in interface AggregatorFactorypublic String getTypeName()
getTypeName in interface AggregatorFactorypublic int getMaxIntermediateSize()
AggregatorFactorygetMaxIntermediateSize in interface AggregatorFactorypublic Object getAggregatorStartValue()
AggregatorFactorygetAggregatorStartValue in interface AggregatorFactoryCopyright © 2011–2015. All rights reserved.