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 2016/11/18 06:32:20 UTC
[7/7] incubator-beam git commit: This closes #1353
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/master
Commit: 4852d2ebf503a5207db612cb6429728d0f3cb7e1
Parents: 212fec4 c0623c1
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Nov 17 22:31:07 2016 -0800
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------