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

This closes apache#2760
tchanghunua · 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 +
+ '}';
+ }
 }