You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by pe...@apache.org on 2017/08/16 03:47:40 UTC

[2/2] beam git commit: This closes #3368

This closes #3368


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

Branch: refs/heads/master
Commit: 724eda37ea1e54aac089d89c711ca3cee14a4603
Parents: 3a8b0b6 ceec7ce
Author: Pei He <pe...@apache.org>
Authored: Wed Aug 16 11:46:49 2017 +0800
Committer: Pei He <pe...@apache.org>
Committed: Wed Aug 16 11:46:49 2017 +0800

----------------------------------------------------------------------
 .../runners/flink/FlinkPipelineOptions.java     |  11 +
 .../FlinkStreamingTransformTranslators.java     |  77 ++--
 .../wrappers/streaming/DoFnOperator.java        | 412 ++++++++++++++-----
 .../streaming/SplittableDoFnOperator.java       |   4 +-
 .../wrappers/streaming/WindowDoFnOperator.java  |   4 +-
 .../state/FlinkSplitStateInternals.java         |   8 +-
 .../beam/runners/flink/PipelineOptionsTest.java |  21 +-
 .../flink/streaming/DoFnOperatorTest.java       | 161 ++++++--
 8 files changed, 535 insertions(+), 163 deletions(-)
----------------------------------------------------------------------