Package | Description |
---|---|
org.apache.flink.api.common | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.rest.messages |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionConfig |
ExecutionConfig.archive() |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionConfig |
AccessExecutionGraph.getArchivedExecutionConfig()
Returns the
ArchivedExecutionConfig for this execution graph. |
ArchivedExecutionConfig |
ExecutionGraph.getArchivedExecutionConfig()
Returns the serializable
ArchivedExecutionConfig . |
ArchivedExecutionConfig |
ArchivedExecutionGraph.getArchivedExecutionConfig() |
Constructor and Description |
---|
ArchivedExecutionGraph(JobID jobID,
String jobName,
Map<JobVertexID,ArchivedExecutionJobVertex> tasks,
List<ArchivedExecutionJobVertex> verticesInCreationOrder,
long[] stateTimestamps,
JobStatus state,
ErrorInfo failureCause,
String jsonPlan,
StringifiedAccumulatorResult[] archivedUserAccumulators,
Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators,
ArchivedExecutionConfig executionConfig,
boolean isStoppable,
CheckpointCoordinatorConfiguration jobCheckpointingConfiguration,
CheckpointStatsSnapshot checkpointStatsSnapshot,
String stateBackendName) |
Modifier and Type | Method and Description |
---|---|
static JobConfigInfo.ExecutionConfigInfo |
JobConfigInfo.ExecutionConfigInfo.from(ArchivedExecutionConfig archivedExecutionConfig) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.