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

Class BaseObjectBinaryOperator<T>

java.lang.Object

io.deephaven.engine.table.impl.updateby.UpdateByOperator

io.deephaven.engine.table.impl.updateby.internal.BaseObjectUpdateByOperator<T>

io.deephaven.engine.table.impl.updateby.internal.BaseObjectBinaryOperator<T>

Direct Known Subclasses:

ComparableCumMinMaxOperator

public abstract class BaseObjectBinaryOperator<T>
extends BaseObjectUpdateByOperator<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	BaseObjectBinaryOperator.Context

Field Summary

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

colType, maybeInnerSource, outputSource

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

affectingColumns, forwardWindowScaleUnits, inputModifiedColumnSet, isWindowed, outputModifiedColumnSet, pair, reverseWindowScaleUnits, rowRedirection, timestampColumnName

Constructor Summary

Constructors

Constructor	Description
BaseObjectBinaryOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, @NotNull Class<T> type)

Method Summary

Modifier and Type	Method	Description
protected abstract T	doOperation(T bucketCurVal, T chunkCurVal)
UpdateByOperator.Context	makeUpdateContext(int affectedChunkSize, int influencerChunkSize)	Make an UpdateByOperator.Context suitable for use with updates.

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

applyOutputShift, clearOutputRows, getOutputColumns, initializeCumulative, initializeSources, prepareForParallelPopulation, startTrackingPrev

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

copy, createInputModifiedColumnSet, createOutputModifiedColumnSet, extractDownstreamModifiedColumnSet, finishUpdate, getAffectingColumnNames, getFwdWindowUnits, getInputColumnNames, getInputModifiedColumnSet, getOutputColumnNames, getOutputModifiedColumnSet, getPrevWindowUnits, getTimestampColumnName, initializeCumulativeWithKeyValues, initializeRolling, initializeRollingWithKeyValues, requiresRowPositions

Methods inherited from class java.lang.Object

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

Constructor Details

BaseObjectBinaryOperator

public BaseObjectBinaryOperator(@NotNull
 @NotNull MatchPair pair,
 @NotNull
 @NotNull String[] affectingColumns,
 @NotNull
 @NotNull Class<T> type)

Method Details

doOperation

protected abstract T doOperation(T bucketCurVal,
 T chunkCurVal)

makeUpdateContext

@NotNull
public UpdateByOperator.Context makeUpdateContext(int affectedChunkSize,
 int influencerChunkSize)

Description copied from class: UpdateByOperator

Make an UpdateByOperator.Context suitable for use with updates.

Specified by:

makeUpdateContext in class UpdateByOperator

Parameters:

affectedChunkSize - The maximum size of affected chunks that will be provided during the update.

influencerChunkSize - The maximum size of influencer chunks that will be provided during the update.

Returns:

a new context