Package | Description |
---|---|
alluxio.master.block | |
alluxio.thrift |
Modifier and Type | Method and Description |
---|---|
BlockHeartbeatTResponse |
BlockMasterWorkerServiceHandler.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options) |
Modifier and Type | Method and Description |
---|---|
BlockHeartbeatTResponse |
BlockMasterWorkerService.Iface.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options)
Periodic block worker heartbeat returns an optional command for the block worker to execute.
|
BlockHeartbeatTResponse |
BlockMasterWorkerService.Client.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options) |
BlockHeartbeatTResponse |
BlockHeartbeatTResponse.deepCopy() |
BlockHeartbeatTResponse |
BlockMasterWorkerService.AsyncClient.blockHeartbeat_call.getResult() |
BlockHeartbeatTResponse |
BlockMasterWorkerService.blockHeartbeat_result.getSuccess() |
BlockHeartbeatTResponse |
BlockMasterWorkerService.Client.recv_blockHeartbeat() |
BlockHeartbeatTResponse |
BlockHeartbeatTResponse.setCommand(Command command) |
Modifier and Type | Method and Description |
---|---|
org.apache.thrift.async.AsyncMethodCallback<BlockHeartbeatTResponse> |
BlockMasterWorkerService.AsyncProcessor.blockHeartbeat.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
Modifier and Type | Method and Description |
---|---|
int |
BlockHeartbeatTResponse.compareTo(BlockHeartbeatTResponse other) |
boolean |
BlockHeartbeatTResponse.equals(BlockHeartbeatTResponse that) |
BlockMasterWorkerService.blockHeartbeat_result |
BlockMasterWorkerService.blockHeartbeat_result.setSuccess(BlockHeartbeatTResponse success) |
Modifier and Type | Method and Description |
---|---|
void |
BlockMasterWorkerService.AsyncProcessor.blockHeartbeat.start(I iface,
BlockMasterWorkerService.blockHeartbeat_args args,
org.apache.thrift.async.AsyncMethodCallback<BlockHeartbeatTResponse> resultHandler) |
Constructor and Description |
---|
blockHeartbeat_result(BlockHeartbeatTResponse success,
AlluxioTException e) |
BlockHeartbeatTResponse(BlockHeartbeatTResponse other)
Performs a deep copy on other.
|
Copyright © 2023. All Rights Reserved.