io.druid.query.aggregation.datasketches.theta

Class SketchMergeAggregatorFactory

java.lang.Object

io.druid.query.aggregation.datasketches.theta.SketchAggregatorFactory

io.druid.query.aggregation.datasketches.theta.SketchMergeAggregatorFactory

All Implemented Interfaces:

AggregatorFactory

Direct Known Subclasses:

OldSketchBuildAggregatorFactory, OldSketchMergeAggregatorFactory

public class SketchMergeAggregatorFactory
extends SketchAggregatorFactory

Field Summary

Fields inherited from class io.druid.query.aggregation.datasketches.theta.SketchAggregatorFactory

COMPARATOR, DEFAULT_MAX_SKETCH_SIZE, fieldName, name, size

Constructor Summary

Constructors

Constructor and Description
SketchMergeAggregatorFactory(String name, String fieldName, Integer size, Boolean shouldFinalize, Boolean isInputThetaSketch)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Object	finalizeComputation(Object object) Finalize the computation on sketch object and returns estimate from underlying sketch.
AggregatorFactory	getCombiningFactory() Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory.
boolean	getIsInputThetaSketch()
List<AggregatorFactory>	getRequiredColumns() Gets a list of all columns that this AggregatorFactory will scan
boolean	getShouldFinalize()
String	getTypeName()
int	hashCode()
String	toString()

Methods inherited from class io.druid.query.aggregation.datasketches.theta.SketchAggregatorFactory

combine, deserialize, factorize, factorizeBuffered, getAggregatorStartValue, getCacheKey, getComparator, getFieldName, getMaxIntermediateSize, getName, getSize, requiredFields

Methods inherited from class java.lang.Object

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

Constructor Detail

SketchMergeAggregatorFactory

public SketchMergeAggregatorFactory(String name,
                                    String fieldName,
                                    Integer size,
                                    Boolean shouldFinalize,
                                    Boolean isInputThetaSketch)

Method Detail

getRequiredColumns

public List<AggregatorFactory> getRequiredColumns()

Description copied from interface: AggregatorFactory

Gets a list of all columns that this AggregatorFactory will scan

Returns:

AggregatorFactories for the columns to scan of the parent AggregatorFactory

getCombiningFactory

public AggregatorFactory getCombiningFactory()

Description copied from interface: AggregatorFactory

Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory. This generally amounts to simply creating a new factory that is the same as the current except with its input column renamed to the same as the output column.

Returns:

a new Factory that can be used for operations on top of data output from the current factory.

getShouldFinalize

public boolean getShouldFinalize()

getIsInputThetaSketch

public boolean getIsInputThetaSketch()

finalizeComputation

public Object finalizeComputation(Object object)

Finalize the computation on sketch object and returns estimate from underlying sketch.

Parameters:

object - the sketch object

Returns:

sketch object

getTypeName

public String getTypeName()

equals

public boolean equals(Object o)

Overrides:

equals in class SketchAggregatorFactory

hashCode

public int hashCode()

Overrides:

hashCode in class SketchAggregatorFactory

toString

public String toString()

Overrides:

toString in class SketchAggregatorFactory