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 <k...@google.com> Authored: Mon Jan 23 19:22:31 2017 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------
