Package | Description |
---|---|
alluxio.master.block | |
alluxio.thrift |
Modifier and Type | Method and Description |
---|---|
RegisterWorkerTResponse |
BlockMasterWorkerServiceHandler.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options) |
void |
DefaultBlockMaster.workerRegister(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options) |
void |
BlockMaster.workerRegister(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options)
Updates metadata when a worker registers with the master.
|
Modifier and Type | Method and Description |
---|---|
RegisterWorkerTOptions |
RegisterWorkerTOptions.deepCopy() |
RegisterWorkerTOptions |
BlockMasterWorkerService.registerWorker_args.getOptions()
the method options
|
RegisterWorkerTOptions |
RegisterWorkerTOptions.setConfigList(List<ConfigProperty> configList) |
Modifier and Type | Method and Description |
---|---|
int |
RegisterWorkerTOptions.compareTo(RegisterWorkerTOptions other) |
boolean |
RegisterWorkerTOptions.equals(RegisterWorkerTOptions that) |
RegisterWorkerTResponse |
BlockMasterWorkerService.Iface.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options)
Registers a worker.
|
RegisterWorkerTResponse |
BlockMasterWorkerService.Client.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options) |
void |
BlockMasterWorkerService.AsyncIface.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
BlockMasterWorkerService.AsyncClient.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
BlockMasterWorkerService.Client.send_registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options) |
BlockMasterWorkerService.registerWorker_args |
BlockMasterWorkerService.registerWorker_args.setOptions(RegisterWorkerTOptions options)
the method options
|
Constructor and Description |
---|
registerWorker_args(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options) |
registerWorker_call(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions 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) |
RegisterWorkerTOptions(RegisterWorkerTOptions other)
Performs a deep copy on other.
|
Copyright © 2023. All Rights Reserved.