alluxio.worker.block

Class AllMasterRegistrationBlockWorker

java.lang.Object

alluxio.worker.AbstractWorker

alluxio.worker.block.DefaultBlockWorker

alluxio.worker.block.AllMasterRegistrationBlockWorker

All Implemented Interfaces:

Server<WorkerNetAddress>, BlockWorker, SessionCleanable, Worker

@NotThreadSafe
public class AllMasterRegistrationBlockWorker
extends DefaultBlockWorker

The class is responsible for managing all top level components of BlockWorker. This block worker implementation register workers to all masters.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.worker.block.DefaultBlockWorker

DefaultBlockWorker.Metrics, DefaultBlockWorker.StorageChecker

Field Summary

Fields inherited from class alluxio.worker.block.DefaultBlockWorker

mAddress, mBlockStore, mFileSystemMasterClient, mResourceCloser, mWorkerId

Constructor Summary

Constructors

Constructor and Description
AllMasterRegistrationBlockWorker(BlockMasterClientPool blockMasterClientPool, FileSystemMasterClient fileSystemMasterClient, Sessions sessions, BlockStore blockStore, AtomicReference<Long> workerId) Constructs a block worker when workers register to all masters.

Method Summary

Modifier and Type	Method and Description
BlockSyncMasterGroup	getBlockSyncMasterGroup()
protected void	setupBlockMasterSync()
void	start(WorkerNetAddress address) Runs the block worker.

Methods inherited from class alluxio.worker.block.DefaultBlockWorker

abortBlock, askForWorkerId, asyncCache, cache, cleanupSession, clearMetrics, commitBlock, commitBlockInUfs, createBlock, createBlockReader, createBlockWriter, createUfsBlockReader, freeWorker, getBlockStore, getConfiguration, getDependencies, getFileInfo, getName, getReport, getServices, getStoreMeta, getStoreMetaFull, getWhiteList, getWorkerAddress, getWorkerId, load, removeBlock, requestSpace, stop, updatePinList

Methods inherited from class alluxio.worker.AbstractWorker

close, getExecutorService

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.Server

close

Constructor Detail

AllMasterRegistrationBlockWorker

public AllMasterRegistrationBlockWorker(BlockMasterClientPool blockMasterClientPool,
                                        FileSystemMasterClient fileSystemMasterClient,
                                        Sessions sessions,
                                        BlockStore blockStore,
                                        AtomicReference<Long> workerId)

Constructs a block worker when workers register to all masters.

Parameters:

blockMasterClientPool - a client pool for talking to the block master

fileSystemMasterClient - a client for talking to the file system master

sessions - an object for tracking and cleaning up client sessions

blockStore - an Alluxio block store

workerId - worker id

Method Detail

setupBlockMasterSync

protected void setupBlockMasterSync()

Overrides:

setupBlockMasterSync in class DefaultBlockWorker

start

public void start(WorkerNetAddress address)
           throws IOException

Description copied from class: DefaultBlockWorker

Runs the block worker. The thread must be called after all services (e.g., web, dataserver) started. BlockWorker doesn't support being restarted!

Specified by:

start in interface Server<WorkerNetAddress>

Overrides:

start in class DefaultBlockWorker

Parameters:

address - the start options

Throws:

IOException

getBlockSyncMasterGroup

public BlockSyncMasterGroup getBlockSyncMasterGroup()

Returns:

the block sync master group