public class JobStatusStore extends Object implements JobStatusListener, JobStatusProvider
Constructor and Description |
---|
JobStatusStore(long initializationTimestamp) |
Modifier and Type | Method and Description |
---|---|
JobStatus |
getState()
Returns the current
JobStatus for this execution graph. |
long |
getStatusTimestamp(JobStatus status)
Returns the timestamp for the given
JobStatus . |
void |
jobStatusChanges(JobID jobId,
JobStatus newJobStatus,
long timestamp)
This method is called whenever the status of the job changes.
|
public void jobStatusChanges(JobID jobId, JobStatus newJobStatus, long timestamp)
JobStatusListener
jobStatusChanges
in interface JobStatusListener
jobId
- The ID of the job.newJobStatus
- The status the job switched to.timestamp
- The timestamp when the status transition occurred.public JobStatus getState()
JobStatusProvider
JobStatus
for this execution graph.getState
in interface JobStatusProvider
public long getStatusTimestamp(JobStatus status)
JobStatusProvider
JobStatus
.getStatusTimestamp
in interface JobStatusProvider
status
- status for which the timestamp should be returnedCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.