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 2019/12/18 15:03:19 UTC
[flink] branch release-1.10 updated: [FLINK-15199][rocksdb] Make
RocksDBResourceContainer public for the benchmarks
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new 5358451 [FLINK-15199][rocksdb] Make RocksDBResourceContainer public for the benchmarks
5358451 is described below
commit 535845153ba45dc8e564f235e353e86aa1429fdd
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Wed Dec 11 16:26:59 2019 +0100
[FLINK-15199][rocksdb] Make RocksDBResourceContainer public for the benchmarks
flink-benchmarks need to access this class in order to use RocksDBKeyedStateBackendBuilder
---
.../flink/contrib/streaming/state/RocksDBResourceContainer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
index 0b81f6c..d49c0fa 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
@@ -37,7 +37,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
* <p>This should be the only entrance for {@link RocksDBStateBackend} to get RocksDB options,
* and should be properly (and necessarily) closed to prevent resource leak.
*/
-final class RocksDBResourceContainer implements AutoCloseable {
+public final class RocksDBResourceContainer implements AutoCloseable {
/** The pre-configured option settings. */
private final PredefinedOptions predefinedOptions;
@@ -76,7 +76,7 @@ final class RocksDBResourceContainer implements AutoCloseable {
/**
* Gets the RocksDB {@link DBOptions} to be used for RocksDB instances.
*/
- DBOptions getDbOptions() {
+ public DBOptions getDbOptions() {
// initial options from pre-defined profile
DBOptions opt = predefinedOptions.createDBOptions(handlesToClose);
handlesToClose.add(opt);