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

Modifier and Type	Method and Description
byte[]	buildSerializedKey()
byte[]	buildSerializedValue()
void	completeStateFuture()
void	completeStateFutureExceptionally(String message, Throwable ex)
org.rocksdb.ColumnFamilyHandle	getColumnFamilyHandle()
boolean	valueIsNull()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()

completeStateFutureExceptionally

public void completeStateFutureExceptionally(String message,
                                             Throwable ex)