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/05 18:26:14 UTC
[beam] 01/01: Merge pull request #6933: [BEAM-5961] Nexmark
rollforward new query with test of Nexmark main
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 560a5799fbebb37f66dbd73346a6d54924ae3558
Merge: 87cd769 7fe59e4
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Mon Nov 5 10:26:07 2018 -0800
Merge pull request #6933: [BEAM-5961] Nexmark rollforward new query with test of Nexmark main
.../java/org/apache/beam/sdk/nexmark/Main.java | 11 +-
.../beam/sdk/nexmark/NexmarkConfiguration.java | 15 ++
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 8 +
.../apache/beam/sdk/nexmark/NexmarkQueryName.java | 5 +-
.../org/apache/beam/sdk/nexmark/NexmarkUtils.java | 121 ++++++++++++
.../sdk/nexmark/queries/BoundedSideInputJoin.java | 88 +++++++++
.../nexmark/queries/BoundedSideInputJoinModel.java | 81 ++++++++
.../beam/sdk/nexmark/queries/NexmarkQuery.java | 22 +++
.../java/org/apache/beam/sdk/nexmark/MainTest.java | 37 ++++
.../apache/beam/sdk/nexmark/NexmarkUtilsTest.java | 67 +++++++
.../nexmark/queries/BoundedSideInputJoinTest.java | 207 +++++++++++++++++++++
11 files changed, 657 insertions(+), 5 deletions(-)