alluxio.master.block.meta

Class MasterBlockInfo

java.lang.Object

alluxio.master.block.meta.MasterBlockInfo

@NotThreadSafe
public final class MasterBlockInfo
extends Object

The metadata for an Alluxio block, managed by the block master. This class is not thread safe, so external locking is required.

Constructor Summary

Constructors

Constructor and Description
MasterBlockInfo(long blockId, long length) Creates a new instance of MasterBlockInfo.

Method Summary

Modifier and Type	Method and Description
void	addWorker(long workerId, String tierAlias) Adds a location of the block.
long	getBlockId()
List<MasterBlockLocation>	getBlockLocations() Gets the net addresses for all workers which have the block's data in their tiered storage.
long	getLength()
int	getNumLocations()
Set<Long>	getWorkers()
boolean	isInTier(String targetTierAlias)
void	removeWorker(long workerId) Removes the worker from the locations of this block.
String	toString()
void	updateLength(long length) Updates the length, if and only if the length was previously unknown.

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterBlockInfo

public MasterBlockInfo(long blockId,
                       long length)

Creates a new instance of MasterBlockInfo.

Parameters:

blockId - the block id to use

length - the block length in bytes to use

Method Detail

getLength

public long getLength()

Returns:

the length of the block

updateLength

public void updateLength(long length)

Updates the length, if and only if the length was previously unknown.

Parameters:

length - the updated length

getBlockId

public long getBlockId()

Returns:

the block id

addWorker

public void addWorker(long workerId,
                      String tierAlias)

Adds a location of the block. It means that the worker has the block in one of its tiers.

Parameters:

workerId - the id of the worker

tierAlias - the alias of the storage tier that this block is on

removeWorker

public void removeWorker(long workerId)

Removes the worker from the locations of this block.

Parameters:

workerId - the worker id to remove

getWorkers

public Set<Long> getWorkers()

Returns:

all the worker ids that this block is on

getNumLocations

public int getNumLocations()

Returns:

the number of workers this block is on

getBlockLocations

public List<MasterBlockLocation> getBlockLocations()

Gets the net addresses for all workers which have the block's data in their tiered storage.

Returns:

the net addresses of the workers

isInTier

public boolean isInTier(String targetTierAlias)

Parameters:

targetTierAlias - the tier alias to target

Returns:

true if the block is in the given tier

toString

public String toString()

Overrides:

toString in class Object