beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [6/6] incubator-beam git commit: This closes #1623: [BEAM-1086] Upgrade to latest Gearpump snapshot
Date Fri, 16 Dec 2016 21:18:48 GMT
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 <klk@google.com>
Authored: Fri Dec 16 13:17:55 2016 -0800
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message