[FLINK-8360][checkpointing] Implement file-based local recovery for RocksDBStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1619fa8a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1619fa8a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1619fa8a Branch: refs/heads/master Commit: 1619fa8abe8d605b14ee0ddabcdc86196c50e24a Parents: e04321f Author: Stefan Richter <[email protected]> Authored: Wed Feb 21 11:27:17 2018 +0100 Committer: Stefan Richter <[email protected]> Committed: Sun Feb 25 15:59:54 2018 +0100 ---------------------------------------------------------------------- .../state/RocksDBKeyedStateBackend.java | 3038 ++++++++++-------- ...lRocksStreamOperatorSnapshotRestoreTest.java | 37 + .../state/RocksDBRocksIteratorWrapperTest.java | 15 +- .../RocksStreamOperatorSnapshotRestoreTest.java | 37 + 4 files changed, 1769 insertions(+), 1358 deletions(-) ----------------------------------------------------------------------
