[FLINK-5014] [RocksDB backend] Add toString for RocksDBStateBackend

This closes apache#2760
EronWright · Nov 8, 2016 · d450bee · d450bee
1 parent d390824
commit d450bee
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/...d-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java b/...d-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
@@ -40,6 +40,7 @@
 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 ColumnFamilyOptions getColumnOptions() {
 		}
 		return columnOptions;
 	}
+
+	@Override
+	public String toString() {
+		return "RocksDB State Backend {" +
+			"isInitialized=" + isInitialized +
+			", configuredDbBasePaths=" + Arrays.toString(configuredDbBasePaths) +
+			", initializedDbBasePaths=" + Arrays.toString(initializedDbBasePaths) +
+			", checkpointStreamBackend=" + checkpointStreamBackend +
+			'}';
+	}
 }