Package org.apache.flink.state.forst

Class ForStStateExecutor

java.lang.Object

org.apache.flink.state.forst.ForStStateExecutor

All Implemented Interfaces:

org.apache.flink.runtime.asyncprocessing.StateExecutor

public class ForStStateExecutor
extends Object
implements org.apache.flink.runtime.asyncprocessing.StateExecutor

The StateExecutor implementation which executing batch StateRequests for ForStStateBackend.

Constructor Summary

Constructors

Constructor	Description
ForStStateExecutor(int ioParallelism, org.rocksdb.RocksDB db, org.rocksdb.WriteOptions writeOptions)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.runtime.asyncprocessing.StateRequestContainer	createStateRequestContainer()
CompletableFuture<Void>	executeBatchRequests(org.apache.flink.runtime.asyncprocessing.StateRequestContainer stateRequestContainer)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

ForStStateExecutor

public ForStStateExecutor(int ioParallelism,
                          org.rocksdb.RocksDB db,
                          org.rocksdb.WriteOptions writeOptions)

Method Detail

executeBatchRequests

public CompletableFuture<Void> executeBatchRequests(org.apache.flink.runtime.asyncprocessing.StateRequestContainer stateRequestContainer)

Specified by:

executeBatchRequests in interface org.apache.flink.runtime.asyncprocessing.StateExecutor

createStateRequestContainer

public org.apache.flink.runtime.asyncprocessing.StateRequestContainer createStateRequestContainer()

Specified by:

createStateRequestContainer in interface org.apache.flink.runtime.asyncprocessing.StateExecutor

shutdown

public void shutdown()

Specified by:

shutdown in interface org.apache.flink.runtime.asyncprocessing.StateExecutor