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 and Description
class	DefaultScheduler The future default scheduler.
class	SchedulerBase Base class which can be used to implement SchedulerNG.

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 and Description
CompletableFuture<String>	StateTransitions.ToStopWithSavepoint.goToStopWithSavepoint(ExecutionGraph executionGraph, ExecutionGraphHandler executionGraphHandler, OperatorCoordinatorHandler operatorCoordinatorHandler, CheckpointScheduling checkpointScheduling, CompletableFuture<String> savepointFuture, List<ExceptionHistoryEntry> failureCollection) Transitions into the StopWithSavepoint state.
CompletableFuture<String>	AdaptiveScheduler.goToStopWithSavepoint(ExecutionGraph executionGraph, ExecutionGraphHandler executionGraphHandler, OperatorCoordinatorHandler operatorCoordinatorHandler, CheckpointScheduling checkpointScheduling, CompletableFuture<String> savepointFuture, List<ExceptionHistoryEntry> failureCollection)

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 and Description
class	AdaptiveBatchScheduler This scheduler decides the parallelism of JobVertex according to the data volume it consumes.