Class ShortCumSumOperator

java.lang.Object
io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
io.deephaven.engine.table.impl.updateby.sum.ShortCumSumOperator
All Implemented Interfaces:
UpdateByOperator

public class ShortCumSumOperator
extends BaseLongUpdateByOperator
  • Constructor Details

    • ShortCumSumOperator

      public ShortCumSumOperator​(@NotNull MatchPair pair, @Nullable RowRedirection rowRedirection)
  • Method Details

    • addChunk

      public void addChunk​(@NotNull UpdateByOperator.UpdateContext context, @NotNull Chunk<Values> values, @NotNull LongChunk<? extends RowKeys> keyChunk, @NotNull IntChunk<RowKeys> bucketPositions, @NotNull IntChunk<ChunkPositions> startPositions, @NotNull IntChunk<ChunkLengths> runLengths)
      Description copied from interface: UpdateByOperator
      Add a chunk of bucketed items to the operation.
      Parameters:
      context - the context object
      values - the value chunk
      keyChunk - a chunk of keys for the rows being added
      bucketPositions - a chunk of hash bucket positions for each key
      startPositions - the start position of a run within the chunk
      runLengths - the runLengths of each run of bucket values
    • doAddChunk

      protected void doAddChunk​(@NotNull BaseLongUpdateByOperator.Context ctx, @NotNull RowSequence inputKeys, @NotNull Chunk<Values> workingChunk, long groupPosition)
      Description copied from class: BaseLongUpdateByOperator
      Add a chunk of values to the operator.
      Specified by:
      doAddChunk in class BaseLongUpdateByOperator
      Parameters:
      ctx - the context object
      inputKeys - the input keys for the chunk
      workingChunk - the chunk of values
      groupPosition - the bucket position that the values belong to.