Package org.apache.druid.query.rowsandcols.semantic

Class DefaultFramedOnHeapAggregatable

java.lang.Object

org.apache.druid.query.rowsandcols.semantic.DefaultFramedOnHeapAggregatable

All Implemented Interfaces:

FramedOnHeapAggregatable

public class DefaultFramedOnHeapAggregatable
extends Object
implements FramedOnHeapAggregatable

Constructor Summary

Constructors

Constructor	Description
DefaultFramedOnHeapAggregatable(AppendableRowsAndColumns rac)

Method Summary

Modifier and Type	Method	Description
RowsAndColumns	aggregateAll(WindowFrame frame, AggregatorFactory[] aggFactories)	Aggregates the data according to the WindowFrame using the AggregatorFactory objects provided.
static Iterable<org.apache.druid.query.rowsandcols.semantic.DefaultFramedOnHeapAggregatable.AggInterval>	buildIteratorFor(AppendableRowsAndColumns rac, WindowFrame frame)
static Object	cloneAggValue(AggregatorFactory aggFactory, Object value)
static int	invertedOrderForLastK(int x, int n, int k)	Inverts order for the last K elements.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultFramedOnHeapAggregatable

public DefaultFramedOnHeapAggregatable(AppendableRowsAndColumns rac)

Method Details

aggregateAll

@Nonnull
public RowsAndColumns aggregateAll(WindowFrame frame,
 AggregatorFactory[] aggFactories)

Description copied from interface: FramedOnHeapAggregatable

Aggregates the data according to the WindowFrame using the AggregatorFactory objects provided.

Specified by:

aggregateAll in interface FramedOnHeapAggregatable

Parameters:

frame - window frame definition

aggFactories - definition of aggregations to be done

Returns:

a RowsAndColumns that contains columns representing the results of the aggregation from the AggregatorFactories

buildIteratorFor

public static Iterable<org.apache.druid.query.rowsandcols.semantic.DefaultFramedOnHeapAggregatable.AggInterval> buildIteratorFor(AppendableRowsAndColumns rac,
 WindowFrame frame)

invertedOrderForLastK

public static int invertedOrderForLastK(int x,
 int n,
 int k)

Inverts order for the last K elements. For n=3, k=2 - it changes the iteration to 0,2,1

cloneAggValue

public static Object cloneAggValue(AggregatorFactory aggFactory,
 Object value)