Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionGraph |
ExecutionGraph.archive() |
Modifier and Type | Method and Description |
---|---|
protected scala.collection.mutable.LinkedHashMap<JobID,ArchivedExecutionGraph> |
MemoryArchivist.graphs() |
Modifier and Type | Method and Description |
---|---|
ArchivedExecutionGraph |
ArchiveMessages.ArchiveExecutionGraph.graph() |
Modifier and Type | Method and Description |
---|---|
Collection<ArchivedExecutionGraph> |
ArchiveMessages.ArchivedJobs.asJavaCollection() |
Iterable<ArchivedExecutionGraph> |
ArchiveMessages.ArchivedJobs.asJavaIterable() |
scala.Option<ArchivedExecutionGraph> |
ArchiveMessages.ArchivedJob.job() |
scala.collection.Iterable<ArchivedExecutionGraph> |
ArchiveMessages.ArchivedJobs.jobs() |
Constructor and Description |
---|
ArchiveExecutionGraph(JobID jobID,
ArchivedExecutionGraph graph) |
Constructor and Description |
---|
ArchivedJob(scala.Option<ArchivedExecutionGraph> job) |
ArchivedJobs(scala.collection.Iterable<ArchivedExecutionGraph> jobs) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.