flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [2/4] flink git commit: [FLINK-5014] [RocksDB backend] Add toString for RocksDBStateBackend
Date Tue, 08 Nov 2016 14:27:31 GMT
[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 <andrey.melentyev@gmail.com>
Authored: Sat Nov 5 10:18:38 2016 +0300
Committer: Stephan Ewen <sewen@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 +
+			'}';
+	}
 }


Mime
View raw message