You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/07/16 21:06:31 UTC
[2/8] flink git commit: [hotfix] Rename PriorityQueueStateType.ROCKS
into PriorityQueueStateType.ROCKSDB
[hotfix] Rename PriorityQueueStateType.ROCKS into PriorityQueueStateType.ROCKSDB
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8db5ca6b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8db5ca6b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8db5ca6b
Branch: refs/heads/master
Commit: 8db5ca6b0da13f7bd8dab3edee127c50cf26109b
Parents: a4b4cb7
Author: Till Rohrmann <tr...@apache.org>
Authored: Mon Jul 16 09:31:06 2018 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Mon Jul 16 22:11:57 2018 +0200
----------------------------------------------------------------------
.../flink/contrib/streaming/state/RocksDBKeyedStateBackend.java | 2 +-
.../org/apache/flink/contrib/streaming/state/RocksDBOptions.java | 4 ++--
.../flink/contrib/streaming/state/RocksDBStateBackend.java | 2 +-
3 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8db5ca6b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
----------------------------------------------------------------------
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
index 0697463..72aa4fb 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
@@ -324,7 +324,7 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> {
case HEAP:
this.priorityQueueFactory = new HeapPriorityQueueSetFactory(keyGroupRange, numberOfKeyGroups, 128);
break;
- case ROCKS:
+ case ROCKSDB:
this.priorityQueueFactory = new RocksDBPriorityQueueSetFactory();
break;
default:
http://git-wip-us.apache.org/repos/asf/flink/blob/8db5ca6b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java
----------------------------------------------------------------------
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java
index 37eb6cf..18f9ec9 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java
@@ -22,7 +22,7 @@ import org.apache.flink.configuration.ConfigOption;
import org.apache.flink.configuration.ConfigOptions;
import static org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType.HEAP;
-import static org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType.ROCKS;
+import static org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType.ROCKSDB;
/**
* Configuration options for the RocksDB backend.
@@ -43,5 +43,5 @@ public class RocksDBOptions {
.key("state.backend.rocksdb.timer-service.impl")
.defaultValue(HEAP.name())
.withDescription(String.format("This determines the timer service implementation. Options are either %s " +
- "(heap-based, default) or %s for an implementation based on RocksDB.", HEAP.name(), ROCKS.name()));
+ "(heap-based, default) or %s for an implementation based on RocksDB.", HEAP.name(), ROCKSDB.name()));
}
http://git-wip-us.apache.org/repos/asf/flink/blob/8db5ca6b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
----------------------------------------------------------------------
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
index 58e8de6..c6b50cd 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
@@ -83,7 +83,7 @@ public class RocksDBStateBackend extends AbstractStateBackend implements Configu
*/
public enum PriorityQueueStateType {
HEAP,
- ROCKS
+ ROCKSDB
}
private static final long serialVersionUID = 1L;