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 2017/01/24 03:23:24 UTC
[12/12] beam git commit: This closes #1661: Implement
GearpumpPipelineResult
This closes #1661: Implement GearpumpPipelineResult
note thread is interrupted on InterruptedException
Remove cache for Gearpump on travis
reduce timeout to wait for result
fix ParDo.BoundMulti translation
return encoded key for GroupByKey translation
support OutputTimeFn
update to latest gearpump dsl function interface
fix group by window
activate ROS on Gearpump by default
update ROS configurations
[BEAM-1180] Implement GearpumpPipelineResult
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1ed16f11
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1ed16f11
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1ed16f11
Branch: refs/heads/gearpump-runner
Commit: 1ed16f11a3fb24c3cc6773235651c4a9255d6fbc
Parents: 4c445dd d814857
Author: Kenneth Knowles <kl...@google.com>
Authored: Mon Jan 23 19:22:31 2017 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Jan 23 19:22:31 2017 -0800
----------------------------------------------------------------------
.travis.yml | 1 +
runners/gearpump/pom.xml | 9 +-
.../gearpump/GearpumpPipelineResult.java | 65 ++++++++++++-
.../beam/runners/gearpump/GearpumpRunner.java | 7 +-
.../runners/gearpump/TestGearpumpRunner.java | 4 +
.../translators/GroupByKeyTranslator.java | 96 ++++++++++++++++----
.../translators/ParDoBoundMultiTranslator.java | 35 +++++--
.../translators/TranslationContext.java | 1 -
.../translators/WindowBoundTranslator.java | 49 ++++++++--
.../translators/functions/DoFnFunction.java | 21 ++++-
.../gearpump/translators/io/GearpumpSource.java | 4 +-
11 files changed, 238 insertions(+), 54 deletions(-)
----------------------------------------------------------------------