io.druid.query.aggregation

Class AggregatorUtil

java.lang.Object

io.druid.query.aggregation.AggregatorUtil

public class AggregatorUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static byte	STRING_SEPARATOR

Constructor Summary

Constructors

Constructor and Description
AggregatorUtil()

Method Summary

Modifier and Type	Method and Description
static Pair<List<AggregatorFactory>,List<PostAggregator>>	condensedAggregators(List<AggregatorFactory> aggList, List<PostAggregator> postAggList, String metric)
static FloatColumnSelector	getFloatColumnSelector(ColumnSelectorFactory metricFactory, String fieldName, String fieldExpression, float nullValue)
static LongColumnSelector	getLongColumnSelector(ColumnSelectorFactory metricFactory, String fieldName, String fieldExpression, long nullValue)
static List<PostAggregator>	pruneDependentPostAgg(List<PostAggregator> postAggregatorList, String postAggName) returns the list of dependent postAggregators that should be calculated in order to calculate given postAgg

Methods inherited from class java.lang.Object

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

Field Detail

STRING_SEPARATOR

public static final byte STRING_SEPARATOR

See Also:

Constant Field Values

Constructor Detail

AggregatorUtil

public AggregatorUtil()

Method Detail

pruneDependentPostAgg

public static List<PostAggregator> pruneDependentPostAgg(List<PostAggregator> postAggregatorList,
                                                         String postAggName)

returns the list of dependent postAggregators that should be calculated in order to calculate given postAgg

Parameters:

postAggregatorList - List of postAggregator, there is a restriction that the list should be in an order such that all the dependencies of any given aggregator should occur before that aggregator. See AggregatorUtilTest.testOutOfOrderPruneDependentPostAgg for example.

postAggName - name of the postAgg on which dependency is to be calculated

Returns:

the list of dependent postAggregators

condensedAggregators

public static Pair<List<AggregatorFactory>,List<PostAggregator>> condensedAggregators(List<AggregatorFactory> aggList,
                                                                                      List<PostAggregator> postAggList,
                                                                                      String metric)

getFloatColumnSelector

public static FloatColumnSelector getFloatColumnSelector(ColumnSelectorFactory metricFactory,
                                                         String fieldName,
                                                         String fieldExpression,
                                                         float nullValue)

getLongColumnSelector

public static LongColumnSelector getLongColumnSelector(ColumnSelectorFactory metricFactory,
                                                       String fieldName,
                                                       String fieldExpression,
                                                       long nullValue)