[hotfix] [FLINK-3798] Make RocksDB state classes also public

apache · Apr 21, 2016 · 7478cba · 7478cba
1 parent d45cb69
commit 7478cba
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java b/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java
@@ -45,7 +45,7 @@
  * @param <S> The type of {@link State}.
  * @param <SD> The type of {@link StateDescriptor}.
  */
-abstract class AbstractRocksDBState<K, N, S extends State, SD extends StateDescriptor<S, ?>>
+public abstract class AbstractRocksDBState<K, N, S extends State, SD extends StateDescriptor<S, ?>>
  implements KvState<K, N, S, SD, RocksDBStateBackend>, State {
 
  private static final Logger LOG = LoggerFactory.getLogger(AbstractRocksDBState.class);

diff --git a/...d-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java b/...d-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java
@@ -43,7 +43,7 @@
  * @param <T> The type of the values that can be folded into the state.
  * @param <ACC> The type of the value in the folding state.
  */
-class RocksDBFoldingState<K, N, T, ACC>
+public class RocksDBFoldingState<K, N, T, ACC>
  extends AbstractRocksDBState<K, N, FoldingState<T, ACC>, FoldingStateDescriptor<T, ACC>>
  implements FoldingState<T, ACC> {
 

diff --git a/...kend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java b/...kend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java
@@ -48,7 +48,7 @@
  * @param <N> The type of the namespace.
  * @param <V> The type of the values in the list state.
  */
-class RocksDBListState<K, N, V>
+public class RocksDBListState<K, N, V>
  extends AbstractRocksDBState<K, N, ListState<V>, ListStateDescriptor<V>>
  implements ListState<V> {
 

diff --git a/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBReducingState.java b/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBReducingState.java
@@ -42,7 +42,7 @@
  * @param <N> The type of the namespace.
  * @param <V> The type of value that the state state stores.
  */
-class RocksDBReducingState<K, N, V>
+public class RocksDBReducingState<K, N, V>
  extends AbstractRocksDBState<K, N, ReducingState<V>, ReducingStateDescriptor<V>>
  implements ReducingState<V> {
 

diff --git a/...end-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBValueState.java b/...end-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBValueState.java
@@ -41,7 +41,7 @@
  * @param <N> The type of the namespace.
  * @param <V> The type of value that the state state stores.
  */
-class RocksDBValueState<K, N, V>
+public class RocksDBValueState<K, N, V>
  extends AbstractRocksDBState<K, N, ValueState<V>, ValueStateDescriptor<V>>
  implements ValueState<V> {