[FLINK-5014] [RocksDB backend] Add toString for RocksDBStateBackend This closes #2760
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d450beec Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d450beec Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d450beec Branch: refs/heads/master Commit: d450beece2f5f76d7f519101316f850e6fa4924a Parents: d390824 Author: Andrey Melentyev <[email protected]> Authored: Sat Nov 5 10:18:38 2016 +0300 Committer: Stephan Ewen <[email protected]> Committed: Tue Nov 8 15:26:42 2016 +0100 ---------------------------------------------------------------------- .../contrib/streaming/state/RocksDBStateBackend.java | 11 +++++++++++ 1 file changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d450beec/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java index 82e7899..37c6312 100644 --- a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java +++ b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java @@ -40,6 +40,7 @@ import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.net.URI; import java.util.ArrayList; +import java.util.Arrays; import java.util.Collection; import java.util.List; import java.util.Random; @@ -447,4 +448,14 @@ public class RocksDBStateBackend extends AbstractStateBackend { } return columnOptions; } + + @Override + public String toString() { + return "RocksDB State Backend {" + + "isInitialized=" + isInitialized + + ", configuredDbBasePaths=" + Arrays.toString(configuredDbBasePaths) + + ", initializedDbBasePaths=" + Arrays.toString(initializedDbBasePaths) + + ", checkpointStreamBackend=" + checkpointStreamBackend + + '}'; + } }
