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

Class ComparableCumMinMaxOperator<T extends Comparable<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>

io.deephaven.engine.table.impl.updateby.minmax.ComparableCumMinMaxOperator<T>

public final class ComparableCumMinMaxOperator<T extends Comparable<T>>
extends BaseObjectBinaryOperator<T>

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseObjectBinaryOperator

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
ComparableCumMinMaxOperator(@NotNull MatchPair inputPair, boolean isMax, Class<T> colType)

Method Summary

Modifier and Type	Method	Description
UpdateByOperator	copy()	Create an uninitialized copy of this operator.
protected T	doOperation(T bucketCurVal, T chunkCurVal)

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

makeUpdateContext

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

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

ComparableCumMinMaxOperator

public ComparableCumMinMaxOperator(@NotNull
 @NotNull MatchPair inputPair,
 boolean isMax,
 Class<T> colType)

Method Details

copy

public UpdateByOperator copy()

Description copied from class: UpdateByOperator

Create an uninitialized copy of this operator. UpdateByOperator.initializeSources(Table, RowRedirection) must be called before this operator can be used.

Specified by:

copy in class UpdateByOperator

Returns:

a copy of this operator

doOperation

protected T doOperation(T bucketCurVal,
 T chunkCurVal)

Specified by:

doOperation in class BaseObjectBinaryOperator<T extends Comparable<T>>