alluxio.thrift

Class BlockMasterWorkerService.blockHeartbeat_args

java.lang.Object

alluxio.thrift.BlockMasterWorkerService.blockHeartbeat_args

All Implemented Interfaces:

Serializable, Cloneable, Comparable<BlockMasterWorkerService.blockHeartbeat_args>, org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

Enclosing class:

BlockMasterWorkerService

public static class BlockMasterWorkerService.blockHeartbeat_args
extends Object
implements org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>, Serializable, Cloneable, Comparable<BlockMasterWorkerService.blockHeartbeat_args>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockMasterWorkerService.blockHeartbeat_args._Fields The set of fields this struct contains, along with convenience methods for finding and manipulating them.

Field Summary

Fields

Modifier and Type	Field and Description
static Map<BlockMasterWorkerService.blockHeartbeat_args._Fields,org.apache.thrift.meta_data.FieldMetaData>	metaDataMap

Constructor Summary

Constructors

Constructor and Description
blockHeartbeat_args()
blockHeartbeat_args(BlockMasterWorkerService.blockHeartbeat_args other) Performs a deep copy on other.
blockHeartbeat_args(long workerId, Map<String,Long> usedBytesOnTiers, List<Long> removedBlockIds, Map<String,List<Long>> addedBlocksOnTiers, BlockHeartbeatTOptions options)

Method Summary

Modifier and Type	Method and Description
void	addToRemovedBlockIds(long elem)
void	clear()
int	compareTo(BlockMasterWorkerService.blockHeartbeat_args other)
BlockMasterWorkerService.blockHeartbeat_args	deepCopy()
boolean	equals(BlockMasterWorkerService.blockHeartbeat_args that)
boolean	equals(Object that)
BlockMasterWorkerService.blockHeartbeat_args._Fields	fieldForId(int fieldId)
Map<String,List<Long>>	getAddedBlocksOnTiers() the map of added blocks on all tiers
int	getAddedBlocksOnTiersSize()
Object	getFieldValue(BlockMasterWorkerService.blockHeartbeat_args._Fields field)
BlockHeartbeatTOptions	getOptions() the method options
List<Long>	getRemovedBlockIds() the list of removed block ids
Iterator<Long>	getRemovedBlockIdsIterator()
int	getRemovedBlockIdsSize()
Map<String,Long>	getUsedBytesOnTiers() the map of space used in bytes on all tiers
int	getUsedBytesOnTiersSize()
long	getWorkerId() the id of the worker
int	hashCode()
boolean	isSet(BlockMasterWorkerService.blockHeartbeat_args._Fields field) Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
boolean	isSetAddedBlocksOnTiers() Returns true if field addedBlocksOnTiers is set (has been assigned a value) and false otherwise
boolean	isSetOptions() Returns true if field options is set (has been assigned a value) and false otherwise
boolean	isSetRemovedBlockIds() Returns true if field removedBlockIds is set (has been assigned a value) and false otherwise
boolean	isSetUsedBytesOnTiers() Returns true if field usedBytesOnTiers is set (has been assigned a value) and false otherwise
boolean	isSetWorkerId() Returns true if field workerId is set (has been assigned a value) and false otherwise
void	putToAddedBlocksOnTiers(String key, List<Long> val)
void	putToUsedBytesOnTiers(String key, long val)
void	read(org.apache.thrift.protocol.TProtocol iprot)
BlockMasterWorkerService.blockHeartbeat_args	setAddedBlocksOnTiers(Map<String,List<Long>> addedBlocksOnTiers) the map of added blocks on all tiers
void	setAddedBlocksOnTiersIsSet(boolean value)
void	setFieldValue(BlockMasterWorkerService.blockHeartbeat_args._Fields field, Object value)
BlockMasterWorkerService.blockHeartbeat_args	setOptions(BlockHeartbeatTOptions options) the method options
void	setOptionsIsSet(boolean value)
BlockMasterWorkerService.blockHeartbeat_args	setRemovedBlockIds(List<Long> removedBlockIds) the list of removed block ids
void	setRemovedBlockIdsIsSet(boolean value)
BlockMasterWorkerService.blockHeartbeat_args	setUsedBytesOnTiers(Map<String,Long> usedBytesOnTiers) the map of space used in bytes on all tiers
void	setUsedBytesOnTiersIsSet(boolean value)
BlockMasterWorkerService.blockHeartbeat_args	setWorkerId(long workerId) the id of the worker
void	setWorkerIdIsSet(boolean value)
String	toString()
void	unsetAddedBlocksOnTiers()
void	unsetOptions()
void	unsetRemovedBlockIds()
void	unsetUsedBytesOnTiers()
void	unsetWorkerId()
void	validate()
void	write(org.apache.thrift.protocol.TProtocol oprot)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

metaDataMap

public static final Map<BlockMasterWorkerService.blockHeartbeat_args._Fields,org.apache.thrift.meta_data.FieldMetaData> metaDataMap

Constructor Detail

blockHeartbeat_args

public blockHeartbeat_args()

blockHeartbeat_args

public blockHeartbeat_args(long workerId,
                           Map<String,Long> usedBytesOnTiers,
                           List<Long> removedBlockIds,
                           Map<String,List<Long>> addedBlocksOnTiers,
                           BlockHeartbeatTOptions options)

blockHeartbeat_args

public blockHeartbeat_args(BlockMasterWorkerService.blockHeartbeat_args other)

Performs a deep copy on other.

Method Detail

deepCopy

public BlockMasterWorkerService.blockHeartbeat_args deepCopy()

Specified by:

deepCopy in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

clear

public void clear()

Specified by:

clear in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

getWorkerId

public long getWorkerId()

the id of the worker

setWorkerId

public BlockMasterWorkerService.blockHeartbeat_args setWorkerId(long workerId)

the id of the worker

unsetWorkerId

public void unsetWorkerId()

isSetWorkerId

public boolean isSetWorkerId()

Returns true if field workerId is set (has been assigned a value) and false otherwise

setWorkerIdIsSet

public void setWorkerIdIsSet(boolean value)

getUsedBytesOnTiersSize

public int getUsedBytesOnTiersSize()

putToUsedBytesOnTiers

public void putToUsedBytesOnTiers(String key,
                                  long val)

getUsedBytesOnTiers

public Map<String,Long> getUsedBytesOnTiers()

the map of space used in bytes on all tiers

setUsedBytesOnTiers

public BlockMasterWorkerService.blockHeartbeat_args setUsedBytesOnTiers(Map<String,Long> usedBytesOnTiers)

the map of space used in bytes on all tiers

unsetUsedBytesOnTiers

public void unsetUsedBytesOnTiers()

isSetUsedBytesOnTiers

public boolean isSetUsedBytesOnTiers()

Returns true if field usedBytesOnTiers is set (has been assigned a value) and false otherwise

setUsedBytesOnTiersIsSet

public void setUsedBytesOnTiersIsSet(boolean value)

getRemovedBlockIdsSize

public int getRemovedBlockIdsSize()

getRemovedBlockIdsIterator

public Iterator<Long> getRemovedBlockIdsIterator()

addToRemovedBlockIds

public void addToRemovedBlockIds(long elem)

getRemovedBlockIds

public List<Long> getRemovedBlockIds()

the list of removed block ids

setRemovedBlockIds

public BlockMasterWorkerService.blockHeartbeat_args setRemovedBlockIds(List<Long> removedBlockIds)

the list of removed block ids

unsetRemovedBlockIds

public void unsetRemovedBlockIds()

isSetRemovedBlockIds

public boolean isSetRemovedBlockIds()

Returns true if field removedBlockIds is set (has been assigned a value) and false otherwise

setRemovedBlockIdsIsSet

public void setRemovedBlockIdsIsSet(boolean value)

getAddedBlocksOnTiersSize

public int getAddedBlocksOnTiersSize()

putToAddedBlocksOnTiers

public void putToAddedBlocksOnTiers(String key,
                                    List<Long> val)

getAddedBlocksOnTiers

public Map<String,List<Long>> getAddedBlocksOnTiers()

the map of added blocks on all tiers

setAddedBlocksOnTiers

public BlockMasterWorkerService.blockHeartbeat_args setAddedBlocksOnTiers(Map<String,List<Long>> addedBlocksOnTiers)

the map of added blocks on all tiers

unsetAddedBlocksOnTiers

public void unsetAddedBlocksOnTiers()

isSetAddedBlocksOnTiers

public boolean isSetAddedBlocksOnTiers()

Returns true if field addedBlocksOnTiers is set (has been assigned a value) and false otherwise

setAddedBlocksOnTiersIsSet

public void setAddedBlocksOnTiersIsSet(boolean value)

getOptions

public BlockHeartbeatTOptions getOptions()

the method options

setOptions

public BlockMasterWorkerService.blockHeartbeat_args setOptions(BlockHeartbeatTOptions options)

the method options

unsetOptions

public void unsetOptions()

isSetOptions

public boolean isSetOptions()

Returns true if field options is set (has been assigned a value) and false otherwise

setOptionsIsSet

public void setOptionsIsSet(boolean value)

setFieldValue

public void setFieldValue(BlockMasterWorkerService.blockHeartbeat_args._Fields field,
                          Object value)

Specified by:

setFieldValue in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

getFieldValue

public Object getFieldValue(BlockMasterWorkerService.blockHeartbeat_args._Fields field)

Specified by:

getFieldValue in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

isSet

public boolean isSet(BlockMasterWorkerService.blockHeartbeat_args._Fields field)

Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise

Specified by:

isSet in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

equals

public boolean equals(Object that)

Overrides:

equals in class Object

equals

public boolean equals(BlockMasterWorkerService.blockHeartbeat_args that)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

compareTo

public int compareTo(BlockMasterWorkerService.blockHeartbeat_args other)

Specified by:

compareTo in interface Comparable<BlockMasterWorkerService.blockHeartbeat_args>

fieldForId

public BlockMasterWorkerService.blockHeartbeat_args._Fields fieldForId(int fieldId)

Specified by:

fieldForId in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

read

public void read(org.apache.thrift.protocol.TProtocol iprot)
          throws org.apache.thrift.TException

Specified by:

read in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

Throws:

org.apache.thrift.TException

write

public void write(org.apache.thrift.protocol.TProtocol oprot)
           throws org.apache.thrift.TException

Specified by:

write in interface org.apache.thrift.TBase<BlockMasterWorkerService.blockHeartbeat_args,BlockMasterWorkerService.blockHeartbeat_args._Fields>

Throws:

org.apache.thrift.TException

toString

public String toString()

Overrides:

toString in class Object

validate

public void validate()
              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException