Class TestTableFilter
- java.lang.Object
-
- org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableFilter
-
- All Implemented Interfaces:
BeamSqlTableFilter
public class TestTableFilter extends java.lang.Object implements BeamSqlTableFilter
-
-
Constructor Summary
Constructors Constructor Description TestTableFilter(java.util.List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> predicateCNF)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<org.apache.beam.vendor.calcite.v1_40_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 aCalcfollowingBeamIOSourceRel.java.util.List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode>getSupported()intnumSupported()This is primarily used by the cost based optimization to determine the benefit of performing predicate push-down for an IOSourceRel.java.lang.StringtoString()
-
-
-
Method Detail
-
getNotSupported
public java.util.List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> getNotSupported()
Description copied from interface:BeamSqlTableFilterIdentify parts of a predicate that are not supported by the IO push-down capabilities to be preserved in aCalcfollowingBeamIOSourceRel.- Specified by:
getNotSupportedin interfaceBeamSqlTableFilter- Returns:
List<RexNode>unsupported by the IO API. Should be empty when an entire condition is supported, or an unchangedList<RexNode>when predicate push-down is not supported at all.
-
numSupported
public int numSupported()
Description copied from interface:BeamSqlTableFilterThis is primarily used by the cost based optimization to determine the benefit of performing predicate push-down for an IOSourceRel.- Specified by:
numSupportedin interfaceBeamSqlTableFilter- Returns:
- number of supported filters.
-
getSupported
public java.util.List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> getSupported()
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-