beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [02/50] [abbrv] beam git commit: This closes #1935: Support merging windows in GearpumpRunner
Date Mon, 07 Aug 2017 23:53:27 GMT
This closes #1935: Support merging windows in GearpumpRunner


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2d0aed92
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2d0aed92
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2d0aed92

Branch: refs/heads/master
Commit: 2d0aed9221b4e763917b136ce2ecc60d08621a07
Parents: 4001aeb 7af6472
Author: Kenneth Knowles <klk@google.com>
Authored: Wed Feb 15 13:17:30 2017 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Wed Feb 15 13:17:30 2017 -0800

----------------------------------------------------------------------
 runners/gearpump/pom.xml                        |   5 -
 .../gearpump/GearpumpPipelineResult.java        |   8 +-
 .../beam/runners/gearpump/GearpumpRunner.java   |  24 +---
 .../translators/GroupByKeyTranslator.java       | 133 +++++++++++--------
 .../translators/WindowBoundTranslator.java      |  53 +-------
 .../gearpump/translators/io/GearpumpSource.java |   6 +-
 .../translators/utils/DoFnRunnerFactory.java    |   1 +
 .../translators/utils/TranslatorUtils.java      |  20 +++
 .../translators/utils/TranslatorUtilsTest.java  |  75 +++++++++++
 9 files changed, 186 insertions(+), 139 deletions(-)
----------------------------------------------------------------------



Mime
View raw message