Package org.apache.flink.runtime.dispatcher

Class SingleJobJobGraphStore

java.lang.Object

org.apache.flink.runtime.dispatcher.SingleJobJobGraphStore

All Implemented Interfaces:

GloballyCleanableResource, LocallyCleanableResource, JobGraphStore, JobGraphWriter

public class SingleJobJobGraphStore
extends Object
implements JobGraphStore

JobGraphStore implementation for a single job.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.jobmanager.JobGraphStore

JobGraphStore.JobGraphListener

Constructor Summary

Constructors

Constructor	Description
SingleJobJobGraphStore(JobGraph jobGraph)

Method Summary

Modifier and Type	Method	Description
Collection<org.apache.flink.api.common.JobID>	getJobIds()	Get all job ids of submitted job graphs to the submitted job graph store.
void	putJobGraph(JobGraph jobGraph)	Adds the JobGraph instance.
void	putJobResourceRequirements(org.apache.flink.api.common.JobID jobId, JobResourceRequirements jobResourceRequirements)	Persist job resource requirements for the given job.
JobGraph	recoverJobGraph(org.apache.flink.api.common.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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

globalCleanupAsync, localCleanupAsync

Constructor Detail

SingleJobJobGraphStore

public SingleJobJobGraphStore(JobGraph jobGraph)

Method Detail

start

public void start(JobGraphStore.JobGraphListener jobGraphListener)
           throws Exception

Description copied from interface: JobGraphStore

Starts the JobGraphStore service.

Specified by:

start in interface JobGraphStore

Throws:

Exception

stop

public void stop()
          throws Exception

Description copied from interface: JobGraphStore

Stops the JobGraphStore service.

Specified by:

stop in interface JobGraphStore

Throws:

Exception

recoverJobGraph

public JobGraph recoverJobGraph(org.apache.flink.api.common.JobID jobId)
                         throws Exception

Description copied from interface: JobGraphStore

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

Specified by:

recoverJobGraph in interface JobGraphStore

Throws:

Exception

putJobGraph

public void putJobGraph(JobGraph jobGraph)
                 throws Exception

Description copied from interface: JobGraphWriter

Adds the JobGraph instance.

If a job graph with the same JobID exists, it is replaced.

Specified by:

putJobGraph in interface JobGraphWriter

Throws:

Exception

putJobResourceRequirements

public void putJobResourceRequirements(org.apache.flink.api.common.JobID jobId,
                                       JobResourceRequirements jobResourceRequirements)
                                throws Exception

Description copied from interface: JobGraphWriter

Persist job resource requirements for the given job.

Specified by:

putJobResourceRequirements in interface JobGraphWriter

Parameters:

jobId - job the given requirements belong to

jobResourceRequirements - requirements to persist

Throws:

Exception - in case we're not able to persist the requirements for some reason

getJobIds

public Collection<org.apache.flink.api.common.JobID> getJobIds()

Description copied from interface: JobGraphStore

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

Specified by:

getJobIds in interface JobGraphStore

Returns:

Collection of submitted job ids