public class BigQueryFilter extends java.lang.Object implements BeamSqlTableFilter
Constructor and Description |
---|
BigQueryFilter(java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> predicateCNF) |
Modifier and Type | Method and Description |
---|---|
java.util.List<org.apache.beam.vendor.calcite.v1_20_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_20_0.org.apache.calcite.rex.RexNode> |
getSupported() |
java.lang.String |
toString() |
public BigQueryFilter(java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> predicateCNF)
public java.util.List<org.apache.beam.vendor.calcite.v1_20_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 java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> getSupported()
public java.lang.String toString()
toString
in class java.lang.Object