You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ap...@apache.org on 2019/10/10 15:28:47 UTC

[beam] branch master updated (6b1fc06 -> 0cb56a2)

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%)