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/01 03:40:19 UTC

[3/3] incubator-beam git commit: This closes #1187

This closes #1187


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

Branch: refs/heads/master
Commit: 978c99e9d699f79d25662c98c091114b8f608ee7
Parents: af17647 1abe47b
Author: Kenneth Knowles <kl...@google.com>
Authored: Mon Oct 31 20:40:02 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Oct 31 20:40:02 2016 -0700

----------------------------------------------------------------------
 .../core/GroupAlsoByWindowViaWindowSetDoFn.java |   3 +-
 .../GroupAlsoByWindowsViaOutputBufferDoFn.java  |   3 +-
 .../beam/runners/core/ReduceFnTester.java       |   6 +-
 .../direct/WatermarkCallbackExecutor.java       |   3 +-
 .../dataflow/DataflowPipelineTranslator.java    |   2 +-
 .../beam/runners/dataflow/DataflowRunner.java   |   4 +-
 .../org/apache/beam/sdk/transforms/Flatten.java |   3 +-
 .../apache/beam/sdk/transforms/GroupByKey.java  |   4 +-
 .../beam/sdk/transforms/windowing/Window.java   |   2 +-
 .../apache/beam/sdk/util/ExecutableTrigger.java | 131 -------------------
 .../apache/beam/sdk/util/WindowingStrategy.java |  10 +-
 .../sdk/transforms/windowing/WindowTest.java    |   6 +-
 .../beam/sdk/util/ExecutableTriggerTest.java    | 109 ---------------
 13 files changed, 21 insertions(+), 265 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/978c99e9/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java
----------------------------------------------------------------------