You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/11/08 14:27:31 UTC
[2/4] flink git commit: [FLINK-5014] [RocksDB backend] Add toString
for RocksDBStateBackend
[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 <an...@gmail.com>
Authored: Sat Nov 5 10:18:38 2016 +0300
Committer: Stephan Ewen <se...@apache.org>
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 +
+ '}';
+ }
}