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

Class ByteEMOperator.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.em.BasePrimitiveEMOperator.Context

io.deephaven.engine.table.impl.updateby.em.ByteEMOperator.Context

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Enclosing class:

ByteEMOperator

protected class ByteEMOperator.Context
extends BasePrimitiveEMOperator.Context

Field Summary

Fields

Modifier and Type	Field	Description
ByteChunk<? extends Values>	byteValueChunk

Fields inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseDoubleUpdateByOperator.Context

curVal, outputFillContext, outputValues

Fields inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context

affectedPosChunk, influencerPosChunk, nullCount

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Context(int affectedChunkSize, int influencerChunkSize)

Method Summary

Modifier and Type	Method	Description
void	accumulateCumulative(@NotNull RowSequence inputKeys, Chunk<? extends Values>[] valueChunkArr, LongChunk<? extends Values> tsChunk, int len)
boolean	isValueValid(long atKey)
void	push(int pos, int count)	Add values to the operators current data set
void	setValueChunks(@NotNull Chunk<? extends Values>[] valueChunks)

Methods inherited from class io.deephaven.engine.table.impl.updateby.em.BasePrimitiveEMOperator.Context

reset

Methods inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseDoubleUpdateByOperator.Context

accumulateRolling, close, writeToOutputChunk, writeToOutputColumn

Methods inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context

pop, setPosChunks

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

byteValueChunk

public ByteChunk<? extends Values> byteValueChunk

Constructor Details

Context

protected Context(int affectedChunkSize,
 int influencerChunkSize)

Method Details

setValueChunks

public void setValueChunks(@NotNull
 @NotNull Chunk<? extends Values>[] valueChunks)

Overrides:

setValueChunks in class BaseDoubleUpdateByOperator.Context

accumulateCumulative

public void accumulateCumulative(@NotNull
 @NotNull RowSequence inputKeys,
 Chunk<? extends Values>[] valueChunkArr,
 LongChunk<? extends Values> tsChunk,
 int len)

Overrides:

accumulateCumulative in class BaseDoubleUpdateByOperator.Context

isValueValid

public boolean isValueValid(long atKey)

Overrides:

isValueValid in class UpdateByOperator.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