alluxio.worker.block

Class BlockMasterSync

java.lang.Object

alluxio.worker.block.BlockMasterSync

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@NotThreadSafe
public final class BlockMasterSync
extends Object
implements HeartbeatExecutor

Task that carries out the necessary block worker to master communications, including register and heartbeat. This class manages its own BlockMasterClient. When running, this task first requests a block report from the BlockWorker, then sends it to the master. The master may respond to the heartbeat with a command which will be executed. After which, the task will wait for the elapsed time since its last heartbeat has reached the heartbeat interval. Then the cycle will continue. If the task fails to heartbeat to the master, it will destroy its old master client and recreate it before retrying.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any resources used by the heartbeat executor.
void	heartbeat() Heartbeats to the master node about the change in the worker's managed space.

Methods inherited from class java.lang.Object

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

Method Detail

heartbeat

public void heartbeat()

Heartbeats to the master node about the change in the worker's managed space.

Specified by:

heartbeat in interface HeartbeatExecutor

close

public void close()

Description copied from interface: HeartbeatExecutor

Cleans up any resources used by the heartbeat executor.

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable