This closes #1353
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4852d2eb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4852d2eb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4852d2eb Branch: refs/heads/gearpump-runner Commit: 4852d2ebf503a5207db612cb6429728d0f3cb7e1 Parents: 212fec4 c0623c1 Author: Kenneth Knowles <k...@google.com> Authored: Thu Nov 17 22:31:07 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Nov 17 22:31:07 2016 -0800 ---------------------------------------------------------------------- .../operators/ApexGroupByKeyOperator.java | 26 +- .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 3 +- .../GroupAlsoByWindowsViaOutputBufferDoFn.java | 5 +- .../beam/runners/core/OutputWindowedValue.java | 45 +++ .../runners/core/ReduceFnContextFactory.java | 83 ++++- .../beam/runners/core/ReduceFnRunner.java | 40 +-- .../beam/runners/core/SimpleDoFnRunner.java | 42 ++- .../beam/runners/core/SimpleOldDoFnRunner.java | 21 +- .../core/WindowingInternalsAdapters.java | 76 +++++ .../beam/runners/core/ReduceFnTester.java | 81 ++--- .../GroupAlsoByWindowEvaluatorFactory.java | 88 ++--- .../functions/FlinkDoFnFunction.java | 21 +- .../FlinkMergingNonShuffleReduceFunction.java | 14 +- .../FlinkMergingPartialReduceFunction.java | 14 +- .../functions/FlinkMergingReduceFunction.java | 12 +- .../functions/FlinkMultiOutputDoFnFunction.java | 14 +- .../FlinkMultiOutputProcessContext.java | 94 ++---- .../functions/FlinkPartialReduceFunction.java | 14 +- .../functions/FlinkProcessContext.java | 330 ------------------- .../functions/FlinkProcessContextBase.java | 278 ++++++++++++++++ .../functions/FlinkReduceFunction.java | 14 +- .../FlinkSingleOutputProcessContext.java | 69 ++++ .../runners/spark/translation/DoFnFunction.java | 10 +- .../spark/translation/MultiDoFnFunction.java | 21 +- .../spark/translation/SparkProcessContext.java | 81 +++-- .../apache/beam/sdk/transforms/DoFnTester.java | 18 +- .../beam/sdk/util/WindowingInternals.java | 14 +- .../beam/sdk/util/state/StateContexts.java | 29 +- 28 files changed, 827 insertions(+), 730 deletions(-) ----------------------------------------------------------------------