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

Class BigQueryFilter

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BigQueryFilter

All Implemented Interfaces:

BeamSqlTableFilter

public class BigQueryFilter
extends java.lang.Object
implements BeamSqlTableFilter

Constructor Summary

Constructors

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

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() Identify parts of a predicate that are not supported by the IO push-down capabilities to be preserved in a Calc following BeamIOSourceRel.
java.util.List<org.apache.beam.vendor.calcite.v1_26_0.org.apache.calcite.rex.RexNode>	getSupported()
int	numSupported() This is primarily used by the cost based optimization to determine the benefit of performing predicate push-down for an IOSourceRel.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

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

expressionsInFilter

Constructor Detail

BigQueryFilter

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

Method Detail

getNotSupported

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

Description copied from interface: BeamSqlTableFilter

Identify parts of a predicate that are not supported by the IO push-down capabilities to be preserved in a Calc following BeamIOSourceRel.

Specified by:

getNotSupported in interface BeamSqlTableFilter

Returns:

List<RexNode> unsupported by the IO API. Should be empty when an entire condition is supported, or an unchanged List<RexNode> when predicate push-down is not supported at all.

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.

getSupported

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object