You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/04/08 01:26:32 UTC
[2/2] beam git commit: This closes #2450
This closes #2450
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7f55746c
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7f55746c
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7f55746c
Branch: refs/heads/master
Commit: 7f55746ce3eb2a0b6ee2f6372d6f7127835cbb34
Parents: 1594849 8484ef9
Author: Eugene Kirpichov <ki...@google.com>
Authored: Fri Apr 7 18:26:15 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Fri Apr 7 18:26:15 2017 -0700
----------------------------------------------------------------------
.../apache/beam/runners/apex/ApexRunner.java | 2 -
.../apex/translation/GroupByKeyTranslator.java | 4 +-
.../apex/translation/ParDoTranslator.java | 15 +-
.../apex/translation/TranslationContext.java | 16 +-
.../translation/WindowAssignTranslator.java | 58 ++----
.../operators/ApexGroupByKeyOperator.java | 21 +--
.../operators/ApexParDoOperator.java | 187 +++++++++++++++----
.../operators/ApexProcessFnOperator.java | 184 ++++++++++++++++++
.../translation/utils/ApexStateInternals.java | 73 ++++++--
.../translation/utils/StateInternalsProxy.java | 67 +++++++
.../translation/ApexGroupByKeyOperatorTest.java | 2 +-
.../apex/translation/ParDoTranslatorTest.java | 2 +-
.../utils/ApexStateInternalsTest.java | 25 ++-
.../streaming/SingletonKeyedWorkItemCoder.java | 2 +-
14 files changed, 512 insertions(+), 146 deletions(-)
----------------------------------------------------------------------