beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [07/50] incubator-beam git commit: This closes #1353
Date Wed, 23 Nov 2016 06:52:03 GMT
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 <klk@google.com>
Authored: Thu Nov 17 22:31:07 2016 -0800
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message