Package org.apache.flink.state.forst
Class ForStDBGetRequest<K,V>
- java.lang.Object
-
- org.apache.flink.state.forst.ForStDBGetRequest<K,V>
-
- Type Parameters:
K- The type of key in get access request.V- The type of value returned by get request.
public class ForStDBGetRequest<K,V> extends Object
The Get access request for ForStDB.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]buildSerializedKey()voidcompleteStateFuture(byte[] bytesValue)voidcompleteStateFutureExceptionally(String message, Throwable ex)org.rocksdb.ColumnFamilyHandlegetColumnFamilyHandle()
-
-
-
Method Detail
-
buildSerializedKey
public byte[] buildSerializedKey() throws IOException- Throws:
IOException
-
getColumnFamilyHandle
public org.rocksdb.ColumnFamilyHandle getColumnFamilyHandle()
-
completeStateFuture
public void completeStateFuture(byte[] bytesValue) throws IOException- Throws:
IOException
-
-