public class ForStStateExecutor extends Object implements StateExecutor
StateExecutor
implementation which executing batch StateRequest
s for
ForStStateBackend.Constructor and Description |
---|
ForStStateExecutor(boolean isWriteInline,
int readIoParallelism,
int writeIoParallelism,
org.rocksdb.RocksDB db,
org.rocksdb.WriteOptions writeOptions) |
Modifier and Type | Method and Description |
---|---|
StateRequestContainer |
createStateRequestContainer()
Create a
StateRequestContainer which is used to hold the batched StateRequest . |
CompletableFuture<Void> |
executeBatchRequests(StateRequestContainer stateRequestContainer)
Execute a batch of state requests.
|
boolean |
fullyLoaded()
Check if this executor is fully loaded.
|
void |
shutdown()
Shutdown the StateExecutor, and new committed state execution requests will be rejected.
|
public ForStStateExecutor(boolean isWriteInline, int readIoParallelism, int writeIoParallelism, org.rocksdb.RocksDB db, org.rocksdb.WriteOptions writeOptions)
public CompletableFuture<Void> executeBatchRequests(StateRequestContainer stateRequestContainer)
StateExecutor
executeBatchRequests
in interface StateExecutor
stateRequestContainer
- The StateRequestContainer which holds the given batch of
processing requests.public StateRequestContainer createStateRequestContainer()
StateExecutor
StateRequestContainer
which is used to hold the batched StateRequest
.createStateRequestContainer
in interface StateExecutor
public boolean fullyLoaded()
StateExecutor
fullyLoaded
in interface StateExecutor
public void shutdown()
StateExecutor
shutdown
in interface StateExecutor
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.