org.apache.flink.runtime.checkpoint

Class CheckpointCoordinatorDeActivator

java.lang.Object

org.apache.flink.runtime.checkpoint.CheckpointCoordinatorDeActivator

All Implemented Interfaces:

JobStatusListener

public class CheckpointCoordinatorDeActivator
extends Object
implements JobStatusListener

This actor listens to changes in the JobStatus and activates or deactivates the periodic checkpoint scheduler.

Constructor Summary

Constructors

Constructor and Description
CheckpointCoordinatorDeActivator(CheckpointCoordinator coordinator, boolean allTasksOutputNonBlocking)

Method Summary

Modifier and Type	Method and Description
void	jobStatusChanges(JobID jobId, JobStatus newJobStatus, long timestamp) This method is called whenever the status of the job changes.

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckpointCoordinatorDeActivator

public CheckpointCoordinatorDeActivator(CheckpointCoordinator coordinator,
                                        boolean allTasksOutputNonBlocking)

Method Detail

jobStatusChanges

public void jobStatusChanges(JobID jobId,
                             JobStatus newJobStatus,
                             long timestamp)

Description copied from interface: JobStatusListener

This method is called whenever the status of the job changes.

Specified by:

jobStatusChanges in interface JobStatusListener

Parameters:

jobId - The ID of the job.

newJobStatus - The status the job switched to.

timestamp - The timestamp when the status transition occurred.