org.apache.flink.runtime.jobmanager

Interface JobGraphStore

All Superinterfaces:

GloballyCleanableResource, JobGraphWriter, LocallyCleanableResource

All Known Implementing Classes:

DefaultJobGraphStore, StandaloneJobGraphStore

public interface JobGraphStore
extends JobGraphWriter

JobGraph instances for recovery.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	JobGraphStore.JobGraphListener A listener for JobGraph instances.

Method Summary

Modifier and Type	Method and Description
Collection<JobID>	getJobIds() Get all job ids of submitted job graphs to the submitted job graph store.
JobGraph	recoverJobGraph(JobID jobId) Returns the JobGraph with the given JobID or null if no job was registered.
void	start(JobGraphStore.JobGraphListener jobGraphListener) Starts the JobGraphStore service.
void	stop() Stops the JobGraphStore service.

Methods inherited from interface org.apache.flink.runtime.jobmanager.JobGraphWriter

globalCleanupAsync, localCleanupAsync, putJobGraph, putJobResourceRequirements

Method Detail

start

void start(JobGraphStore.JobGraphListener jobGraphListener)
    throws Exception

Starts the JobGraphStore service.

Throws:

Exception

stop

void stop()
   throws Exception

Stops the JobGraphStore service.

Throws:

Exception

recoverJobGraph

@Nullable
JobGraph recoverJobGraph(JobID jobId)
                            throws Exception

Returns the JobGraph with the given JobID or null if no job was registered.

Throws:

Exception

getJobIds

Collection<JobID> getJobIds()
                     throws Exception

Get all job ids of submitted job graphs to the submitted job graph store.

Returns:

Collection of submitted job ids

Throws:

Exception - if the operation fails