Package org.apache.flink.state.forst
Class ForStGeneralMultiGetOperation
- java.lang.Object
-
- org.apache.flink.state.forst.ForStGeneralMultiGetOperation
-
- All Implemented Interfaces:
ForStDBOperation
public class ForStGeneralMultiGetOperation extends Object implements ForStDBOperation
The general-purpose multiGet operation implementation for ForStDB, which simulates multiGet by calling the Get API multiple times with multiple threads.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletableFuture<Void>
process()
Process the ForStDB access requests.int
subProcessCount()
The count of sub-processes.
-
-
-
Method Detail
-
process
public CompletableFuture<Void> process()
Description copied from interface:ForStDBOperation
Process the ForStDB access requests.- Specified by:
process
in interfaceForStDBOperation
- Returns:
- The future which indicates whether the operation is completed.
-
subProcessCount
public int subProcessCount()
Description copied from interface:ForStDBOperation
The count of sub-processes. Each sub-process is an atomic operation in one single thread.- Specified by:
subProcessCount
in interfaceForStDBOperation
- Returns:
- the count.
-
-