public class MemoryArchivedExecutionGraphStore extends Object implements ArchivedExecutionGraphStore
ArchivedExecutionGraphStore
implementation which stores the ArchivedExecutionGraph
in memory.Constructor and Description |
---|
MemoryArchivedExecutionGraphStore() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ArchivedExecutionGraph |
get(JobID jobId)
Get the
ArchivedExecutionGraph for the given job id. |
Collection<JobDetails> |
getAvailableJobDetails()
Return the collection of
JobDetails of all currently stored jobs. |
JobDetails |
getAvailableJobDetails(JobID jobId)
Return the
JobDetails } for the given job. |
JobsOverview |
getStoredJobsOverview()
Return the
JobsOverview for all stored/past jobs. |
void |
put(ArchivedExecutionGraph serializableExecutionGraph)
Store the given
ArchivedExecutionGraph in the store. |
int |
size()
Returns the current number of stored
ArchivedExecutionGraph . |
public int size()
ArchivedExecutionGraphStore
ArchivedExecutionGraph
.size
in interface ArchivedExecutionGraphStore
ArchivedExecutionGraph
@Nullable public ArchivedExecutionGraph get(JobID jobId)
ArchivedExecutionGraphStore
ArchivedExecutionGraph
for the given job id. Null if it isn't stored.get
in interface ArchivedExecutionGraphStore
jobId
- identifying the serializable execution graph to retrievepublic void put(ArchivedExecutionGraph serializableExecutionGraph) throws IOException
ArchivedExecutionGraphStore
ArchivedExecutionGraph
in the store.put
in interface ArchivedExecutionGraphStore
serializableExecutionGraph
- to storeIOException
- if the serializable execution graph could not be stored in the storepublic JobsOverview getStoredJobsOverview()
ArchivedExecutionGraphStore
JobsOverview
for all stored/past jobs.getStoredJobsOverview
in interface ArchivedExecutionGraphStore
public Collection<JobDetails> getAvailableJobDetails()
ArchivedExecutionGraphStore
JobDetails
of all currently stored jobs.getAvailableJobDetails
in interface ArchivedExecutionGraphStore
@Nullable public JobDetails getAvailableJobDetails(JobID jobId)
ArchivedExecutionGraphStore
JobDetails
} for the given job.getAvailableJobDetails
in interface ArchivedExecutionGraphStore
jobId
- identifying the job for which to retrieve the JobDetails
JobDetails
of the requested job or null if the job is not availablepublic void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.