This closes #1960
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/137fee95 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/137fee95 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/137fee95 Branch: refs/heads/master Commit: 137fee95b3c1f7bd98f9983d29effcbe5acff899 Parents: f03f6ac 7d32b93 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Thu Feb 16 12:13:54 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Feb 16 12:13:54 2017 +0100 ---------------------------------------------------------------------- runners/flink/pom.xml | 2 +- runners/flink/runner/pom.xml | 6 + .../flink/DefaultParallelismFactory.java | 3 +- .../FlinkStreamingTransformTranslators.java | 20 +- .../FlinkStreamingTranslationContext.java | 8 + .../wrappers/streaming/DoFnOperator.java | 408 ++++--- .../wrappers/streaming/FlinkStateInternals.java | 1055 ------------------ .../wrappers/streaming/WindowDoFnOperator.java | 389 +------ .../streaming/io/BoundedSourceWrapper.java | 5 - .../streaming/io/UnboundedSourceWrapper.java | 23 +- .../state/FlinkBroadcastStateInternals.java | 865 ++++++++++++++ .../state/FlinkKeyGroupStateInternals.java | 487 ++++++++ .../state/FlinkSplitStateInternals.java | 260 +++++ .../streaming/state/FlinkStateInternals.java | 1053 +++++++++++++++++ .../state/KeyGroupCheckpointedOperator.java | 35 + .../state/KeyGroupRestoringOperator.java | 32 + .../wrappers/streaming/state/package-info.java | 22 + .../beam/runners/flink/PipelineOptionsTest.java | 25 +- .../flink/streaming/DoFnOperatorTest.java | 109 +- .../FlinkBroadcastStateInternalsTest.java | 245 ++++ .../FlinkKeyGroupStateInternalsTest.java | 262 +++++ .../streaming/FlinkSplitStateInternalsTest.java | 101 ++ .../streaming/FlinkStateInternalsTest.java | 27 +- .../streaming/UnboundedSourceWrapperTest.java | 16 + 24 files changed, 3814 insertions(+), 1644 deletions(-) ----------------------------------------------------------------------
