public class JobCheckpointingSettings extends Object implements Serializable
Constructor and Description |
---|
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizedCheckpointSettings,
SerializedValue<StateBackend> defaultStateBackend,
boolean isExactlyOnce) |
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizedCheckpointSettings,
SerializedValue<StateBackend> defaultStateBackend,
SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks,
boolean isExactlyOnce) |
Modifier and Type | Method and Description |
---|---|
long |
getCheckpointInterval() |
long |
getCheckpointTimeout() |
SerializedValue<StateBackend> |
getDefaultStateBackend() |
ExternalizedCheckpointSettings |
getExternalizedCheckpointSettings() |
SerializedValue<MasterTriggerRestoreHook.Factory[]> |
getMasterHooks() |
int |
getMaxConcurrentCheckpoints() |
long |
getMinPauseBetweenCheckpoints() |
List<JobVertexID> |
getVerticesToAcknowledge() |
List<JobVertexID> |
getVerticesToConfirm() |
List<JobVertexID> |
getVerticesToTrigger() |
boolean |
isExactlyOnce() |
String |
toString() |
public JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, ExternalizedCheckpointSettings externalizedCheckpointSettings, @Nullable SerializedValue<StateBackend> defaultStateBackend, boolean isExactlyOnce)
public JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, long checkpointInterval, long checkpointTimeout, long minPauseBetweenCheckpoints, int maxConcurrentCheckpoints, ExternalizedCheckpointSettings externalizedCheckpointSettings, @Nullable SerializedValue<StateBackend> defaultStateBackend, @Nullable SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks, boolean isExactlyOnce)
public List<JobVertexID> getVerticesToTrigger()
public List<JobVertexID> getVerticesToAcknowledge()
public List<JobVertexID> getVerticesToConfirm()
public long getCheckpointInterval()
public long getCheckpointTimeout()
public long getMinPauseBetweenCheckpoints()
public int getMaxConcurrentCheckpoints()
public ExternalizedCheckpointSettings getExternalizedCheckpointSettings()
@Nullable public SerializedValue<StateBackend> getDefaultStateBackend()
@Nullable public SerializedValue<MasterTriggerRestoreHook.Factory[]> getMasterHooks()
public boolean isExactlyOnce()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.