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 |
---|---|
BlockHeartbeatTOptions |
BlockHeartbeatTOptions.deepCopy() |
BlockHeartbeatTOptions |
BlockMasterWorkerService.blockHeartbeat_args.getOptions()
the method options
|
BlockHeartbeatTOptions |
BlockHeartbeatTOptions.setMetrics(List<Metric> metrics) |
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) |
void |
BlockMasterWorkerService.AsyncIface.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
BlockMasterWorkerService.AsyncClient.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
int |
BlockHeartbeatTOptions.compareTo(BlockHeartbeatTOptions other) |
boolean |
BlockHeartbeatTOptions.equals(BlockHeartbeatTOptions that) |
void |
BlockMasterWorkerService.Client.send_blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options) |
BlockMasterWorkerService.blockHeartbeat_args |
BlockMasterWorkerService.blockHeartbeat_args.setOptions(BlockHeartbeatTOptions options)
the method options
|
Constructor and Description |
---|
blockHeartbeat_args(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options) |
blockHeartbeat_call(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
BlockHeartbeatTOptions(BlockHeartbeatTOptions other)
Performs a deep copy on other.
|
Copyright © 2023. All Rights Reserved.