Package | Description |
---|---|
alluxio.master.block | |
alluxio.thrift | |
alluxio.worker.block |
Modifier and Type | Method and Description |
---|---|
Command |
DefaultBlockMaster.workerHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
List<Metric> metrics) |
Command |
BlockMaster.workerHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
List<Metric> metrics)
Updates metadata when a worker periodically heartbeats with the master.
|
Modifier and Type | Method and Description |
---|---|
Command |
Command.deepCopy() |
Command |
BlockHeartbeatTResponse.getCommand() |
Command |
Command.setCommandType(CommandType commandType) |
Command |
Command.setData(List<Long> data) |
Modifier and Type | Method and Description |
---|---|
int |
Command.compareTo(Command other) |
boolean |
Command.equals(Command that) |
BlockHeartbeatTResponse |
BlockHeartbeatTResponse.setCommand(Command command) |
Constructor and Description |
---|
BlockHeartbeatTResponse(Command command) |
Command(Command other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
Command |
BlockMasterClient.heartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlocks,
Map<String,List<Long>> addedBlocks,
List<Metric> metrics)
The method the worker should periodically execute to heartbeat back to the master.
|
Copyright © 2023. All Rights Reserved.