Package com.illumon.iris.db.v2.by

Class ChunkedOperatorAggregationHelper

java.lang.Object

com.illumon.iris.db.v2.by.ChunkedOperatorAggregationHelper

public class ChunkedOperatorAggregationHelper
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	KEY_ONLY_SUBSTITUTION_ENABLED

Constructor Summary

Constructors

Constructor	Description
ChunkedOperatorAggregationHelper()

Method Summary

Modifier and Type	Method	Description
static QueryTable	aggregation(AggregationContextFactory aggregationContextFactory, QueryTable queryTable, SelectColumn[] groupByColumns)
static QueryTable	aggregation(AggregationControl control, AggregationContextFactory aggregationContextFactory, QueryTable queryTable, SelectColumn[] groupByColumns)
static int	chunkSize(long size)	Return the minimum of our chunk size and the size of an input.

Methods inherited from class java.lang.Object

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

Field Details

KEY_ONLY_SUBSTITUTION_ENABLED

@VisibleForTesting public static boolean KEY_ONLY_SUBSTITUTION_ENABLED

Constructor Details

ChunkedOperatorAggregationHelper

public ChunkedOperatorAggregationHelper()

Method Details

aggregation

public static QueryTable aggregation(AggregationContextFactory aggregationContextFactory, QueryTable queryTable, SelectColumn[] groupByColumns)

aggregation

@VisibleForTesting public static QueryTable aggregation(AggregationControl control, AggregationContextFactory aggregationContextFactory, QueryTable queryTable, SelectColumn[] groupByColumns)

chunkSize

public static int chunkSize(long size)

Return the minimum of our chunk size and the size of an input.

Parameters:

size - the input size

Returns:

an appropriate chunk size to use