Package 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 Object implements BeamSqlTableFilter
This default implementation of BeamSqlTableFilter interface. Assumes that predicate push-down is not supported.

  • Constructor Summary

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

  • Method Summary

    Modifier and Type
    Method
    Description
    List<org.apache.beam.vendor.calcite.v1_40_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

  • Constructor Details

    • DefaultTableFilter

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

  • Method Details

    • getNotSupported

      public List<org.apache.beam.vendor.calcite.v1_40_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.