This is an automated email from the ASF dual-hosted git repository.
apilloud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 6b1fc06 Merge pull request #9751: [BEAM-8370] update outdated Flink
gradle command
add ea0977d [BEAM-8343] Added nessesary methods to BeamSqlTable to enable
support for predicate/project push-down
add 0cb56a2 Merge pull request #9731: [BEAM-8343] Added nessesary methods
to BeamSqlTable to enable support for predicate/project push-down
No new revisions were added by this update.
Summary of changes:
.../sdk/extensions/sql/meta/BaseBeamTable.java | 32 ++++++++++++++++++-
.../beam/sdk/extensions/sql/meta/BeamSqlTable.java | 11 +++++++
.../extensions/sql/meta/BeamSqlTableFilter.java} | 22 ++++++-------
.../extensions/sql/meta/DefaultTableFilter.java} | 30 ++++++++++++------
.../sql/meta/CustomTableResolverTest.java | 36 ++++++++++++++++++++++
5 files changed, 108 insertions(+), 23 deletions(-)
copy
sdks/java/extensions/sql/{zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TableResolver.java
=>
src/main/java/org/apache/beam/sdk/extensions/sql/meta/BeamSqlTableFilter.java}
(61%)
copy
sdks/java/extensions/sql/{zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlOperatorRewriter.java
=>
src/main/java/org/apache/beam/sdk/extensions/sql/meta/DefaultTableFilter.java}
(55%)
