Package org.apache.flink.state.forst

Class ForStDBGetRequest<K,N,V,R>

java.lang.Object

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

Type Parameters:

K - The type of key in get access request.

N - The type of namespace in put access request.

V - The type of value returned by get request.

R - The type of returned value in state future.

Direct Known Subclasses:

ForStDBListGetRequest, ForStDBMapCheckRequest, ForStDBRawGetRequest, ForStDBSingleGetRequest

public abstract class ForStDBGetRequest<K,N,V,R>
extends Object

The Get access request for ForStDB.

Method Summary

Modifier and Type	Method	Description
byte[]	buildSerializedKey()
abstract void	completeStateFuture(byte[] bytesValue)
void	completeStateFutureExceptionally(String message, Throwable ex)
org.forstdb.ColumnFamilyHandle	getColumnFamilyHandle()
void	process(org.forstdb.RocksDB db)

Methods inherited from class java.lang.Object

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

Method Detail

process

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

Throws:

IOException

org.forstdb.RocksDBException

buildSerializedKey

public byte[] buildSerializedKey()
                          throws IOException

Throws:

IOException

getColumnFamilyHandle

public org.forstdb.ColumnFamilyHandle getColumnFamilyHandle()

completeStateFuture

public abstract void completeStateFuture(byte[] bytesValue)
                                  throws IOException

Throws:

IOException

completeStateFutureExceptionally

public void completeStateFutureExceptionally(String message,
                                             Throwable ex)