Package org.apache.flink.state.forst

Class ForStDBMapCheckRequest<K,N,V>

java.lang.Object

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

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

Type Parameters:

K - The type of key in map check request.

N - The type of namespace in map check request.

V - The type of value in map check request.

public class ForStDBMapCheckRequest<K,N,V>
extends ForStDBGetRequest<K,N,V,Boolean>

The Map#isEmpty() and Map#contains() request for ForStDB.

Constructor Summary

Constructors

Constructor	Description
ForStDBMapCheckRequest(ContextKey<K,N> key, ForStInnerTable<K,N,V> table, org.apache.flink.core.asyncprocessing.InternalAsyncFuture<Boolean> future, boolean checkEmpty)

Method Summary

Modifier and Type	Method	Description
void	completeStateFuture(byte[] bytesValue)
void	process(org.forstdb.RocksDB db)

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

buildSerializedKey, completeStateFutureExceptionally, getColumnFamilyHandle

Methods inherited from class java.lang.Object

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

Constructor Detail

ForStDBMapCheckRequest

public ForStDBMapCheckRequest(ContextKey<K,N> key,
                              ForStInnerTable<K,N,V> table,
                              org.apache.flink.core.asyncprocessing.InternalAsyncFuture<Boolean> future,
                              boolean checkEmpty)

Method Detail

process

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

Overrides:

process in class ForStDBGetRequest<K,N,V,Boolean>

Throws:

org.forstdb.RocksDBException

IOException

completeStateFuture

public void completeStateFuture(byte[] bytesValue)

Specified by:

completeStateFuture in class ForStDBGetRequest<K,N,V,Boolean>