InMemoryCheckpointManager.getCheckpoint(String partitionId) Method

定义

public CompletableFuture<Checkpoint> getCheckpoint(String partitionId)

参数

partitionId
String

返回

CompletableFuture<Checkpoint>
替代

适用于