Class BigDecimalEMOperator.Context

All Implemented Interfaces:
SafeCloseable, AutoCloseable
Enclosing class:
BigDecimalEMOperator

public class BigDecimalEMOperator.Context extends BaseBigNumberEMOperator<BigDecimal>.Context
  • Constructor Details

    • Context

      protected Context(int chunkSize)
  • Method Details

    • accumulateCumulative

      public void accumulateCumulative(@NotNull @NotNull RowSequence inputKeys, @NotNull @NotNull Chunk<? extends Values>[] valueChunkArr, LongChunk<? extends Values> tsChunk, int len)
      Overrides:
      accumulateCumulative in class BaseObjectUpdateByOperator<BigDecimal>.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