Package | Description |
---|---|
alluxio.master.block | |
alluxio.thrift | |
alluxio.wire |
Modifier and Type | Method and Description |
---|---|
GetWorkerIdTResponse |
BlockMasterWorkerServiceHandler.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options) |
Modifier and Type | Method and Description |
---|---|
WorkerNetAddress |
WorkerNetAddress.deepCopy() |
WorkerNetAddress |
WorkerInfo.getAddress() |
WorkerNetAddress |
BlockLocation.getWorkerAddress() |
WorkerNetAddress |
BlockMasterWorkerService.getWorkerId_args.getWorkerNetAddress()
the worker network address
|
WorkerNetAddress |
WorkerNetAddress.setDataPort(int dataPort) |
WorkerNetAddress |
WorkerNetAddress.setDomainSocketPath(String domainSocketPath) |
WorkerNetAddress |
WorkerNetAddress.setHost(String host) |
WorkerNetAddress |
WorkerNetAddress.setRpcPort(int rpcPort) |
WorkerNetAddress |
WorkerNetAddress.setTieredIdentity(TieredIdentity tieredIdentity) |
WorkerNetAddress |
WorkerNetAddress.setWebPort(int webPort) |
Modifier and Type | Method and Description |
---|---|
List<WorkerNetAddress> |
FileBlockInfo.getUfsLocations() |
Iterator<WorkerNetAddress> |
FileBlockInfo.getUfsLocationsIterator() |
Modifier and Type | Method and Description |
---|---|
void |
FileBlockInfo.addToUfsLocations(WorkerNetAddress elem) |
int |
WorkerNetAddress.compareTo(WorkerNetAddress other) |
boolean |
WorkerNetAddress.equals(WorkerNetAddress that) |
GetWorkerIdTResponse |
BlockMasterWorkerService.Iface.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options)
Returns a worker id for the given network address.
|
GetWorkerIdTResponse |
BlockMasterWorkerService.Client.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options) |
void |
BlockMasterWorkerService.AsyncIface.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
BlockMasterWorkerService.AsyncClient.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
BlockMasterWorkerService.Client.send_getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options) |
WorkerInfo |
WorkerInfo.setAddress(WorkerNetAddress address) |
BlockLocation |
BlockLocation.setWorkerAddress(WorkerNetAddress workerAddress) |
BlockMasterWorkerService.getWorkerId_args |
BlockMasterWorkerService.getWorkerId_args.setWorkerNetAddress(WorkerNetAddress workerNetAddress)
the worker network address
|
Modifier and Type | Method and Description |
---|---|
FileBlockInfo |
FileBlockInfo.setUfsLocations(List<WorkerNetAddress> ufsLocations) |
Constructor and Description |
---|
BlockLocation(long workerId,
WorkerNetAddress workerAddress,
String tierAlias) |
getWorkerId_args(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options) |
getWorkerId_call(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions 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) |
WorkerInfo(long id,
WorkerNetAddress address,
int lastContactSec,
String state,
long capacityBytes,
long usedBytes,
long startTimeMs,
Map<String,Long> capacityBytesOnTiers,
Map<String,Long> usedBytesOnTiers) |
WorkerNetAddress(WorkerNetAddress other)
Performs a deep copy on other.
|
Constructor and Description |
---|
FileBlockInfo(BlockInfo blockInfo,
long offset,
List<WorkerNetAddress> ufsLocations,
List<String> ufsStringLocations) |
Modifier and Type | Method and Description |
---|---|
WorkerNetAddress |
WorkerNetAddress.toThrift() |
Modifier and Type | Method and Description |
---|---|
static WorkerNetAddress |
WorkerNetAddress.fromThrift(WorkerNetAddress address)
Creates a new instance of
WorkerNetAddress from thrift representation. |
Copyright © 2023. All Rights Reserved.