public class FilteredAggregatorFactory extends AggregatorFactory
Constructor and Description |
---|
FilteredAggregatorFactory(AggregatorFactory delegate,
DimFilter filter) |
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 columnSelectorFactory) |
BufferAggregator |
factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) |
Object |
finalizeComputation(Object object)
"Finalizes" the computation of an object.
|
AggregatorFactory |
getAggregator() |
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() |
DimFilter |
getFilter() |
int |
getMaxIntermediateSize()
Returns the maximum size that this aggregator will require in bytes for intermediate storage of results.
|
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() |
getMergingFactory, mergeAggregators
public FilteredAggregatorFactory(AggregatorFactory delegate, DimFilter filter)
public Aggregator factorize(ColumnSelectorFactory columnSelectorFactory)
factorize
in class AggregatorFactory
public BufferAggregator factorizeBuffered(ColumnSelectorFactory columnSelectorFactory)
factorizeBuffered
in class AggregatorFactory
public Comparator getComparator()
getComparator
in class AggregatorFactory
public Object combine(Object lhs, Object rhs)
AggregatorFactory
combine
in class AggregatorFactory
lhs
- The left hand side of the combinerhs
- The right hand side of the combinepublic AggregatorFactory getCombiningFactory()
AggregatorFactory
getCombiningFactory
in class AggregatorFactory
public Object deserialize(Object object)
AggregatorFactory
deserialize
in class AggregatorFactory
object
- the object to deserializepublic Object finalizeComputation(Object object)
AggregatorFactory
finalizeComputation
in class AggregatorFactory
object
- the object to be finalizedpublic String getName()
getName
in class AggregatorFactory
public List<String> requiredFields()
requiredFields
in class AggregatorFactory
public byte[] getCacheKey()
getCacheKey
in class AggregatorFactory
public String getTypeName()
getTypeName
in class AggregatorFactory
public int getMaxIntermediateSize()
AggregatorFactory
getMaxIntermediateSize
in class AggregatorFactory
public Object getAggregatorStartValue()
AggregatorFactory
getAggregatorStartValue
in class AggregatorFactory
public AggregatorFactory getAggregator()
public DimFilter getFilter()
public List<AggregatorFactory> getRequiredColumns()
AggregatorFactory
getRequiredColumns
in class AggregatorFactory
Copyright © 2011–2016. All rights reserved.