Uses of Package
org.apache.flink.core.execution
-
Packages that use org.apache.flink.core.execution Package Description org.apache.flink.configuration org.apache.flink.core.execution -
Classes in org.apache.flink.core.execution used by org.apache.flink.configuration Class Description CheckpointingMode The checkpointing mode defines what consistency guarantees the system gives in the presence of failures.RestoreMode Defines state files ownership when Flink restore from a given savepoint or retained checkpoint. -
Classes in org.apache.flink.core.execution used by org.apache.flink.core.execution Class Description CheckpointingMode The checkpointing mode defines what consistency guarantees the system gives in the presence of failures.CheckpointType Describes the type in which a checkpoint should be taken.JobClient A client that is scoped to a specific job.PipelineExecutor The entity responsible for executing aPipeline, i.e.PipelineExecutorFactory A factory for selecting and instantiating the adequatePipelineExecutorbased on a providedConfiguration.PipelineExecutorServiceLoader An interface to be implemented by the entity responsible for finding the correctPipelineExecutorto execute a givenPipeline.RestoreMode Defines state files ownership when Flink restore from a given savepoint or retained checkpoint.SavepointFormatType Describes the binary format in which a savepoint should be taken.