Package io.deephaven.engine.table.impl.by

Class ChunkedOperatorAggregationHelper

java.lang.Object

io.deephaven.engine.table.impl.by.ChunkedOperatorAggregationHelper

public class ChunkedOperatorAggregationHelper
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	SKIP_RUN_FIND

Constructor Summary

Constructors

Constructor	Description
ChunkedOperatorAggregationHelper()

Method Summary

Modifier and Type	Method	Description
static QueryTable	aggregation(@NotNull AggregationContextFactory aggregationContextFactory, @NotNull QueryTable input, boolean preserveEmpty, @Nullable Table initialKeys, @NotNull Collection<? extends ColumnName> groupByColumns)
static QueryTable	aggregation(@NotNull AggregationControl control, @NotNull AggregationContextFactory aggregationContextFactory, @NotNull QueryTable input, boolean preserveEmpty, @Nullable Table initialKeys, @NotNull Collection<? extends ColumnName> 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

SKIP_RUN_FIND

public static final boolean SKIP_RUN_FIND

Constructor Details

ChunkedOperatorAggregationHelper

public ChunkedOperatorAggregationHelper()

Method Details

aggregation

public static QueryTable aggregation(@NotNull
 @NotNull AggregationContextFactory aggregationContextFactory,
 @NotNull
 @NotNull QueryTable input,
 boolean preserveEmpty,
 @Nullable
 @Nullable Table initialKeys,
 @NotNull
 @NotNull Collection<? extends ColumnName> groupByColumns)

aggregation

@VisibleForTesting
public static QueryTable aggregation(@NotNull
 @NotNull AggregationControl control,
 @NotNull
 @NotNull AggregationContextFactory aggregationContextFactory,
 @NotNull
 @NotNull QueryTable input,
 boolean preserveEmpty,
 @Nullable
 @Nullable Table initialKeys,
 @NotNull
 @NotNull Collection<? extends ColumnName> 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