org.apache.flink.runtime.highavailability.zookeeper

Class ZooKeeperRunningJobsRegistry

java.lang.Object

org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRunningJobsRegistry

All Implemented Interfaces:

RunningJobsRegistry

public class ZooKeeperRunningJobsRegistry
extends Object
implements RunningJobsRegistry

A zookeeper based registry for running jobs, 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
ZooKeeperRunningJobsRegistry(org.apache.curator.framework.CuratorFramework client, Configuration configuration)

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

ZooKeeperRunningJobsRegistry

public ZooKeeperRunningJobsRegistry(org.apache.curator.framework.CuratorFramework client,
                                    Configuration configuration)

Method Detail

setJobRunning

public void setJobRunning(JobID jobID)
                   throws IOException

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.

Throws:

IOException - Thrown when the communication with the highly-available storage or registry failed and could not be retried.

setJobFinished

public void setJobFinished(JobID jobID)
                    throws IOException

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.

Throws:

IOException - Thrown when the communication with the highly-available storage or registry failed and could not be retried.

getJobSchedulingStatus

public RunningJobsRegistry.JobSchedulingStatus getJobSchedulingStatus(JobID jobID)
                                                               throws IOException

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.

Throws:

IOException - Thrown when the communication with the highly-available storage or registry failed and could not be retried.

clearJob

public void clearJob(JobID jobID)
              throws IOException

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.

Throws:

IOException - Thrown when the communication with the highly-available storage or registry failed and could not be retried.