alluxio.master.meta

Class JobMasterSync

java.lang.Object

alluxio.master.meta.JobMasterSync

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@NotThreadSafe
public final class JobMasterSync
extends Object
implements HeartbeatExecutor

If a job master is detected as a standby job master. It will set up its JobMasterSync and use its RetryHandlingMetaMasterMasterClient to register to the primary job master, then maintain a heartbeat with the primary.

Constructor Summary

Constructors

Constructor and Description
JobMasterSync(Address masterAddress, RetryHandlingJobMasterMasterClient 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 timeout) 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

JobMasterSync

public JobMasterSync(Address masterAddress,
                     RetryHandlingJobMasterMasterClient masterClient)

Creates a new instance of MetaMasterSync.

Parameters:

masterAddress - the master address

masterClient - the meta master client

Method Detail

heartbeat

public void heartbeat(long timeout)

Heartbeats to the leader master node.

Specified by:

heartbeat in interface HeartbeatExecutor

Parameters:

timeout - 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