beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [41/50] [abbrv] beam git commit: This closes #3125
Date Thu, 18 May 2017 20:08:41 GMT
This closes #3125


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

Branch: refs/heads/gearpump-runner
Commit: f314ab3ce7536eb0274a571cd4baa1c15afc93a5
Parents: 32fd49a 2417949
Author: Eugene Kirpichov <kirpichov@google.com>
Authored: Tue May 16 11:55:58 2017 -0700
Committer: Eugene Kirpichov <kirpichov@google.com>
Committed: Tue May 16 11:55:58 2017 -0700

----------------------------------------------------------------------
 .../beam/runners/core/AssignWindowsDoFn.java    |  78 --
 .../apache/beam/runners/core/DoFnAdapters.java  | 381 ----------
 .../apache/beam/runners/core/DoFnRunners.java   |  27 +-
 .../GroupAlsoByWindowViaOutputBufferDoFn.java   | 113 ---
 .../core/GroupAlsoByWindowViaWindowSetDoFn.java |  94 ---
 .../GroupAlsoByWindowViaWindowSetNewDoFn.java   |   6 +-
 .../core/GroupAlsoByWindowsAggregators.java     |  26 +
 .../runners/core/GroupAlsoByWindowsDoFn.java    |  39 -
 .../core/LateDataDroppingDoFnRunner.java        |   3 +-
 .../org/apache/beam/runners/core/OldDoFn.java   | 335 ---------
 .../beam/runners/core/SimpleDoFnRunner.java     |   2 +-
 .../beam/runners/core/SimpleOldDoFnRunner.java  | 499 -------------
 .../core/WindowingInternalsAdapters.java        |  74 --
 ...roupAlsoByWindowViaOutputBufferDoFnTest.java | 109 ---
 .../core/GroupAlsoByWindowsProperties.java      | 744 -------------------
 .../apache/beam/runners/core/NoOpOldDoFn.java   |  65 --
 .../apache/beam/runners/core/OldDoFnTest.java   |  51 --
 .../runners/core/SimpleOldDoFnRunnerTest.java   |  86 ---
 .../GroupAlsoByWindowEvaluatorFactory.java      |   6 +-
 runners/google-cloud-dataflow-java/pom.xml      |   2 +-
 .../SparkGroupAlsoByWindowViaWindowSet.java     |   9 +-
 .../spark/translation/SparkAssignWindowFn.java  |   4 +-
 ...SparkGroupAlsoByWindowViaOutputBufferFn.java |   4 +-
 23 files changed, 45 insertions(+), 2712 deletions(-)
----------------------------------------------------------------------



Mime
View raw message