Repository: beam Updated Branches: refs/heads/master f5efca029 -> 754d5d833
This closes #2855 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/754d5d83 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/754d5d83 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/754d5d83 Branch: refs/heads/master Commit: 754d5d833f15d3095257cc129a061e1ea3267502 Parents: 69522fe f5efca0 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Mon May 15 17:36:16 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Mon May 15 17:36:16 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/apex/ApexRunner.java | 34 +++++ .../translation/ApexPipelineTranslator.java | 23 ++++ .../apex/translation/ParDoTranslator.java | 68 +++++++++- .../operators/ApexGroupByKeyOperator.java | 4 +- .../operators/ApexParDoOperator.java | 124 ++++++++++++++++++- .../operators/ApexProcessFnOperator.java | 8 +- .../operators/ApexTimerInternals.java | 21 +++- .../translation/utils/ApexStateInternals.java | 4 + .../translation/utils/StateInternalsProxy.java | 7 +- .../operators/ApexTimerInternalsTest.java | 8 +- 10 files changed, 286 insertions(+), 15 deletions(-) ----------------------------------------------------------------------
