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 2016/12/16 21:18:48 UTC
[6/6] incubator-beam git commit: This closes #1623: [BEAM-1086]
Upgrade to latest Gearpump snapshot
This closes #1623: [BEAM-1086] Upgrade to latest Gearpump snapshot
Fix NoOpAggregatorFactory
Remove print to stdout
Skip window assignment when windows don't change
Add Window.Bound translator
Upgrade Gearpump version
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b6e7bb65
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b6e7bb65
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b6e7bb65
Branch: refs/heads/gearpump-runner
Commit: b6e7bb659f33e346c00e66ca96e3c54dd7ef07da
Parents: 88de0cb 8e0e819
Author: Kenneth Knowles <kl...@google.com>
Authored: Fri Dec 16 13:17:55 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Fri Dec 16 13:17:55 2016 -0800
----------------------------------------------------------------------
runners/gearpump/pom.xml | 39 +------
.../gearpump/GearpumpPipelineTranslator.java | 3 +
.../beam/runners/gearpump/GearpumpRunner.java | 60 ++--------
.../FlattenPCollectionTranslator.java | 1 -
.../translators/GroupByKeyTranslator.java | 109 ++++++++++++++-----
.../translators/WindowBoundTranslator.java | 97 +++++++++++++++++
.../gearpump/translators/io/GearpumpSource.java | 28 +++--
.../gearpump/translators/io/ValuesSource.java | 21 ++--
.../utils/NoOpAggregatorFactory.java | 24 +++-
.../translators/utils/TranslatorUtils.java | 35 ++++++
10 files changed, 282 insertions(+), 135 deletions(-)
----------------------------------------------------------------------