org.apache.flink.runtime.heartbeat

Class DefaultHeartbeatMonitor<O>

java.lang.Object

org.apache.flink.runtime.heartbeat.DefaultHeartbeatMonitor<O>

Type Parameters:

O - Type of the payload being sent to the associated heartbeat target

All Implemented Interfaces:

Runnable, HeartbeatMonitor<O>

public class DefaultHeartbeatMonitor<O>
extends Object
implements HeartbeatMonitor<O>, Runnable

The default implementation of HeartbeatMonitor.

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancel this monitor.
HeartbeatTarget<O>	getHeartbeatTarget() Gets heartbeat target.
ResourceID	getHeartbeatTargetId() Gets heartbeat target id.
long	getLastHeartbeat() Gets the last heartbeat.
boolean	isCanceled()
void	reportHeartbeat() Report heartbeat from the monitored target.
void	reportHeartbeatRpcFailure() Reports that the heartbeat rpc could not be sent to the target.
void	reportHeartbeatRpcSuccess() Reports that the heartbeat rpc could be sent to the target.
void	run()

Methods inherited from class java.lang.Object

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

Method Detail

getHeartbeatTarget

public HeartbeatTarget<O> getHeartbeatTarget()

Description copied from interface: HeartbeatMonitor

Gets heartbeat target.

Specified by:

getHeartbeatTarget in interface HeartbeatMonitor<O>

Returns:

the heartbeat target

getHeartbeatTargetId

public ResourceID getHeartbeatTargetId()

Description copied from interface: HeartbeatMonitor

Gets heartbeat target id.

Specified by:

getHeartbeatTargetId in interface HeartbeatMonitor<O>

Returns:

the heartbeat target id

getLastHeartbeat

public long getLastHeartbeat()

Description copied from interface: HeartbeatMonitor

Gets the last heartbeat.

Specified by:

getLastHeartbeat in interface HeartbeatMonitor<O>

Returns:

the last heartbeat

reportHeartbeatRpcFailure

public void reportHeartbeatRpcFailure()

Description copied from interface: HeartbeatMonitor

Reports that the heartbeat rpc could not be sent to the target.

Specified by:

reportHeartbeatRpcFailure in interface HeartbeatMonitor<O>

reportHeartbeatRpcSuccess

public void reportHeartbeatRpcSuccess()

Description copied from interface: HeartbeatMonitor

Reports that the heartbeat rpc could be sent to the target.

Specified by:

reportHeartbeatRpcSuccess in interface HeartbeatMonitor<O>

reportHeartbeat

public void reportHeartbeat()

Description copied from interface: HeartbeatMonitor

Report heartbeat from the monitored target.

Specified by:

reportHeartbeat in interface HeartbeatMonitor<O>

cancel

public void cancel()

Description copied from interface: HeartbeatMonitor

Cancel this monitor.

Specified by:

cancel in interface HeartbeatMonitor<O>

run

public void run()

Specified by:

run in interface Runnable

isCanceled

public boolean isCanceled()