Package org.apache.druid.query.groupby.epinephelinae

Class GrouperBufferComparatorUtils

java.lang.Object

org.apache.druid.query.groupby.epinephelinae.GrouperBufferComparatorUtils

public class GrouperBufferComparatorUtils
extends Object

Set of utility methods to faciliate implementation of Grouper.KeySerde.bufferComparator() and Grouper.KeySerde.bufferComparatorWithAggregators(AggregatorFactory[], int[])

Constructor Summary

Constructors

Constructor	Description
GrouperBufferComparatorUtils()

Method Summary

Modifier and Type	Method	Description
static Grouper.BufferComparator	bufferComparator(boolean includeTimestamp, boolean sortByDimsFirst, int dimCount, Grouper.BufferComparator[] serdeHelperComparators)
static Grouper.BufferComparator	bufferComparatorWithAggregators(AggregatorFactory[] aggregatorFactories, int[] aggregatorOffsets, DefaultLimitSpec limitSpec, List<DimensionSpec> dimensions, Grouper.BufferComparator[] dimComparators, boolean includeTimestamp, boolean sortByDimsFirst, int keySize)
static Grouper.BufferComparator	makeBufferComparatorForDouble(int keyBufferPosition, boolean pushLimitDown, StringComparator stringComparator)
static Grouper.BufferComparator	makeBufferComparatorForFloat(int keyBufferPosition, boolean pushLimitDown, StringComparator stringComparator)
static Grouper.BufferComparator	makeBufferComparatorForLong(int keyBufferPosition, boolean pushLimitDown, StringComparator stringComparator)
static Grouper.BufferComparator	makeNullHandlingBufferComparatorForNumericData(int keyBufferPosition, Grouper.BufferComparator delegate)

Methods inherited from class java.lang.Object

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

Constructor Details

GrouperBufferComparatorUtils

public GrouperBufferComparatorUtils()

Method Details

bufferComparator

public static Grouper.BufferComparator bufferComparator(boolean includeTimestamp,
 boolean sortByDimsFirst,
 int dimCount,
 Grouper.BufferComparator[] serdeHelperComparators)

bufferComparatorWithAggregators

public static Grouper.BufferComparator bufferComparatorWithAggregators(AggregatorFactory[] aggregatorFactories,
 int[] aggregatorOffsets,
 DefaultLimitSpec limitSpec,
 List<DimensionSpec> dimensions,
 Grouper.BufferComparator[] dimComparators,
 boolean includeTimestamp,
 boolean sortByDimsFirst,
 int keySize)

makeBufferComparatorForLong

public static Grouper.BufferComparator makeBufferComparatorForLong(int keyBufferPosition,
 boolean pushLimitDown,
 @Nullable
 StringComparator stringComparator)

makeBufferComparatorForDouble

public static Grouper.BufferComparator makeBufferComparatorForDouble(int keyBufferPosition,
 boolean pushLimitDown,
 @Nullable
 StringComparator stringComparator)

makeBufferComparatorForFloat

public static Grouper.BufferComparator makeBufferComparatorForFloat(int keyBufferPosition,
 boolean pushLimitDown,
 @Nullable
 StringComparator stringComparator)

makeNullHandlingBufferComparatorForNumericData

public static Grouper.BufferComparator makeNullHandlingBufferComparatorForNumericData(int keyBufferPosition,
 Grouper.BufferComparator delegate)