public class JobCheckpointingSettings extends Object implements Serializable
Constructor and Description |
---|
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend) |
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend,
SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks) |
Modifier and Type | Method and Description |
---|---|
CheckpointCoordinatorConfiguration |
getCheckpointCoordinatorConfiguration() |
SerializedValue<StateBackend> |
getDefaultStateBackend() |
SerializedValue<MasterTriggerRestoreHook.Factory[]> |
getMasterHooks() |
List<JobVertexID> |
getVerticesToAcknowledge() |
List<JobVertexID> |
getVerticesToConfirm() |
List<JobVertexID> |
getVerticesToTrigger() |
String |
toString() |
public JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, @Nullable SerializedValue<StateBackend> defaultStateBackend)
public JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, @Nullable SerializedValue<StateBackend> defaultStateBackend, @Nullable SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks)
public List<JobVertexID> getVerticesToTrigger()
public List<JobVertexID> getVerticesToAcknowledge()
public List<JobVertexID> getVerticesToConfirm()
public CheckpointCoordinatorConfiguration getCheckpointCoordinatorConfiguration()
@Nullable public SerializedValue<StateBackend> getDefaultStateBackend()
@Nullable public SerializedValue<MasterTriggerRestoreHook.Factory[]> getMasterHooks()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.