Package org.apache.flink.state.rocksdb
Class RocksDBKeyedStateBackend.RocksDbKvStateInfo
- java.lang.Object
-
- org.apache.flink.state.rocksdb.RocksDBKeyedStateBackend.RocksDbKvStateInfo
-
- All Implemented Interfaces:
AutoCloseable
- Enclosing class:
- RocksDBKeyedStateBackend<K>
public static class RocksDBKeyedStateBackend.RocksDbKvStateInfo extends Object implements AutoCloseable
Rocks DB specific information about the k/v states.
-
-
Field Summary
Fields Modifier and Type Field Description org.rocksdb.ColumnFamilyHandle
columnFamilyHandle
RegisteredStateMetaInfoBase
metaInfo
-
Constructor Summary
Constructors Constructor Description RocksDbKvStateInfo(org.rocksdb.ColumnFamilyHandle columnFamilyHandle, RegisteredStateMetaInfoBase metaInfo)
-
-
-
Field Detail
-
columnFamilyHandle
public final org.rocksdb.ColumnFamilyHandle columnFamilyHandle
-
metaInfo
public final RegisteredStateMetaInfoBase metaInfo
-
-
Constructor Detail
-
RocksDbKvStateInfo
public RocksDbKvStateInfo(org.rocksdb.ColumnFamilyHandle columnFamilyHandle, RegisteredStateMetaInfoBase metaInfo)
-
-
Method Detail
-
close
public void close() throws Exception
- Specified by:
close
in interfaceAutoCloseable
- Throws:
Exception
-
-