Package io.deephaven.engine.table.impl.select

Class IncrementalReleaseFilter

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

io.deephaven.engine.liveness.ReferenceCountedLivenessNode

io.deephaven.engine.liveness.LivenessArtifact

io.deephaven.engine.table.impl.select.WhereFilterLivenessArtifactImpl

io.deephaven.engine.table.impl.select.BaseIncrementalReleaseFilter

io.deephaven.engine.table.impl.select.IncrementalReleaseFilter

All Implemented Interfaces:

Expression, Filter, LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, WhereFilter, NotificationQueue.Dependency, Serializable, Runnable

public class IncrementalReleaseFilter
extends BaseIncrementalReleaseFilter

This will filter a table starting off with the first N rows, and then adding new rows to the table on each run.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.api.filter.Filter

Filter.Visitor<T>

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.select.WhereFilter

WhereFilter.PreviousFilteringNotSupported, WhereFilter.RecomputeListener

Field Summary

Fields inherited from class io.deephaven.engine.table.impl.select.WhereFilterLivenessArtifactImpl

updateGraph

Fields inherited from interface io.deephaven.engine.table.impl.select.WhereFilter

ZERO_LENGTH_WHERE_FILTER_ARRAY

Constructor Summary

Constructors

Constructor	Description
IncrementalReleaseFilter(long initialSize, long sizeIncrement)	Create an incremental release filter with an initial size that will release sizeIncrement rows each cycle.

Method Summary

Methods inherited from class io.deephaven.engine.table.impl.select.BaseIncrementalReleaseFilter

copy, destroy, durationNanos, filter, getColumnArrays, getColumns, getExpectedSize, getInitialSize, getUpdateGraph, init, isRefreshing, isSimpleFilter, permitParallelization, run, satisfied, setRecomputeListener, start, waitForCompletion, waitForCompletion

Methods inherited from class io.deephaven.engine.table.impl.select.WhereFilterLivenessArtifactImpl

isAutomatedFilter, setAutomatedFilter

Methods inherited from class io.deephaven.engine.liveness.LivenessArtifact

manageWithCurrentScope

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode

getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

dropReference, tryRetainReference

Methods inherited from class io.deephaven.util.referencecounting.ReferenceCounted

append, decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, toString, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.liveness.LivenessManager

manage

Methods inherited from interface io.deephaven.engine.liveness.LivenessNode

unmanage, unmanage

Methods inherited from interface io.deephaven.engine.liveness.LivenessReferent

dropReference, getReferentDescription, retainReference, tryRetainReference

Methods inherited from interface io.deephaven.base.log.LogOutputAppendable

append

Methods inherited from interface io.deephaven.engine.updategraph.NotificationQueue.Dependency

getUpdateGraph

Methods inherited from interface io.deephaven.engine.table.impl.select.WhereFilter

beginOperation, canMemoize, filter, filterInverse, init, invert, validateSafeForRefresh, walk, walk

Constructor Details

IncrementalReleaseFilter

public IncrementalReleaseFilter(long initialSize,
 long sizeIncrement)

Create an incremental release filter with an initial size that will release sizeIncrement rows each cycle.

Parameters:

initialSize - how many rows should be in the table initially

sizeIncrement - how many rows to release at the beginning of each UGP cycle.