beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [01/11] incubator-beam git commit: Closes #887
Date Fri, 02 Sep 2016 17:43:48 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 3ef7a35b7 -> 38b8a0e48


Closes #887


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/38b8a0e4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/38b8a0e4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/38b8a0e4

Branch: refs/heads/master
Commit: 38b8a0e483401802975520f5d912499f5df53541
Parents: 3ef7a35 a62e501
Author: Dan Halperin <dhalperi@google.com>
Authored: Fri Sep 2 10:35:39 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Fri Sep 2 10:35:39 2016 -0700

----------------------------------------------------------------------
 .../apache/beam/runners/core/AssignWindows.java |   46 +
 .../beam/runners/core/AssignWindowsDoFn.java    |   79 +
 .../beam/runners/core/BatchTimerInternals.java  |  140 ++
 .../apache/beam/runners/core/DoFnRunner.java    |   65 +
 .../beam/runners/core/DoFnRunnerBase.java       |  559 +++++++
 .../apache/beam/runners/core/DoFnRunners.java   |  148 ++
 .../runners/core/ElementByteSizeObservable.java |   44 +
 .../core/GroupAlsoByWindowViaWindowSetDoFn.java |    5 +-
 .../runners/core/GroupAlsoByWindowsDoFn.java    |   66 +
 .../GroupAlsoByWindowsViaOutputBufferDoFn.java  |  100 ++
 .../core/GroupByKeyViaGroupByKeyOnly.java       |  271 ++++
 .../core/LateDataDroppingDoFnRunner.java        |  151 ++
 .../apache/beam/runners/core/NonEmptyPanes.java |  151 ++
 .../beam/runners/core/PaneInfoTracker.java      |  158 ++
 .../beam/runners/core/PeekingReiterator.java    |  100 ++
 .../core/PushbackSideInputDoFnRunner.java       |  116 ++
 .../org/apache/beam/runners/core/ReduceFn.java  |  130 ++
 .../runners/core/ReduceFnContextFactory.java    |  499 ++++++
 .../beam/runners/core/ReduceFnRunner.java       |  993 ++++++++++++
 .../beam/runners/core/SimpleDoFnRunner.java     |   58 +
 .../beam/runners/core/SystemReduceFn.java       |  139 ++
 .../apache/beam/runners/core/TriggerRunner.java |  247 +++
 .../apache/beam/runners/core/WatermarkHold.java |  539 +++++++
 .../org/apache/beam/sdk/util/AssignWindows.java |   46 -
 .../apache/beam/sdk/util/AssignWindowsDoFn.java |   77 -
 .../beam/sdk/util/BatchTimerInternals.java      |  137 --
 .../org/apache/beam/sdk/util/DoFnRunner.java    |   63 -
 .../apache/beam/sdk/util/DoFnRunnerBase.java    |  551 -------
 .../org/apache/beam/sdk/util/DoFnRunners.java   |  143 --
 .../beam/sdk/util/GroupAlsoByWindowsDoFn.java   |   63 -
 .../GroupAlsoByWindowsViaOutputBufferDoFn.java  |   97 --
 .../sdk/util/GroupByKeyViaGroupByKeyOnly.java   |  268 ----
 .../sdk/util/LateDataDroppingDoFnRunner.java    |  145 --
 .../org/apache/beam/sdk/util/NonEmptyPanes.java |  150 --
 .../apache/beam/sdk/util/PaneInfoTracker.java   |  156 --
 .../sdk/util/PushbackSideInputDoFnRunner.java   |  113 --
 .../java/org/apache/beam/sdk/util/ReduceFn.java |  128 --
 .../beam/sdk/util/ReduceFnContextFactory.java   |  493 ------
 .../apache/beam/sdk/util/ReduceFnRunner.java    |  983 ------------
 .../apache/beam/sdk/util/SimpleDoFnRunner.java  |   55 -
 .../apache/beam/sdk/util/SystemReduceFn.java    |  138 --
 .../org/apache/beam/sdk/util/TriggerRunner.java |  241 ---
 .../org/apache/beam/sdk/util/WatermarkHold.java |  536 -------
 .../util/common/ElementByteSizeObservable.java  |   42 -
 .../beam/sdk/util/common/PeekingReiterator.java |   99 --
 .../beam/sdk/util/common/package-info.java      |   20 -
 .../org/apache/beam/sdk/util/package-info.java  |   20 -
 .../runners/core/BatchTimerInternalsTest.java   |  118 ++
 .../core/GroupAlsoByWindowsProperties.java      |  660 ++++++++
 ...oupAlsoByWindowsViaOutputBufferDoFnTest.java |  110 ++
 .../core/LateDataDroppingDoFnRunnerTest.java    |  117 ++
 .../core/PushbackSideInputDoFnRunnerTest.java   |  235 +++
 .../beam/runners/core/ReduceFnRunnerTest.java   | 1446 ++++++++++++++++++
 .../beam/runners/core/ReduceFnTester.java       |  796 ++++++++++
 .../beam/runners/core/SimpleDoFnRunnerTest.java |   88 ++
 .../beam/sdk/util/BatchTimerInternalsTest.java  |  117 --
 .../sdk/util/GroupAlsoByWindowsProperties.java  |  658 --------
 ...oupAlsoByWindowsViaOutputBufferDoFnTest.java |  109 --
 .../util/LateDataDroppingDoFnRunnerTest.java    |  114 --
 .../util/PushbackSideInputDoFnRunnerTest.java   |  231 ---
 .../beam/sdk/util/ReduceFnRunnerTest.java       | 1442 -----------------
 .../apache/beam/sdk/util/ReduceFnTester.java    |  784 ----------
 .../beam/sdk/util/SimpleDoFnRunnerTest.java     |   84 -
 .../GroupAlsoByWindowEvaluatorFactory.java      |    8 +-
 .../direct/GroupByKeyOnlyEvaluatorFactory.java  |    4 +-
 .../beam/runners/direct/ParDoEvaluator.java     |    8 +-
 .../direct/UncommittedBundleOutputManager.java  |    2 +-
 .../FlinkStreamingTransformTranslators.java     |    2 +-
 .../wrappers/streaming/DoFnOperator.java        |    6 +-
 .../wrappers/streaming/WindowDoFnOperator.java  |    2 +-
 .../apache/beam/runners/spark/SparkRunner.java  |    2 +-
 .../spark/translation/TransformTranslator.java  |   10 +-
 .../streaming/StreamingTransformTranslator.java |    2 +-
 .../src/main/resources/beam/findbugs-filter.xml |    2 +-
 .../org/apache/beam/sdk/util/BitSetCoder.java   |    2 +-
 75 files changed, 8395 insertions(+), 8332 deletions(-)
----------------------------------------------------------------------



Mime
View raw message