Package io.deephaven.engine.table.impl.updateby.emstd

Class BasePrimitiveEmStdOperator.Context

java.lang.Object
io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context
io.deephaven.engine.table.impl.updateby.internal.BaseDoubleUpdateByOperator.Context
io.deephaven.engine.table.impl.updateby.emstd.BasePrimitiveEmStdOperator.Context
All Implemented Interfaces:
SafeCloseable, AutoCloseable
Direct Known Subclasses:
ByteEmStdOperator.Context, CharEmStdOperator.Context, DoubleEmStdOperator.Context, FloatEmStdOperator.Context, IntEmStdOperator.Context, LongEmStdOperator.Context, ShortEmStdOperator.Context
Enclosing class:
BasePrimitiveEmStdOperator
public abstract class BasePrimitiveEmStdOperator.Context extends BaseDoubleUpdateByOperator.Context

  • Field Details

    • emaFillContext

      protected final ChunkSink.FillFromContext emaFillContext

    • emaValues

      protected final WritableDoubleChunk<Values> emaValues

    • alpha

      protected double alpha

    • oneMinusAlpha

      protected double oneMinusAlpha

    • lastDt

      protected long lastDt

    • lastStamp

      protected long lastStamp

    • curEma

      protected double curEma

    • curVariance

      protected double curVariance

  • Method Details

    • 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

    • reset

      public void reset()
      Description copied from class: UpdateByOperator.Context
      Reset the operator data values to a known state. This may occur during initialization or when a windowed operator has an empty window
      Overrides:
      reset in class BaseDoubleUpdateByOperator.Context

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface SafeCloseable
      Overrides:
      close in class BaseDoubleUpdateByOperator.Context