Class BigDecimalEmStdOperator.Context

All Implemented Interfaces:
SafeCloseable, AutoCloseable
Enclosing class:
BigDecimalEmStdOperator

public class BigDecimalEmStdOperator.Context extends BaseBigNumberEmStdOperator<BigDecimal>.Context
  • Constructor Details

    • Context

      protected Context(int affectedChunkSize, int influencerChunkSize)
  • Method Details

    • accumulateCumulative

      public void accumulateCumulative(@NotNull @NotNull RowSequence inputKeys, @NotNull @NotNull Chunk<? extends Values>[] valueChunkArr, @Nullable @Nullable LongChunk<? extends Values> tsChunk, int len)
      Description copied from class: UpdateByOperator.Context
      For cumulative operators only, this method will be called to pass the input chunk data to the operator and produce the output data values.
      Overrides:
      accumulateCumulative in class BaseObjectUpdateByOperator<BigDecimal>.Context
      Parameters:
      inputKeys - the keys for the input data rows (also matches the output keys)
      valueChunkArr - the input data chunks needed by the operator for internal calculations
      tsChunk - the timestamp chunk for the input data (if applicable)
      len - the number of items in the input data chunks