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/06/22 02:22:26 UTC
[12/12] incubator-beam git commit: This closes #510
This closes #510
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e255cd6b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e255cd6b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e255cd6b
Branch: refs/heads/master
Commit: e255cd6be4eef7072c05bdf8720a766a2a597ea5
Parents: 73862b4 0fef8e6
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Jun 21 19:21:53 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Jun 21 19:21:53 2016 -0700
----------------------------------------------------------------------
runners/core-java/pom.xml | 30 +
.../org/apache/beam/sdk/util/AssignWindows.java | 46 +
.../apache/beam/sdk/util/AssignWindowsDoFn.java | 75 +
.../beam/sdk/util/BatchTimerInternals.java | 140 ++
.../org/apache/beam/sdk/util/DoFnRunner.java | 62 +
.../apache/beam/sdk/util/DoFnRunnerBase.java | 558 +++++++
.../org/apache/beam/sdk/util/DoFnRunners.java | 144 ++
.../beam/sdk/util/GroupAlsoByWindowsDoFn.java | 59 +
.../GroupAlsoByWindowsViaOutputBufferDoFn.java | 100 ++
.../sdk/util/GroupByKeyViaGroupByKeyOnly.java | 212 +++
.../sdk/util/LateDataDroppingDoFnRunner.java | 147 ++
.../org/apache/beam/sdk/util/NonEmptyPanes.java | 150 ++
.../apache/beam/sdk/util/PaneInfoTracker.java | 154 ++
.../sdk/util/PushbackSideInputDoFnRunner.java | 115 ++
.../java/org/apache/beam/sdk/util/ReduceFn.java | 130 ++
.../beam/sdk/util/ReduceFnContextFactory.java | 497 ++++++
.../apache/beam/sdk/util/ReduceFnRunner.java | 985 ++++++++++++
.../apache/beam/sdk/util/SimpleDoFnRunner.java | 56 +
.../apache/beam/sdk/util/SystemReduceFn.java | 135 ++
.../org/apache/beam/sdk/util/TriggerRunner.java | 234 +++
.../org/apache/beam/sdk/util/WatermarkHold.java | 536 +++++++
.../beam/sdk/util/BatchTimerInternalsTest.java | 118 ++
.../sdk/util/GroupAlsoByWindowsProperties.java | 619 ++++++++
...oupAlsoByWindowsViaOutputBufferDoFnTest.java | 106 ++
.../util/LateDataDroppingDoFnRunnerTest.java | 117 ++
.../util/PushbackSideInputDoFnRunnerTest.java | 234 +++
.../beam/sdk/util/ReduceFnRunnerTest.java | 1448 ++++++++++++++++++
.../apache/beam/sdk/util/ReduceFnTester.java | 784 ++++++++++
.../beam/sdk/util/SimpleDoFnRunnerTest.java | 86 ++
.../beam/runners/direct/DirectGroupByKey.java | 2 +-
.../direct/GroupByKeyEvaluatorFactoryTest.java | 2 +-
.../GroupByKeyOnlyEvaluatorFactoryTest.java | 2 +-
.../org/apache/beam/sdk/util/AssignWindows.java | 46 -
.../apache/beam/sdk/util/AssignWindowsDoFn.java | 75 -
.../beam/sdk/util/BatchTimerInternals.java | 140 --
.../org/apache/beam/sdk/util/DoFnRunner.java | 62 -
.../apache/beam/sdk/util/DoFnRunnerBase.java | 558 -------
.../org/apache/beam/sdk/util/DoFnRunners.java | 144 --
.../apache/beam/sdk/util/GatherAllPanes.java | 1 -
.../beam/sdk/util/GroupAlsoByWindowsDoFn.java | 59 -
.../GroupAlsoByWindowsViaOutputBufferDoFn.java | 100 --
.../sdk/util/GroupByKeyViaGroupByKeyOnly.java | 247 ---
.../sdk/util/LateDataDroppingDoFnRunner.java | 147 --
.../org/apache/beam/sdk/util/NonEmptyPanes.java | 150 --
.../apache/beam/sdk/util/PaneInfoTracker.java | 154 --
.../sdk/util/PushbackSideInputDoFnRunner.java | 115 --
.../java/org/apache/beam/sdk/util/ReduceFn.java | 130 --
.../beam/sdk/util/ReduceFnContextFactory.java | 497 ------
.../apache/beam/sdk/util/ReduceFnRunner.java | 985 ------------
.../sdk/util/ReifyTimestampsAndWindows.java | 63 +
.../apache/beam/sdk/util/SimpleDoFnRunner.java | 56 -
.../apache/beam/sdk/util/SystemReduceFn.java | 135 --
.../org/apache/beam/sdk/util/TriggerRunner.java | 234 ---
.../org/apache/beam/sdk/util/WatermarkHold.java | 536 -------
.../beam/sdk/util/BatchTimerInternalsTest.java | 118 --
.../sdk/util/GroupAlsoByWindowsProperties.java | 619 --------
...oupAlsoByWindowsViaOutputBufferDoFnTest.java | 106 --
.../util/LateDataDroppingDoFnRunnerTest.java | 117 --
.../util/PushbackSideInputDoFnRunnerTest.java | 234 ---
.../beam/sdk/util/ReduceFnRunnerTest.java | 1448 ------------------
.../apache/beam/sdk/util/ReduceFnTester.java | 784 ----------
.../beam/sdk/util/SimpleDoFnRunnerTest.java | 86 --
62 files changed, 8143 insertions(+), 8086 deletions(-)
----------------------------------------------------------------------