alluxio.worker.block

Class BlockSyncMasterGroup

java.lang.Object

alluxio.worker.block.BlockSyncMasterGroup

All Implemented Interfaces:

Closeable, AutoCloseable

public class BlockSyncMasterGroup
extends Object
implements Closeable

An abstraction layer that manages the worker heartbeats with multiple block masters. This is only active when worker.register.to.all.masters=true.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockSyncMasterGroup.Factory The factory class.

Constructor Summary

Constructors

Constructor and Description
BlockSyncMasterGroup(List<InetSocketAddress> masterAddresses, BlockWorker blockWorker) Creates a block sync master group.

Method Summary

Modifier and Type	Method and Description
void	close()
Map<InetSocketAddress,SpecificMasterBlockSync>	getMasterSyncOperators()
boolean	isRegisteredToAllMasters()
void	start(ExecutorService executorService) Starts the heartbeats.
void	waitForPrimaryMasterRegistrationComplete(InetSocketAddress primaryMasterAddress) Waits until the primary master registration completes.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockSyncMasterGroup

public BlockSyncMasterGroup(List<InetSocketAddress> masterAddresses,
                            BlockWorker blockWorker)
                     throws IOException

Creates a block sync master group.

Parameters:

masterAddresses - the master addresses to sync

blockWorker - the block worker instance

Throws:

IOException

Method Detail

start

public void start(ExecutorService executorService)

Starts the heartbeats.

Parameters:

executorService - the executor service to run the heartbeats

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

waitForPrimaryMasterRegistrationComplete

public void waitForPrimaryMasterRegistrationComplete(InetSocketAddress primaryMasterAddress)

Waits until the primary master registration completes.

Parameters:

primaryMasterAddress - the primary master address

isRegisteredToAllMasters

public boolean isRegisteredToAllMasters()

Returns:

if the worker is registered to all masters

getMasterSyncOperators

public Map<InetSocketAddress,SpecificMasterBlockSync> getMasterSyncOperators()

Returns:

the master sync operators