Package org.apache.flink.runtime.jobgraph.tasks

Class JobCheckpointingSettings

java.lang.Object

org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings

All Implemented Interfaces:

Serializable

public class JobCheckpointingSettings
extends Object
implements Serializable

The JobCheckpointingSettings are attached to a JobGraph and describe the settings for the asynchronous checkpoints of the JobGraph, such as interval.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend)
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend, TernaryBoolean changelogStateBackendEnabled, SerializedValue<CheckpointStorage> defaultCheckpointStorage, SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks)
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend, TernaryBoolean changelogStateBackendEnabled, SerializedValue<CheckpointStorage> defaultCheckpointStorage, SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks, TernaryBoolean stateBackendUseManagedMemory)

Method Summary

Modifier and Type	Method	Description
CheckpointCoordinatorConfiguration	getCheckpointCoordinatorConfiguration()
SerializedValue<CheckpointStorage>	getDefaultCheckpointStorage()
SerializedValue<StateBackend>	getDefaultStateBackend()
SerializedValue<MasterTriggerRestoreHook.Factory[]>	getMasterHooks()
TernaryBoolean	isChangelogStateBackendEnabled()
TernaryBoolean	isStateBackendUseManagedMemory()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JobCheckpointingSettings

@VisibleForTesting
public JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
                                @Nullable
                                SerializedValue<StateBackend> defaultStateBackend)

JobCheckpointingSettings

@VisibleForTesting
public JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
                                @Nullable
                                SerializedValue<StateBackend> defaultStateBackend,
                                @Nullable
                                TernaryBoolean changelogStateBackendEnabled,
                                @Nullable
                                SerializedValue<CheckpointStorage> defaultCheckpointStorage,
                                @Nullable
                                SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks)

JobCheckpointingSettings

public JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
                                @Nullable
                                SerializedValue<StateBackend> defaultStateBackend,
                                @Nullable
                                TernaryBoolean changelogStateBackendEnabled,
                                @Nullable
                                SerializedValue<CheckpointStorage> defaultCheckpointStorage,
                                @Nullable
                                SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks,
                                TernaryBoolean stateBackendUseManagedMemory)

Method Detail

getCheckpointCoordinatorConfiguration

public CheckpointCoordinatorConfiguration getCheckpointCoordinatorConfiguration()

getDefaultStateBackend

@Nullable
public SerializedValue<StateBackend> getDefaultStateBackend()

isChangelogStateBackendEnabled

public TernaryBoolean isChangelogStateBackendEnabled()

isStateBackendUseManagedMemory

public TernaryBoolean isStateBackendUseManagedMemory()

getDefaultCheckpointStorage

@Nullable
public SerializedValue<CheckpointStorage> getDefaultCheckpointStorage()

getMasterHooks

@Nullable
public SerializedValue<MasterTriggerRestoreHook.Factory[]> getMasterHooks()

toString

public String toString()

Overrides:

toString in class Object