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 <[email protected]> Authored: Wed Aug 16 11:46:49 2017 +0800 Committer: Pei He <[email protected]> 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(-) ----------------------------------------------------------------------
