public class StandaloneSubmittedJobGraphStore extends Object implements SubmittedJobGraphStore
SubmittedJobGraph
instances for JobManagers running in HighAvailabilityMode.NONE
.
All operations are NoOps, because JobGraph
instances cannot be recovered in this
recovery mode.
SubmittedJobGraphStore.SubmittedJobGraphListener
Constructor and Description |
---|
StandaloneSubmittedJobGraphStore() |
Modifier and Type | Method and Description |
---|---|
Collection<JobID> |
getJobIds()
Get all job ids of submitted job graphs to the submitted job graph store.
|
void |
putJobGraph(SubmittedJobGraph jobGraph)
Adds the
SubmittedJobGraph instance. |
SubmittedJobGraph |
recoverJobGraph(JobID jobId)
Returns the
SubmittedJobGraph with the given JobID . |
void |
removeJobGraph(JobID jobId)
Removes the
SubmittedJobGraph with the given JobID if it exists. |
void |
start(SubmittedJobGraphStore.SubmittedJobGraphListener jobGraphListener)
Starts the
SubmittedJobGraphStore service. |
void |
stop()
Stops the
SubmittedJobGraphStore service. |
public void start(SubmittedJobGraphStore.SubmittedJobGraphListener jobGraphListener) throws Exception
SubmittedJobGraphStore
SubmittedJobGraphStore
service.start
in interface SubmittedJobGraphStore
Exception
public void stop()
SubmittedJobGraphStore
SubmittedJobGraphStore
service.stop
in interface SubmittedJobGraphStore
public void putJobGraph(SubmittedJobGraph jobGraph) throws Exception
SubmittedJobGraphStore
SubmittedJobGraph
instance.
If a job graph with the same JobID
exists, it is replaced.
putJobGraph
in interface SubmittedJobGraphStore
Exception
public void removeJobGraph(JobID jobId) throws Exception
SubmittedJobGraphStore
SubmittedJobGraph
with the given JobID
if it exists.removeJobGraph
in interface SubmittedJobGraphStore
Exception
public Collection<JobID> getJobIds() throws Exception
SubmittedJobGraphStore
getJobIds
in interface SubmittedJobGraphStore
Exception
- if the operation failspublic SubmittedJobGraph recoverJobGraph(JobID jobId) throws Exception
SubmittedJobGraphStore
SubmittedJobGraph
with the given JobID
.
An Exception is thrown, if no job graph with the given ID exists.
recoverJobGraph
in interface SubmittedJobGraphStore
Exception
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.