This closes #3313
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f9d51aa5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f9d51aa5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f9d51aa5 Branch: refs/heads/master Commit: f9d51aa5cc718c44c82ec4773dbd16a57e7d394e Parents: 1597f3c 8362bdb Author: Aljoscha Krettek <[email protected]> Authored: Mon Jun 12 22:35:35 2017 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Mon Jun 12 22:35:35 2017 +0200 ---------------------------------------------------------------------- pom.xml | 7 + .../core/InMemoryStateInternalsTest.java | 555 ++---------------- .../beam/runners/core/StateInternalsTest.java | 573 +++++++++++++++++++ runners/flink/pom.xml | 8 + .../streaming/FlinkStateInternalsTest.java | 348 +---------- 5 files changed, 641 insertions(+), 850 deletions(-) ----------------------------------------------------------------------
