public interface BeamSqlTableFilter
Modifier and Type | Method and Description |
---|---|
static int |
expressionsInFilter(java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> filterNodes)
Count a number of
RexNode s involved in all supported filters. |
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 . |
int |
numSupported()
This is primarily used by the cost based optimization to determine the benefit of performing
predicate push-down for an IOSourceRel.
|
java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> getNotSupported()
Calc
following BeamIOSourceRel
.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.int numSupported()
static int expressionsInFilter(java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> filterNodes)
RexNode
s involved in all supported filters.filterNodes
- List<RexNode>
supported filters.