This closes #3309
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7126fdc6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7126fdc6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7126fdc6 Branch: refs/heads/master Commit: 7126fdc6ee5671e99a2dede3f25ba616aa0e8fa4 Parents: fe3d554 4d18606 Author: Aljoscha Krettek <[email protected]> Authored: Tue Jun 13 11:35:43 2017 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Tue Jun 13 11:35:43 2017 +0200 ---------------------------------------------------------------------- .../beam/runners/core/StateInternalsTest.java | 40 ++ runners/flink/pom.xml | 1 - .../streaming/state/FlinkStateInternals.java | 425 +++++++++---------- .../streaming/FlinkStateInternalsTest.java | 17 - 4 files changed, 232 insertions(+), 251 deletions(-) ----------------------------------------------------------------------
