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

Class WhereFilterSerialImpl

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.WhereFilterDelegatingBase

io.deephaven.engine.table.impl.select.WhereFilterSerialImpl

All Implemented Interfaces:

ConcurrencyControl<Filter>, Expression, Filter, LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, DependencyStreamProvider, WhereFilter, WhereFilterDelegating, Serializable

public class WhereFilterSerialImpl
extends WhereFilterDelegatingBase

A serial wrapper for a WhereFilter that enforces serial (non-parallel) execution.

See Also:

• Serialized Form

Nested Class Summary

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

WhereFilter.PreviousFilteringNotSupported, WhereFilter.RecomputeListener, WhereFilter.Visitor<T>

Field Summary

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

filter

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

Method Summary

Modifier and Type	Method	Description
WhereFilter	copy()	Create a copy of this WhereFilter.
boolean	isSerial()	Return true if this filter is a serial filter.
WhereFilter	maybeUnwrapFilter()	Returns the wrapped filter if and only if the wrapped filter accepts the same rows as this filter.
static WhereFilter	of(WhereFilter filter)	Wraps the provided WhereFilter with serial behavior.
boolean	permitParallelization()	Always returns false to indicate that parallelization is not permitted.
String	toString()
final <T> T	walk(WhereFilter.Visitor<T> visitor)	This method calls the appropriate visitor method based on the type of this WhereFilter.

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

beginOperation, canMemoize, equals, filter, filterInverse, getColumnArrays, getColumns, getDependencyStream, getWrappedFilter, hashCode, init, init, isAutomatedFilter, isRefreshing, isSimpleFilter, setAutomatedFilter, setRecomputeListener, validateSafeForRefresh

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

manageWithCurrentScope

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

ensureCleanupOnGC, findAnyManagedReferent, forEachManagedReference, getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage

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

destroy, dropReference, tryRetainReference

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

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

manage, unmanage, unmanage

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

dropReference, getReferentDescription, retainReference, tryRetainReference

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

filter, hasVirtualRowVariables, invert, walk, walk, withDeclaredBarriers, withRespectedBarriers, withSerial

Method Details

of

public static WhereFilter of(WhereFilter filter)

Wraps the provided WhereFilter with serial behavior.

Parameters:

filter - the filter to wrap

Returns:

a new WhereFilterSerialImpl instance that enforces serial execution

maybeUnwrapFilter

public WhereFilter maybeUnwrapFilter()

Description copied from interface: WhereFilterDelegating

Returns the wrapped filter if and only if the wrapped filter accepts the same rows as this filter. For example, serial and barrier wrappers do not change functionality and will return the wrapped filter. Filters such as WhereFilterInvertedImpl that perform a transformation should return themselves.

permitParallelization

public boolean permitParallelization()

Always returns false to indicate that parallelization is not permitted.

Specified by:

permitParallelization in interface WhereFilter

Overrides:

permitParallelization in class WhereFilterDelegatingBase

Returns:

false

isSerial

public boolean isSerial()

Description copied from interface: WhereFilter

Return true if this filter is a serial filter.

A filter only returns true if the user explicitly marked the filter (or a filter that it wraps) as serial. A serial filter must not permit parallelism (as being executed in parallel would violate the contract of a serial filter).

Specified by:

isSerial in interface WhereFilter

Overrides:

isSerial in class WhereFilterDelegatingBase

Returns:

true if this filter is a serial filter.

copy

public WhereFilter copy()

Description copied from interface: WhereFilter

Create a copy of this WhereFilter.

Returns:

an independent copy of this WhereFilter.

toString

public String toString()

Overrides:

toString in class ReferenceCounted

walk

public final <T> T walk(WhereFilter.Visitor<T> visitor)

Description copied from interface: WhereFilter

This method calls the appropriate visitor method based on the type of this WhereFilter. This will invoke the most specific WhereFilter.Visitor method available.

Type Parameters:

T - the return value type

Parameters:

visitor - the visitor

Returns:

the value