Description
- InMemoryTable should implement a following methods:
public PCollection<Row> buildIOReader( PBegin begin, BeamSqlTableFilter filters, List<String> fieldNames); public BeamSqlTableFilter constructFilter(List<RexNode> filter);
- Update a push-down rule to support predicate/filter push-down.
- Create a class
class TestTableFilter implements BeamSqlTableFilter