public class MasterWorkerInfo extends Object
Modifier and Type | Field and Description |
---|---|
InetSocketAddress |
ADDRESS |
Constructor and Description |
---|
MasterWorkerInfo(long id,
InetSocketAddress address,
long capacityBytes) |
Modifier and Type | Method and Description |
---|---|
ClientWorkerInfo |
generateClientWorkerInfo() |
InetSocketAddress |
getAddress() |
long |
getAvailableBytes() |
Set<Long> |
getBlocks()
Get all blocks in the worker's memory.
|
long |
getCapacityBytes() |
long |
getId() |
long |
getLastUpdatedTimeMs() |
List<Long> |
getToRemovedBlocks()
Get all blocks in the worker's memory need to be removed.
|
long |
getUsedBytes() |
String |
toString() |
void |
updateBlock(boolean add,
long blockId) |
void |
updateBlocks(boolean add,
Collection<Long> blockIds) |
void |
updateLastUpdatedTimeMs() |
void |
updateToRemovedBlock(boolean add,
long blockId) |
void |
updateToRemovedBlocks(boolean add,
Collection<Long> blockIds) |
void |
updateUsedBytes(long usedBytes) |
public final InetSocketAddress ADDRESS
public MasterWorkerInfo(long id, InetSocketAddress address, long capacityBytes)
public ClientWorkerInfo generateClientWorkerInfo()
public InetSocketAddress getAddress()
public long getAvailableBytes()
public Set<Long> getBlocks()
public long getCapacityBytes()
public long getId()
public long getLastUpdatedTimeMs()
public List<Long> getToRemovedBlocks()
public long getUsedBytes()
public void updateBlock(boolean add, long blockId)
public void updateBlocks(boolean add, Collection<Long> blockIds)
public void updateLastUpdatedTimeMs()
public void updateToRemovedBlock(boolean add, long blockId)
public void updateToRemovedBlocks(boolean add, Collection<Long> blockIds)
public void updateUsedBytes(long usedBytes)
Copyright © 2014. All rights reserved.