Package org.apache.druid.query.aggregation

Class ObjectColumnDoubleAggregatorWrapper

java.lang.Object

org.apache.druid.query.aggregation.DelegatingAggregator

org.apache.druid.query.aggregation.ObjectColumnDoubleAggregatorWrapper

All Implemented Interfaces:

Closeable, AutoCloseable, Aggregator

public class ObjectColumnDoubleAggregatorWrapper
extends DelegatingAggregator

This class can be used to wrap Double Aggregator that consume double type columns to handle Object type.

Field Summary

Fields inherited from class org.apache.druid.query.aggregation.DelegatingAggregator

delegate

Constructor Summary

Constructors

Constructor	Description
ObjectColumnDoubleAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseDoubleColumnValueSelector,Aggregator> delegateBuilder, double nullValue)

Method Summary

Modifier and Type	Method	Description
void	aggregate()	Performs aggregation.

Methods inherited from class org.apache.druid.query.aggregation.DelegatingAggregator

close, get, getDouble, getFloat, getLong, isNull

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.druid.query.aggregation.Aggregator

aggregateWithSize

Constructor Details

ObjectColumnDoubleAggregatorWrapper

public ObjectColumnDoubleAggregatorWrapper(BaseObjectColumnValueSelector selector,
 Function<BaseDoubleColumnValueSelector,Aggregator> delegateBuilder,
 double nullValue)

Method Details

aggregate

public void aggregate()

Description copied from interface: Aggregator

Performs aggregation.

Specified by:

aggregate in interface Aggregator

Overrides:

aggregate in class DelegatingAggregator