Package org.apache.flink.state.forst
Interface ForStDBOperation
-
- All Known Implementing Classes:
ForStGeneralMultiGetOperation,ForStIterateOperation,ForStWriteBatchOperation
@Internal public interface ForStDBOperationData access operation to ForStDB. This interface is used to encapsulate the DB access operations formed after grouping state access. For more information about “Grouping state access”, please refer to FLIP-426.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CompletableFuture<Void>process()Process the ForStDB access requests.intsubProcessCount()The count of sub-processes.
-
-
-
Method Detail
-
process
CompletableFuture<Void> process()
Process the ForStDB access requests.- Returns:
- The future which indicates whether the operation is completed.
-
subProcessCount
int subProcessCount()
The count of sub-processes. Each sub-process is an atomic operation in one single thread.- Returns:
- the count.
-
-