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.

Constructor Summary

Constructors

Constructor and Description
BlockMasterSync(BlockWorker blockWorker, AtomicReference<Long> workerId, WorkerNetAddress workerAddress, BlockMasterClientPool masterClientPool) Creates a new instance of BlockMasterSync.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any resources used by the heartbeat executor.
static RetryPolicy	getDefaultAcquireLeaseRetryPolicy() Gets the default retry policy for acquiring a RegisterLease from the BlockMaster.
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

Constructor Detail

BlockMasterSync

public BlockMasterSync(BlockWorker blockWorker,
                       AtomicReference<Long> workerId,
                       WorkerNetAddress workerAddress,
                       BlockMasterClientPool masterClientPool)
                throws IOException

Creates a new instance of BlockMasterSync.

Parameters:

blockWorker - the BlockWorker this syncer is updating to

workerId - the worker id of the worker, assigned by the block master

workerAddress - the net address of the worker

masterClientPool - the Alluxio master client pool

Throws:

IOException

Method Detail

getDefaultAcquireLeaseRetryPolicy

public static RetryPolicy getDefaultAcquireLeaseRetryPolicy()

Gets the default retry policy for acquiring a RegisterLease from the BlockMaster.

Returns:

the policy to use

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