public class BigQueryFilter extends java.lang.Object implements BeamSqlTableFilter
Constructor and Description |
---|
BigQueryFilter(java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> predicateCNF) |
Modifier and Type | Method and Description |
---|---|
java.util.List<org.apache.beam.vendor.calcite.v1_28_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_28_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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
expressionsInFilter
public BigQueryFilter(java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> predicateCNF)
public java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> getNotSupported()
BeamSqlTableFilter
Calc
following BeamIOSourceRel
.getNotSupported
in interface BeamSqlTableFilter
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.public int numSupported()
BeamSqlTableFilter
numSupported
in interface BeamSqlTableFilter
public java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> getSupported()
public java.lang.String toString()
toString
in class java.lang.Object