Class ShortCumProdOperator.Context

All Implemented Interfaces:
SafeCloseable, AutoCloseable
Enclosing class:
ShortCumProdOperator

protected class ShortCumProdOperator.Context extends BaseLongUpdateByOperator.Context
  • Field Details

  • Constructor Details

    • Context

      protected Context(int chunkSize)
  • Method Details

    • setValueChunks

      public void setValueChunks(@NotNull @NotNull Chunk<? extends Values>[] valueChunks)
      Overrides:
      setValueChunks in class BaseLongUpdateByOperator.Context
    • push

      public void push(int pos, int count)
      Description copied from class: UpdateByOperator.Context
      Add values to the operators current data set
      Specified by:
      push in class UpdateByOperator.Context
      Parameters:
      pos - the index in the associated chunk where this value can be found. Depending on the usage, might be a values chunk (for cumulative operators) or an influencer values chunk (for windowed). It is the task of the operator to pull the data from the chunk and use it properly
      count - the number of items to push from the chunk