alluxio.heartbeat

Interface HeartbeatExecutor

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

CommandHandlingExecutor, ConfigHashSync, DefaultBlockMaster.LostWorkerDetectionHeartbeatExecutor, DefaultBlockMaster.WorkerRegisterStreamGCExecutor, JobMasterSync, JournalSpaceMonitor, MetaMasterSync, ProxyMasterSync, UpdateChecker, UpdateChecker

public interface HeartbeatExecutor
extends Closeable

An interface for a heartbeat execution. The HeartbeatThread calls the heartbeat(long) method.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any resources used by the heartbeat executor.
void	heartbeat(long timeLimitMs) Implements the heartbeat logic.

Method Detail

heartbeat

void heartbeat(long timeLimitMs)
        throws InterruptedException

Implements the heartbeat logic.

Parameters:

timeLimitMs - time limit in milliseconds this heartbeat should not exceed when running

Throws:

InterruptedException - if the thread is interrupted

close

void close()

Cleans up any resources used by the heartbeat executor.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable