Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Constructor and Description |
---|
PerJobCheckpointRecoveryFactory(PerJobCheckpointRecoveryFactory.CheckpointStoreRecoveryHelper<T> checkpointStoreRecoveryHelper) |
PerJobCheckpointRecoveryFactory(PerJobCheckpointRecoveryFactory.CheckpointStoreRecoveryHelper<T> checkpointStoreRecoveryHelper,
java.util.function.Supplier<CheckpointIDCounter> checkpointIDCounterPerJobFactory) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.