org.apache.flink.runtime.highavailability.nonha.standalone

Class StandaloneRunningJobsRegistry

java.lang.Object

org.apache.flink.runtime.highavailability.nonha.standalone.StandaloneRunningJobsRegistry

All Implemented Interfaces:

RunningJobsRegistry

public class StandaloneRunningJobsRegistry
extends Object
implements RunningJobsRegistry

A registry for running jobs, not-highly available.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.highavailability.RunningJobsRegistry

RunningJobsRegistry.JobSchedulingStatus

Constructor Summary

Constructors

Constructor and Description
StandaloneRunningJobsRegistry()

Method Summary

Modifier and Type	Method and Description
void	clearJob(JobID jobID) Clear job state form the registry, usually called after job finish.
RunningJobsRegistry.JobSchedulingStatus	getJobSchedulingStatus(JobID jobID) Gets the scheduling status of a job.
void	setJobFinished(JobID jobID) Marks a job as completed.
void	setJobRunning(JobID jobID) Marks a job as running.

Methods inherited from class java.lang.Object

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

Constructor Detail

StandaloneRunningJobsRegistry

public StandaloneRunningJobsRegistry()

Method Detail

setJobRunning

public void setJobRunning(JobID jobID)

Description copied from interface: RunningJobsRegistry

Marks a job as running. Requesting the job's status via the RunningJobsRegistry.getJobSchedulingStatus(JobID) method will return RunningJobsRegistry.JobSchedulingStatus.RUNNING.

Specified by:

setJobRunning in interface RunningJobsRegistry

Parameters:

jobID - The id of the job.

setJobFinished

public void setJobFinished(JobID jobID)

Description copied from interface: RunningJobsRegistry

Marks a job as completed. Requesting the job's status via the RunningJobsRegistry.getJobSchedulingStatus(JobID) method will return RunningJobsRegistry.JobSchedulingStatus.DONE.

Specified by:

setJobFinished in interface RunningJobsRegistry

Parameters:

jobID - The id of the job.

getJobSchedulingStatus

public RunningJobsRegistry.JobSchedulingStatus getJobSchedulingStatus(JobID jobID)

Description copied from interface: RunningJobsRegistry

Gets the scheduling status of a job.

Specified by:

getJobSchedulingStatus in interface RunningJobsRegistry

Parameters:

jobID - The id of the job to check.

Returns:

The job scheduling status.

clearJob

public void clearJob(JobID jobID)

Description copied from interface: RunningJobsRegistry

Clear job state form the registry, usually called after job finish.

Specified by:

clearJob in interface RunningJobsRegistry

Parameters:

jobID - The id of the job to check.