public class MemoryArchivist extends Object implements FlinkActor, LogMessages
- ArchiveExecutionGraph
archives the attached ExecutionGraph
- RequestArchivedJobs
returns all currently stored ExecutionGraph
s to the sender
encapsulated in a ArchivedJobs
message.
- RequestJob
returns the corresponding JobGraph
encapsulated in JobFound
if the job is stored by the MemoryArchivist. If not, then
JobNotFound
is returned.
- RequestJobStatus
returns the last state of the corresponding job. If the job can be found,
then a CurrentJobStatus
message with the last state is returned to the sender, otherwise
a JobNotFound
message is returned
- RequestJobCounts
returns the number of finished, canceled, and failed jobs as a Tuple3
param: maxEntries Maximum number of stored Flink jobs param: archivePath Optional path of the job archive directory
Constructor and Description |
---|
MemoryArchivist(int maxEntries,
scala.Option<Path> archivePath) |
Modifier and Type | Method and Description |
---|---|
protected scala.collection.mutable.LinkedHashMap<JobID,ArchivedExecutionGraph> |
graphs() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Handle incoming messages
|
grizzled.slf4j.Logger |
log() |
void |
preStart() |
void |
unhandled(Object message)
Handle unmatched messages with an exception.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
receive
decorateMessage
public MemoryArchivist(int maxEntries, scala.Option<Path> archivePath)
public grizzled.slf4j.Logger log()
log
in interface FlinkActor
protected scala.collection.mutable.LinkedHashMap<JobID,ArchivedExecutionGraph> graphs()
public void preStart()
preStart
in interface akka.actor.Actor
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
FlinkActor
handleMessage
in interface FlinkActor
public void unhandled(Object message)
unhandled
in interface akka.actor.Actor
message
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.