Package org.apache.flink.state.forst

Class ForStDBMultiRawMergePutRequest<K,N,V>

java.lang.Object

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

org.apache.flink.state.forst.ForStDBMultiRawMergePutRequest<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.

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

The Put access request for ForStDB.

Method Summary

Modifier and Type	Method	Description
void	process(ForStDBWriteBatchWrapper writeBatchWrapper, org.forstdb.RocksDB db)

Methods inherited from class org.apache.flink.state.forst.ForStDBPutRequest

buildSerializedKey, buildSerializedValue, completeStateFuture, completeStateFutureExceptionally, getColumnFamilyHandle, 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

Overrides:

process in class ForStDBPutRequest<K,N,V>

Throws:

IOException

org.forstdb.RocksDBException