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 <k...@google.com> Authored: Fri Dec 16 13:17:55 2016 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------