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.AsyncExecutor<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>, 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(boolean coordinatorInline, boolean isWriteInline, int readIoParallelism, int writeIoParallelism, org.forstdb.RocksDB db, org.forstdb.WriteOptions writeOptions)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>	createRequestContainer()
CompletableFuture<Void>	executeBatchRequests(org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer asyncRequestContainer)
void	executeRequestSync(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?> stateRequest)
boolean	fullyLoaded()
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(boolean coordinatorInline,
                          boolean isWriteInline,
                          int readIoParallelism,
                          int writeIoParallelism,
                          org.forstdb.RocksDB db,
                          org.forstdb.WriteOptions writeOptions)

Method Detail

executeBatchRequests

public CompletableFuture<Void> executeBatchRequests(org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer asyncRequestContainer)

Specified by:

executeBatchRequests in interface org.apache.flink.runtime.asyncprocessing.AsyncExecutor<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>

createRequestContainer

public org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>> createRequestContainer()

Specified by:

createRequestContainer in interface org.apache.flink.runtime.asyncprocessing.AsyncExecutor<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>

executeRequestSync

public void executeRequestSync(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?> stateRequest)

Specified by:

executeRequestSync in interface org.apache.flink.runtime.asyncprocessing.AsyncExecutor<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>

fullyLoaded

public boolean fullyLoaded()

Specified by:

fullyLoaded in interface org.apache.flink.runtime.asyncprocessing.AsyncExecutor<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>

shutdown

public void shutdown()

Specified by:

shutdown in interface org.apache.flink.runtime.asyncprocessing.AsyncExecutor<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>