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

Class OperatorAggregationStateManagerOpenAddressedBase

java.lang.Object
io.deephaven.engine.table.impl.by.OperatorAggregationStateManagerOpenAddressedBase
Direct Known Subclasses:
StaticChunkedOperatorAggregationStateManagerOpenAddressedBase
public abstract class OperatorAggregationStateManagerOpenAddressedBase extends Object

  • Field Details

    • CHUNK_SIZE

      public static final int CHUNK_SIZE

    • tableSize

      protected int tableSize

    • numEntries

      protected long numEntries

    • mainKeySources

      protected final ColumnSource[] mainKeySources

    • UNKNOWN_ROW

      static final int UNKNOWN_ROW
      See Also:

  • Constructor Details

    • OperatorAggregationStateManagerOpenAddressedBase

      protected OperatorAggregationStateManagerOpenAddressedBase(ColumnSource<?>[] tableKeySources, int tableSize, double maximumLoadFactor)

  • Method Details

    • maxTableSize

      public final int maxTableSize()

    • build

      protected abstract void build(RowSequence rowSequence, Chunk<Values>[] sourceKeyChunks)

    • onNextChunk

      protected abstract void onNextChunk(int nextChunkSize)

    • buildTable

      protected void buildTable(TypedHasherUtil.BuildOrProbeContext.BuildContext bc, RowSequence buildRows, ColumnSource<?>[] buildSources)

    • doRehash

      public void doRehash(int nextChunkSize)

    • rehashInternalFull

      protected abstract void rehashInternalFull(int oldSize)

    • rehashRequired

      public boolean rehashRequired(int nextChunkSize)

    • hashToTableLocation

      protected int hashToTableLocation(int hash)

    • findPositionForKey

      public abstract int findPositionForKey(Object key)

    • makeAggregationStateBuildContext

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

    • add

      void add(SafeCloseable bc, RowSequence rowSequence, ColumnSource<?>[] sources, MutableInt nextOutputPosition, WritableIntChunk<RowKeys> outputPositions)

    • getKeyHashTableSources

      ColumnSource[] getKeyHashTableSources()