org.apache.beam.sdk.extensions.sql.meta

Class DefaultTableFilter

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.DefaultTableFilter

All Implemented Interfaces:

BeamSqlTableFilter

public final class DefaultTableFilter
extends java.lang.Object
implements BeamSqlTableFilter

This default implementation of BeamSqlTableFilter interface. Assumes that predicate push-down is not supported.

Constructor Summary

Constructors

Constructor and Description
DefaultTableFilter(java.util.List<org.apache.beam.vendor.calcite.v1_26_0.org.apache.calcite.rex.RexNode> filters)

Method Summary

Modifier and Type	Method and Description
java.util.List<org.apache.beam.vendor.calcite.v1_26_0.org.apache.calcite.rex.RexNode>	getNotSupported() Since predicate push-down is assumed not to be supported by default - return an unchanged list of filters to be preserved.
int	numSupported() This is primarily used by the cost based optimization to determine the benefit of performing predicate push-down for an IOSourceRel.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.BeamSqlTableFilter

expressionsInFilter

Constructor Detail

DefaultTableFilter

public DefaultTableFilter(java.util.List<org.apache.beam.vendor.calcite.v1_26_0.org.apache.calcite.rex.RexNode> filters)

Method Detail

getNotSupported

public java.util.List<org.apache.beam.vendor.calcite.v1_26_0.org.apache.calcite.rex.RexNode> getNotSupported()

Since predicate push-down is assumed not to be supported by default - return an unchanged list of filters to be preserved.

Specified by:

getNotSupported in interface BeamSqlTableFilter

Returns:

Predicate List<RexNode> which are not supported. To make a single RexNode expression all of the nodes must be joined by a logical AND.

numSupported

public int numSupported()

Description copied from interface: BeamSqlTableFilter

This is primarily used by the cost based optimization to determine the benefit of performing predicate push-down for an IOSourceRel.

Specified by:

numSupported in interface BeamSqlTableFilter

Returns:

number of supported filters.