public interface SubmittedJobGraphStore
SubmittedJobGraph
instances for recovery.Modifier and Type | Interface and Description |
---|---|
static interface |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
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. |
void start(SubmittedJobGraphStore.SubmittedJobGraphListener jobGraphListener) throws Exception
SubmittedJobGraphStore
service.Exception
void stop() throws Exception
SubmittedJobGraphStore
service.Exception
SubmittedJobGraph recoverJobGraph(JobID jobId) throws Exception
SubmittedJobGraph
with the given JobID
.
An Exception is thrown, if no job graph with the given ID exists.
Exception
void putJobGraph(SubmittedJobGraph jobGraph) throws Exception
SubmittedJobGraph
instance.
If a job graph with the same JobID
exists, it is replaced.
Exception
void removeJobGraph(JobID jobId) throws Exception
SubmittedJobGraph
with the given JobID
if it exists.Exception
Collection<JobID> getJobIds() throws Exception
Exception
- if the operation failsCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.