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

Class StaticSymbolTableChunkedOperatorAggregationStateManager

java.lang.Object

io.deephaven.engine.table.impl.by.StaticSymbolTableChunkedOperatorAggregationStateManager

public class StaticSymbolTableChunkedOperatorAggregationStateManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int	UNKNOWN_ROW

Method Summary

Modifier and Type	Method	Description
void	add(SafeCloseable bc, RowSequence rowSequence, ColumnSource<?>[] sources, org.apache.commons.lang3.mutable.MutableInt nextOutputPosition, WritableIntChunk<RowKeys> outputPositions)
int	findPositionForKey(Object key)
ColumnSource<?>[]	getKeyHashTableSources()
SafeCloseable	makeAggregationStateBuildContext(ColumnSource<?>[] buildSources, long maxSize)
int	maxTableSize()

Methods inherited from class java.lang.Object

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

Field Details

UNKNOWN_ROW

static final int UNKNOWN_ROW

See Also:

• Constant Field Values

Method Details

maxTableSize

public int maxTableSize()

makeAggregationStateBuildContext

public SafeCloseable makeAggregationStateBuildContext(ColumnSource<?>[] buildSources,
 long maxSize)

add

public void add(SafeCloseable bc,
 RowSequence rowSequence,
 ColumnSource<?>[] sources,
 org.apache.commons.lang3.mutable.MutableInt nextOutputPosition,
 WritableIntChunk<RowKeys> outputPositions)

getKeyHashTableSources

public ColumnSource<?>[] getKeyHashTableSources()

findPositionForKey

public int findPositionForKey(Object key)