alluxio.master.block.meta

Class MasterWorkerInfo

java.lang.Object

alluxio.master.block.meta.MasterWorkerInfo

@NotThreadSafe
public final class MasterWorkerInfo
extends Object

Metadata for an Alluxio worker. This class is not thread safe, so external locking is required.

Constructor Summary

Constructors

Constructor and Description
MasterWorkerInfo(long id, WorkerNetAddress address) Creates a new instance of MasterWorkerInfo.

Method Summary

Modifier and Type	Method and Description
void	addBlock(long blockId) Adds a block to the worker.
void	addLostStorage(Map<String,StorageList> lostStorage) Adds new worker lost storage paths.
void	addLostStorage(String tierAlias, String dirPath) Adds a new worker lost storage path.
WorkerInfo	generateWorkerInfo(Set<GetWorkerReportOptions.WorkerInfoField> fieldRange, boolean isLiveWorker) Gets the selected field information for this worker.
long	getAvailableBytes()
Set<Long>	getBlocks()
long	getCapacityBytes()
Map<String,Long>	getFreeBytesOnTiers()
long	getId()
long	getLastUpdatedTimeMs()
Map<String,List<String>>	getLostStorage()
long	getStartTime()
StorageTierAssoc	getStorageTierAssoc()
List<Long>	getToRemoveBlocks()
Map<String,Long>	getTotalBytesOnTiers()
long	getUsedBytes()
Map<String,Long>	getUsedBytesOnTiers()
WorkerNetAddress	getWorkerAddress()
boolean	hasLostStorage()
boolean	isRegistered()
Set<Long>	register(StorageTierAssoc globalStorageTierAssoc, List<String> storageTierAliases, Map<String,Long> totalBytesOnTiers, Map<String,Long> usedBytesOnTiers, Set<Long> blocks) Marks the worker as registered, while updating all of its metadata.
void	removeBlock(long blockId) Removes a block from the worker.
String	toString()
void	updateCapacityBytes(Map<String,Long> capacityBytesOnTiers) Sets the capacity of the worker in bytes.
void	updateLastUpdatedTimeMs() Updates the last updated time of the worker in ms.
void	updateToRemovedBlock(boolean add, long blockId) Adds or removes a block from the to-be-removed blocks set of the worker.
void	updateUsedBytes(Map<String,Long> usedBytesOnTiers) Sets the used space of the worker in bytes.
void	updateUsedBytes(String tierAlias, long usedBytesOnTier) Sets the used space of the worker in bytes.

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterWorkerInfo

public MasterWorkerInfo(long id,
                        WorkerNetAddress address)

Creates a new instance of MasterWorkerInfo.

Parameters:

id - the worker id to use

address - the worker address to use

Method Detail

register

public Set<Long> register(StorageTierAssoc globalStorageTierAssoc,
                          List<String> storageTierAliases,
                          Map<String,Long> totalBytesOnTiers,
                          Map<String,Long> usedBytesOnTiers,
                          Set<Long> blocks)

Marks the worker as registered, while updating all of its metadata.

Parameters:

globalStorageTierAssoc - global mapping between storage aliases and ordinal position

storageTierAliases - list of storage tier aliases in order of their position in the hierarchy

totalBytesOnTiers - mapping from storage tier alias to total bytes

usedBytesOnTiers - mapping from storage tier alias to used byes

blocks - set of block ids on this worker

Returns:

A Set of blocks removed (or lost) from this worker

addBlock

public void addBlock(long blockId)

Adds a block to the worker.

Parameters:

blockId - the id of the block to be added

removeBlock

public void removeBlock(long blockId)

Removes a block from the worker.

Parameters:

blockId - the id of the block to be removed

addLostStorage

public void addLostStorage(String tierAlias,
                           String dirPath)

Adds a new worker lost storage path.

Parameters:

tierAlias - the tier alias

dirPath - the lost storage path

addLostStorage

public void addLostStorage(Map<String,StorageList> lostStorage)

Adds new worker lost storage paths.

Parameters:

lostStorage - the lost storage to add

generateWorkerInfo

public WorkerInfo generateWorkerInfo(Set<GetWorkerReportOptions.WorkerInfoField> fieldRange,
                                     boolean isLiveWorker)

Gets the selected field information for this worker.

Parameters:

fieldRange - the client selected fields

isLiveWorker - the worker is live or not

Returns:

generated worker information

getWorkerAddress

public WorkerNetAddress getWorkerAddress()

Returns:

the worker's address

getAvailableBytes

public long getAvailableBytes()

Returns:

the available space of the worker in bytes

getBlocks

public Set<Long> getBlocks()

Returns:

ids of all blocks the worker contains

getCapacityBytes

public long getCapacityBytes()

Returns:

the capacity of the worker in bytes

getId

public long getId()

Returns:

the id of the worker

getLastUpdatedTimeMs

public long getLastUpdatedTimeMs()

Returns:

the last updated time of the worker in ms

getToRemoveBlocks

public List<Long> getToRemoveBlocks()

Returns:

ids of blocks the worker should remove

getUsedBytes

public long getUsedBytes()

Returns:

used space of the worker in bytes

getStorageTierAssoc

public StorageTierAssoc getStorageTierAssoc()

Returns:

the storage tier mapping for the worker

getTotalBytesOnTiers

public Map<String,Long> getTotalBytesOnTiers()

Returns:

the total bytes on each storage tier

getUsedBytesOnTiers

public Map<String,Long> getUsedBytesOnTiers()

Returns:

the used bytes on each storage tier

getStartTime

public long getStartTime()

Returns:

the start time in milliseconds

isRegistered

public boolean isRegistered()

Returns:

whether the worker has been registered yet

getFreeBytesOnTiers

public Map<String,Long> getFreeBytesOnTiers()

Returns:

the free bytes on each storage tier

getLostStorage

public Map<String,List<String>> getLostStorage()

Returns:

the map from tier alias to lost storage paths in this worker

hasLostStorage

public boolean hasLostStorage()

Returns:

true if this worker has lost storage, false otherwise

toString

public String toString()

Overrides:

toString in class Object

updateLastUpdatedTimeMs

public void updateLastUpdatedTimeMs()

Updates the last updated time of the worker in ms.

updateToRemovedBlock

public void updateToRemovedBlock(boolean add,
                                 long blockId)

Adds or removes a block from the to-be-removed blocks set of the worker.

Parameters:

add - true if to add, to remove otherwise

blockId - the id of the block to be added or removed

updateCapacityBytes

public void updateCapacityBytes(Map<String,Long> capacityBytesOnTiers)

Sets the capacity of the worker in bytes.

Parameters:

capacityBytesOnTiers - used bytes on each storage tier

updateUsedBytes

public void updateUsedBytes(Map<String,Long> usedBytesOnTiers)

Sets the used space of the worker in bytes.

Parameters:

usedBytesOnTiers - used bytes on each storage tier

updateUsedBytes

public void updateUsedBytes(String tierAlias,
                            long usedBytesOnTier)

Sets the used space of the worker in bytes.

Parameters:

tierAlias - alias of storage tier

usedBytesOnTier - used bytes on certain storage tier