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

Posted to commits@beam.apache.org by ke...@apache.org on 2018/11/24 03:44:12 UTC

[beam] branch master updated (894f728 -> e3c79e2)

This is an automated email from the ASF dual-hosted git repository.

kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 894f728  Merge pull request #7123: [BEAM-6115] SyntheticSource bundle size parameter sometimes should be casted to int
     add 6e617d6  Fix name of BoundedSideInputJoin transform
     add c9510e5  [BEAM-6109] Verify SQL join triggering only once CoGBK join is selected
     add d023aa0  Ignore unobservable timestamps in BoundedSideInputJoinModel verification
     add 49a3695  [BEAM-5817] Add Nexmark SqlBoundedSideInputJoin
     add e3c79e2  Merge pull request #7114: [BEAM-5817] Add Nexmark SqlBoundedSideInputJoin

No new revisions were added by this update.

Summary of changes:
 .../sdk/extensions/sql/impl/rel/BeamJoinRel.java   |   6 +-
 .../sdk/nexmark/queries/BoundedSideInputJoin.java  |   2 +-
 .../nexmark/queries/BoundedSideInputJoinModel.java |   2 +-
 .../queries/sql/SqlBoundedSideInputJoin.java       | 100 +++++++++++++++++++++
 .../SqlBoundedSideInputJoinTest.java}              |  30 ++++---
 5 files changed, 122 insertions(+), 18 deletions(-)
 create mode 100644 sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlBoundedSideInputJoin.java
 copy sdks/java/testing/nexmark/src/test/java/org/apache/beam/sdk/nexmark/queries/{BoundedSideInputJoinTest.java => sql/SqlBoundedSideInputJoinTest.java} (88%)