io.druid.query.aggregation.datasketches.theta

Class SketchMergeAggregatorFactory

java.lang.Object

io.druid.query.aggregation.AggregatorFactory

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

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

All Implemented Interfaces:

Cacheable

Direct Known Subclasses:

OldSketchBuildAggregatorFactory, OldSketchMergeAggregatorFactory

public class SketchMergeAggregatorFactory
extends SketchAggregatorFactory

Field Summary

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

DEFAULT_MAX_SKETCH_SIZE, fieldName, name, size

Constructor Summary

Constructors

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

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.
Integer	getErrorBoundsStdDev()
boolean	getIsInputThetaSketch()
AggregatorFactory	getMergingFactory(AggregatorFactory other) Returns an AggregatorFactory that can be used to merge the output of aggregators from this factory and other factory.
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, getCacheKey, getComparator, getFieldName, getMaxIntermediateSize, getName, getSize, makeAggregateCombiner, requiredFields

Methods inherited from class io.druid.query.aggregation.AggregatorFactory

mergeAggregators

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,
                                    Integer errorBoundsStdDev)

Method Detail

getRequiredColumns

public List<AggregatorFactory> getRequiredColumns()

Description copied from class: AggregatorFactory

Gets a list of all columns that this AggregatorFactory will scan

Specified by:

getRequiredColumns in class AggregatorFactory

Returns:

AggregatorFactories for the columns to scan of the parent AggregatorFactory

getCombiningFactory

public AggregatorFactory getCombiningFactory()

Description copied from class: 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.

Specified by:

getCombiningFactory in class AggregatorFactory

Returns:

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

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

getShouldFinalize

public boolean getShouldFinalize()

getIsInputThetaSketch

public boolean getIsInputThetaSketch()

getErrorBoundsStdDev

public Integer getErrorBoundsStdDev()

finalizeComputation

public Object finalizeComputation(Object object)

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

Specified by:

finalizeComputation in class AggregatorFactory

Parameters:

object - the sketch object

Returns:

sketch object

getTypeName

public String getTypeName()

Specified by:

getTypeName in class AggregatorFactory

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