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/17 16:55:32 UTC

[beam] branch master updated (432e17f -> f1aee7c)

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 432e17f  Merge pull request #9803: [BEAM-8372] Follow-up to Flink UberJar submission.
     add e06cece  Updated price model and added a rule to perform project push-down for TestTableProvider
     add f1aee7c  Merge pull request #9764: [BEAM-8365] Project push-down for TestTableProvider

No new revisions were added by this update.

Summary of changes:
 .../sdk/extensions/sql/impl/BeamCalciteTable.java  |  10 +-
 .../extensions/sql/impl/planner/BeamRuleSets.java  |   2 +
 .../extensions/sql/impl/rel/BeamIOSourceRel.java   |  41 +++-
 .../sql/impl/rule/BeamIOPushDownRule.java          | 248 +++++++++++++++++++++
 .../sql/meta/provider/test/TestTableProvider.java  |  40 +++-
 .../sql/impl/rule/IOPushDownRuleTest.java          | 177 +++++++++++++++
 .../meta/provider/test/TestTableProviderTest.java  |   7 +
 .../test/TestTableProviderWithProjectPushDown.java | 206 +++++++++++++++++
 8 files changed, 722 insertions(+), 9 deletions(-)
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOPushDownRule.java
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/rule/IOPushDownRuleTest.java
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/test/TestTableProviderWithProjectPushDown.java