Package org.apache.flink.state.forst

Class ForStDBPutRequest<K,N,V>

java.lang.Object

org.apache.flink.state.forst.ForStDBPutRequest<K,N,V>

Type Parameters:

K - The type of key in put access request.

N - The type of namespace in put access request.

V - The type of value in put access request.

Direct Known Subclasses:

ForStDBBunchPutRequest

public class ForStDBPutRequest<K,N,V>
extends Object

The Put access request for ForStDB.

Method Summary

Modifier and Type	Method	Description
byte[]	buildSerializedKey()
byte[]	buildSerializedValue()
void	completeStateFuture()
void	completeStateFutureExceptionally(String message, Throwable ex)
org.forstdb.ColumnFamilyHandle	getColumnFamilyHandle()
void	process(ForStDBWriteBatchWrapper writeBatchWrapper, org.forstdb.RocksDB db)
boolean	valueIsNull()

Methods inherited from class java.lang.Object

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

Method Detail

process

public void process(ForStDBWriteBatchWrapper writeBatchWrapper,
                    org.forstdb.RocksDB db)
             throws IOException,
                    org.forstdb.RocksDBException

Throws:

IOException

org.forstdb.RocksDBException

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)

valueIsNull

@VisibleForTesting
public boolean valueIsNull()

getColumnFamilyHandle

@VisibleForTesting
public org.forstdb.ColumnFamilyHandle getColumnFamilyHandle()