Uses of Interface
org.apache.flink.runtime.checkpoint.CheckpointScheduling
-
Packages that use CheckpointScheduling Package Description org.apache.flink.runtime.scheduler org.apache.flink.runtime.scheduler.adaptive org.apache.flink.runtime.scheduler.adaptivebatch -
-
Uses of CheckpointScheduling in org.apache.flink.runtime.scheduler
Classes in org.apache.flink.runtime.scheduler that implement CheckpointScheduling Modifier and Type Class Description classDefaultSchedulerThe future default scheduler.classSchedulerBaseBase class which can be used to implementSchedulerNG. -
Uses of CheckpointScheduling in org.apache.flink.runtime.scheduler.adaptive
Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type CheckpointScheduling Modifier and Type Method Description CompletableFuture<String>AdaptiveScheduler. goToStopWithSavepoint(ExecutionGraph executionGraph, ExecutionGraphHandler executionGraphHandler, OperatorCoordinatorHandler operatorCoordinatorHandler, CheckpointScheduling checkpointScheduling, CompletableFuture<String> savepointFuture, List<ExceptionHistoryEntry> failureCollection)CompletableFuture<String>StateTransitions.ToStopWithSavepoint. goToStopWithSavepoint(ExecutionGraph executionGraph, ExecutionGraphHandler executionGraphHandler, OperatorCoordinatorHandler operatorCoordinatorHandler, CheckpointScheduling checkpointScheduling, CompletableFuture<String> savepointFuture, List<ExceptionHistoryEntry> failureCollection)Transitions into theStopWithSavepointstate. -
Uses of CheckpointScheduling in org.apache.flink.runtime.scheduler.adaptivebatch
Classes in org.apache.flink.runtime.scheduler.adaptivebatch that implement CheckpointScheduling Modifier and Type Class Description classAdaptiveBatchSchedulerThis scheduler decides the parallelism of JobVertex according to the data volume it consumes.classSpeculativeSchedulerThe speculative scheduler.
-