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