Class TestTableFilter

    • 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 a Calc following BeamIOSourceRel.
      java.util.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.
      java.lang.String toString()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • TestTableFilter

        public TestTableFilter​(java.util.List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> predicateCNF)
    • 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: 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_40_0.org.apache.calcite.rex.RexNode> getSupported()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object