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

Class ConditionFilter

java.lang.Object

io.deephaven.engine.table.impl.select.WhereFilterImpl

io.deephaven.engine.table.impl.select.AbstractConditionFilter

io.deephaven.engine.table.impl.select.ConditionFilter

All Implemented Interfaces:

ConcurrencyControl<Filter>, Expression, Filter, WhereFilter, Serializable

public class ConditionFilter
extends AbstractConditionFilter

A condition filter evaluates a formula against a table.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConditionFilter.ChunkFilter
static interface	ConditionFilter.ChunkGetter
static final class	ConditionFilter.ColumnICount
static final class	ConditionFilter.ColumnIICount
static final class	ConditionFilter.ColumnILookup
static interface	ConditionFilter.ContextGetter
static interface	ConditionFilter.FilterKernel<CONTEXT extends ConditionFilter.FilterKernel.Context>
static class	ConditionFilter.IndexCount
static class	ConditionFilter.IndexLookup

Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.select.AbstractConditionFilter

AbstractConditionFilter.Filter

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

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

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CHUNK_SIZE
protected static final String	CLASS_NAME

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

formula, initialized, params

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

ZERO_LENGTH_WHERE_FILTER_ARRAY

Method Summary

Modifier and Type	Method	Description
ConditionFilter	copy()	Create a copy of this WhereFilter.
static WhereFilter	createConditionFilter(@NotNull String formula)
static WhereFilter	createConditionFilter(@NotNull String formula, FormulaParserConfiguration parser)
static WhereFilter	createStateless(@NotNull String formula)
protected void	generateFilterCode(@NotNull TableDefinition tableDefinition, @NotNull TimeLiteralReplacedExpression timeConversionResult, QueryLanguageParser.Result result, @NotNull QueryCompilerRequestProcessor compilationProcessor)
@NotNull AbstractConditionFilter.Filter	getFilter(Table table, RowSet fullSet)	Retrieve the current filter for this condition filter or create a new one initialized to the provided table and row set.
int	getNumInputsUsed()	Get the number of inputs (columns and special variables) used by this filter.
boolean	permitParallelization()
ConditionFilter	renameFilter(Map<String,String> renames)
protected void	setPythonFilter(AbstractConditionFilter.Filter filter)	When numba vectorized functions are used to evaluate query filters, we need to create a special ChunkFilter that can handle packing and unpacking arrays required/returned by the vectorized function, essentially bypassing the regular code generation process which isn't able to support such use cases without needing some major rework.

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

filter, getColumnArrays, getColumns, getFormulaShiftedColumnDefinitions, hasConstantArrayAccess, hasVirtualRowVariables, init, init, isSimpleFilter, onCopy, setRecomputeListener, toString, validateSafeForRefresh

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

isAutomatedFilter, setAutomatedFilter

Methods inherited from class java.lang.Object

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

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

beginOperation, canMemoize, filter, filterInverse, invert, isRefreshing, walk, walk, walk, withDeclaredBarriers, withRespectedBarriers, withSerial

Field Details

CHUNK_SIZE

public static final int CHUNK_SIZE

See Also:

• Constant Field Values

CLASS_NAME

protected static final String CLASS_NAME

See Also:

• Constant Field Values

Method Details

createConditionFilter

public static WhereFilter createConditionFilter(@NotNull
 @NotNull String formula,
 FormulaParserConfiguration parser)

createConditionFilter

public static WhereFilter createConditionFilter(@NotNull
 @NotNull String formula)

createStateless

public static WhereFilter createStateless(@NotNull
 @NotNull String formula)

getNumInputsUsed

public int getNumInputsUsed()

Get the number of inputs (columns and special variables) used by this filter.

generateFilterCode

protected void generateFilterCode(@NotNull
 @NotNull TableDefinition tableDefinition,
 @NotNull
 @NotNull TimeLiteralReplacedExpression timeConversionResult,
 @NotNull
 QueryLanguageParser.Result result,
 @NotNull
 @NotNull QueryCompilerRequestProcessor compilationProcessor)

Specified by:

generateFilterCode in class AbstractConditionFilter

getFilter

@NotNull
public @NotNull AbstractConditionFilter.Filter getFilter(Table table,
 RowSet fullSet)
                                                  throws InstantiationException,
IllegalAccessException,
NoSuchMethodException,
InvocationTargetException

Description copied from class: AbstractConditionFilter

Retrieve the current filter for this condition filter or create a new one initialized to the provided table and row set. With a context from AbstractConditionFilter.Filter.getContext(int), this filter can be used for directly filtering chunked data.

Specified by:

getFilter in class AbstractConditionFilter

Parameters:

table - the table to filter, or a table with a compatible schema

fullSet - the full set of rows currently in the table, used to populate the virtual row variables such as i, ii, and k

Returns:

the initialized filter

Throws:

InstantiationException

IllegalAccessException

NoSuchMethodException

InvocationTargetException

setPythonFilter

protected void setPythonFilter(AbstractConditionFilter.Filter filter)

Description copied from class: AbstractConditionFilter

When numba vectorized functions are used to evaluate query filters, we need to create a special ChunkFilter that can handle packing and unpacking arrays required/returned by the vectorized function, essentially bypassing the regular code generation process which isn't able to support such use cases without needing some major rework.

Specified by:

setPythonFilter in class AbstractConditionFilter

Parameters:

filter - the filter to set

copy

public ConditionFilter copy()

Description copied from interface: WhereFilter

Create a copy of this WhereFilter.

Specified by:

copy in interface WhereFilter

Specified by:

copy in class AbstractConditionFilter

Returns:

an independent copy of this WhereFilter.

renameFilter

public ConditionFilter renameFilter(Map<String,String> renames)

Specified by:

renameFilter in class AbstractConditionFilter

permitParallelization

public boolean permitParallelization()

Returns:

if this filter can be applied in parallel