Package | Description |
---|---|
org.apache.flink.runtime.executiongraph |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionJobVertex |
ExecutionJobVertex.archive() |
ArchivedExecutionJobVertex |
ArchivedExecutionGraph.getJobVertex(JobVertexID id) |
Modifier and Type | Method and Description |
---|---|
Iterable<ArchivedExecutionJobVertex> |
ArchivedExecutionGraph.getVerticesTopologically() |
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,
JobSnapshottingSettings jobSnapshottingSettings,
CheckpointStatsSnapshot checkpointStatsSnapshot) |
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,
JobSnapshottingSettings jobSnapshottingSettings,
CheckpointStatsSnapshot checkpointStatsSnapshot) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.