org.apache.flink.runtime.dispatcher

Interface ArchivedExecutionGraphStore

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

FileArchivedExecutionGraphStore, MemoryArchivedExecutionGraphStore

public interface ArchivedExecutionGraphStore
extends Closeable

Interface for a ArchivedExecutionGraph store.

Method Summary

Modifier and Type	Method and Description
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 archivedExecutionGraph) Store the given ArchivedExecutionGraph in the store.
int	size() Returns the current number of stored ArchivedExecutionGraph.

Methods inherited from interface java.io.Closeable

close

Method Detail

size

int size()

Returns the current number of stored ArchivedExecutionGraph.

Returns:

Current number of stored ArchivedExecutionGraph

get

@Nullable
ArchivedExecutionGraph get(JobID jobId)

Get the ArchivedExecutionGraph for the given job id. Null if it isn't stored.

Parameters:

jobId - identifying the serializable execution graph to retrieve

Returns:

The stored serializable execution graph or null

put

void put(ArchivedExecutionGraph archivedExecutionGraph)
  throws IOException

Store the given ArchivedExecutionGraph in the store.

Parameters:

archivedExecutionGraph - to store

Throws:

IOException - if the serializable execution graph could not be stored in the store

getStoredJobsOverview

JobsOverview getStoredJobsOverview()

Return the JobsOverview for all stored/past jobs.

Returns:

Jobs overview for all stored/past jobs

getAvailableJobDetails

Collection<JobDetails> getAvailableJobDetails()

Return the collection of JobDetails of all currently stored jobs.

Returns:

Collection of job details of all currently stored jobs

getAvailableJobDetails

@Nullable
JobDetails getAvailableJobDetails(JobID jobId)

Return the JobDetails} for the given job.

Parameters:

jobId - identifying the job for which to retrieve the JobDetails

Returns:

JobDetails of the requested job or null if the job is not available