alluxio.master.meta

Class MetaMasterSync

java.lang.Object

alluxio.master.meta.MetaMasterSync

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@NotThreadSafe
public final class MetaMasterSync
extends Object
implements HeartbeatExecutor

If a master is detected as a standby master. It will set up its MetaMasterSync and manage its own RetryHandlingMetaMasterMasterClient which helps communicate with the leader master. When running, the standby master will send its heartbeat to the leader master. The leader 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.

Constructor Summary

Constructors

Constructor and Description
MetaMasterSync(Address masterAddress, RetryHandlingMetaMasterMasterClient masterClient) Creates a new instance of MetaMasterSync.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any resources used by the heartbeat executor.
void	heartbeat(long timeLimitMs) Heartbeats to the leader master node.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetaMasterSync

public MetaMasterSync(Address masterAddress,
                      RetryHandlingMetaMasterMasterClient masterClient)

Creates a new instance of MetaMasterSync.

Parameters:

masterAddress - the master address

masterClient - the meta master client

Method Detail

heartbeat

public void heartbeat(long timeLimitMs)

Heartbeats to the leader master node.

Specified by:

heartbeat in interface HeartbeatExecutor

Parameters:

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

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