Package org.apache.beam.sdk.extensions.sql.meta.provider.test

Class TestTableFilter

java.lang.Object
org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableFilter
All Implemented Interfaces:
BeamSqlTableFilter
public class TestTableFilter extends Object implements BeamSqlTableFilter

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestTableFilter(List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> predicateCNF)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    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 a Calc following BeamIOSourceRel.
    List<org.apache.beam.vendor.calcite.v1_40_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.
    String
    toString()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • TestTableFilter

      public TestTableFilter(List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> predicateCNF)

  • Method Details

    • getNotSupported

      public List<org.apache.beam.vendor.calcite.v1_40_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 List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> getSupported()

    • toString

      public String toString()
      Overrides:
      toString in class Object