Modifier and Type | Method and Description |
---|---|
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createSparseArchivedExecutionGraph(JobID jobId,
String jobName,
JobStatus jobStatus,
JobType jobType,
Throwable throwable,
JobCheckpointingSettings checkpointingSettings,
long initializationTimestamp)
Create a sparse ArchivedExecutionGraph for a job.
|
static ArchivedExecutionGraph |
ArchivedExecutionGraph.createSparseArchivedExecutionGraphWithJobVertices(JobID jobId,
String jobName,
JobStatus jobStatus,
JobType jobType,
Throwable throwable,
JobCheckpointingSettings checkpointingSettings,
long initializationTimestamp,
Iterable<JobVertex> jobVertices,
VertexParallelismStore initialParallelismStore) |
Modifier and Type | Method and Description |
---|---|
JobCheckpointingSettings |
JobGraph.getCheckpointingSettings()
Gets the settings for asynchronous snapshots.
|
Modifier and Type | Method and Description |
---|---|
JobGraphBuilder |
JobGraphBuilder.setJobCheckpointingSettings(JobCheckpointingSettings newJobCheckpointingSettings) |
void |
JobGraph.setSnapshotSettings(JobCheckpointingSettings settings)
Sets the settings for asynchronous snapshots.
|
Constructor and Description |
---|
DefaultJobMasterServiceProcessFactory(JobID jobId,
String jobName,
JobType jobType,
JobCheckpointingSettings checkpointingSettings,
long initializationTimestamp,
JobMasterServiceFactory jobMasterServiceFactory) |
Modifier and Type | Method and Description |
---|---|
JobCheckpointingSettings |
JobGraphJobInformation.getCheckpointingSettings() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.