Package | Description |
---|---|
tachyon.client | |
tachyon.master | |
tachyon.thrift | |
tachyon.web |
Modifier and Type | Method and Description |
---|---|
List<NetAddress> |
TachyonFS.getFileNetAddresses(int fileId) |
List<List<NetAddress>> |
TachyonFS.getFilesNetAddresses(List<Integer> fileIds) |
Modifier and Type | Method and Description |
---|---|
NetAddress |
MasterInfo.getWorker(boolean random,
String host) |
NetAddress |
MasterClient.user_getWorker(boolean random,
String hostname) |
NetAddress |
MasterServiceHandler.user_getWorker(boolean random,
String host) |
Modifier and Type | Method and Description |
---|---|
List<NetAddress> |
InodeFile.getBlockLocations(int blockIndex) |
List<NetAddress> |
BlockInfo.getLocations() |
Modifier and Type | Method and Description |
---|---|
void |
InodeFile.addLocation(int blockIndex,
long workerId,
NetAddress workerAddress) |
void |
BlockInfo.addLocation(long workerId,
NetAddress workerAddress) |
long |
MasterInfo.registerWorker(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlockIds) |
long |
MasterClient.worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlockList)
Register the worker to the master.
|
long |
MasterServiceHandler.worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlockIds) |
Modifier and Type | Field and Description |
---|---|
NetAddress |
ClientWorkerInfo.address |
NetAddress |
MasterService.user_getWorker_result.success |
NetAddress |
MasterService.worker_register_args.workerNetAddress |
Modifier and Type | Field and Description |
---|---|
List<NetAddress> |
ClientBlockInfo.locations |
Modifier and Type | Method and Description |
---|---|
NetAddress |
NetAddress.deepCopy() |
NetAddress |
ClientWorkerInfo.getAddress() |
NetAddress |
MasterService.AsyncClient.user_getWorker_call.getResult() |
NetAddress |
MasterService.user_getWorker_result.getSuccess() |
NetAddress |
MasterService.worker_register_args.getWorkerNetAddress() |
NetAddress |
MasterService.Client.recv_user_getWorker() |
NetAddress |
NetAddress.setMHost(String mHost) |
NetAddress |
NetAddress.setMPort(int mPort) |
NetAddress |
MasterService.Iface.user_getWorker(boolean random,
String host)
Get local worker NetAddress
|
NetAddress |
MasterService.Client.user_getWorker(boolean random,
String host) |
Modifier and Type | Method and Description |
---|---|
List<NetAddress> |
ClientBlockInfo.getLocations() |
Iterator<NetAddress> |
ClientBlockInfo.getLocationsIterator() |
Modifier and Type | Method and Description |
---|---|
void |
ClientBlockInfo.addToLocations(NetAddress elem) |
int |
NetAddress.compareTo(NetAddress other) |
boolean |
NetAddress.equals(NetAddress that) |
void |
MasterService.Client.send_worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks) |
ClientWorkerInfo |
ClientWorkerInfo.setAddress(NetAddress address) |
MasterService.user_getWorker_result |
MasterService.user_getWorker_result.setSuccess(NetAddress success) |
MasterService.worker_register_args |
MasterService.worker_register_args.setWorkerNetAddress(NetAddress workerNetAddress) |
long |
MasterService.Iface.worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks)
Worker register.
|
long |
MasterService.Client.worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks) |
void |
MasterService.AsyncIface.worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_register_call> resultHandler) |
void |
MasterService.AsyncClient.worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_register_call> resultHandler) |
Modifier and Type | Method and Description |
---|---|
ClientBlockInfo |
ClientBlockInfo.setLocations(List<NetAddress> locations) |
Constructor and Description |
---|
ClientWorkerInfo(long id,
NetAddress address,
int lastContactSec,
String state,
long capacityBytes,
long usedBytes,
long starttimeMs) |
MasterService.AsyncClient.worker_register_call(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_register_call> resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
MasterService.user_getWorker_result(NetAddress success,
NoWorkerException e) |
MasterService.worker_register_args(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks) |
NetAddress(NetAddress other)
Performs a deep copy on other.
|
Constructor and Description |
---|
ClientBlockInfo(long blockId,
long offset,
long length,
List<NetAddress> locations) |
Modifier and Type | Method and Description |
---|---|
void |
WebInterfaceBrowseServlet.UiFileInfo.setFileLocations(List<NetAddress> fileLocations) |
Copyright © 2014. All rights reserved.