Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph |
Modifier and Type | Method and Description |
---|---|
JobCheckpointingSettings |
CheckpointStatsTracker.getSnapshottingSettings()
Returns the job's snapshotting settings which are derived from the
CheckpointConfig.
|
Constructor and Description |
---|
CheckpointStatsTracker(int numRememberedCheckpoints,
List<ExecutionJobVertex> jobVertices,
JobCheckpointingSettings jobCheckpointingSettings,
MetricGroup metricGroup)
Creates a new checkpoint stats tracker.
|
Modifier and Type | Method and Description |
---|---|
JobCheckpointingSettings |
ExecutionGraph.getJobCheckpointingSettings() |
JobCheckpointingSettings |
ArchivedExecutionGraph.getJobCheckpointingSettings() |
JobCheckpointingSettings |
AccessExecutionGraph.getJobCheckpointingSettings()
Returns the
JobCheckpointingSettings or null if
checkpointing is disabled. |
Constructor and Description |
---|
ArchivedExecutionGraph(JobID jobID,
String jobName,
Map<JobVertexID,ArchivedExecutionJobVertex> tasks,
List<ArchivedExecutionJobVertex> verticesInCreationOrder,
long[] stateTimestamps,
JobStatus state,
String failureCause,
String jsonPlan,
StringifiedAccumulatorResult[] archivedUserAccumulators,
Map<String,SerializedValue<Object>> serializedUserAccumulators,
ArchivedExecutionConfig executionConfig,
boolean isStoppable,
JobCheckpointingSettings jobCheckpointingSettings,
CheckpointStatsSnapshot checkpointStatsSnapshot) |
Modifier and Type | Method and Description |
---|---|
JobCheckpointingSettings |
JobGraph.getCheckpointingSettings()
Gets the settings for asynchronous snapshots.
|
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.setSnapshotSettings(JobCheckpointingSettings settings)
Sets the settings for asynchronous snapshots.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.