Package | Description |
---|---|
tachyon | |
tachyon.thrift |
Modifier and Type | Method and Description |
---|---|
void |
InodeFile.addBlock(BlockInfo blockInfo) |
void |
WorkerServiceHandler.addCheckpoint(long userId,
int fileId) |
void |
WorkerStorage.addCheckpoint(long userId,
int fileId) |
boolean |
MasterServiceHandler.addCheckpoint(long workerId,
int fileId,
long fileSizeBytes,
String checkpointPath) |
boolean |
MasterClient.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
boolean |
MasterInfo.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath)
Add a checkpoint to a file.
|
void |
InodeFile.addLocation(int blockIndex,
long workerId,
NetAddress workerAddress) |
void |
WorkerServiceHandler.cacheBlock(long userId,
long blockId) |
void |
WorkerStorage.cacheBlock(long userId,
long blockId) |
void |
MasterInfo.cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length)
A worker cache a block in its memory.
|
int |
MasterInfo.createFile(boolean recursive,
String path,
boolean directory,
int columns,
ByteBuffer metadata,
long blockSizeByte) |
int |
MasterInfo.createFile(String path,
long blockSizeByte) |
List<NetAddress> |
InodeFile.getBlockLocations(int blockIndex) |
ClientBlockInfo |
InodeFile.getClientBlockInfo(int blockIndex) |
ClientBlockInfo |
MasterInfo.getClientBlockInfo(long blockId) |
Command |
WorkerStorage.heartbeat() |
long |
MasterInfo.registerWorker(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlockIds) |
void |
InodeFile.removeLocation(int blockIndex,
long workerId) |
void |
InodeFile.setLength(long length) |
int |
MasterServiceHandler.user_createFile(String path,
long blockSizeByte) |
int |
MasterServiceHandler.user_createFileOnCheckpoint(String path,
String checkpointPath) |
ClientBlockInfo |
MasterServiceHandler.user_getClientBlockInfo(long blockId) |
ClientBlockInfo |
MasterClient.user_getClientBlockInfo(long blockId) |
void |
MasterServiceHandler.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
void |
MasterClient.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
Command |
MasterServiceHandler.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlockIds) |
Command |
MasterClient.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedPartitionList) |
long |
MasterServiceHandler.worker_register(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.
|
Command |
MasterInfo.workerHeartbeat(long workerId,
long usedBytes,
List<Long> removedBlockIds) |
Modifier and Type | Field and Description |
---|---|
BlockInfoException |
MasterService.worker_register_result.e |
BlockInfoException |
MasterService.worker_heartbeat_result.e |
BlockInfoException |
MasterService.addCheckpoint_result.eB |
BlockInfoException |
MasterService.worker_cacheBlock_result.eB |
BlockInfoException |
MasterService.user_createFile_result.eB |
BlockInfoException |
MasterService.user_createFileOnCheckpoint_result.eB |
BlockInfoException |
MasterService.user_getClientBlockInfo_result.eB |
BlockInfoException |
WorkerService.addCheckpoint_result.eB |
BlockInfoException |
WorkerService.cacheBlock_result.eB |
Modifier and Type | Method and Description |
---|---|
BlockInfoException |
BlockInfoException.deepCopy() |
BlockInfoException |
MasterService.worker_register_result.getE() |
BlockInfoException |
MasterService.worker_heartbeat_result.getE() |
BlockInfoException |
MasterService.addCheckpoint_result.getEB() |
BlockInfoException |
MasterService.worker_cacheBlock_result.getEB() |
BlockInfoException |
MasterService.user_createFile_result.getEB() |
BlockInfoException |
MasterService.user_createFileOnCheckpoint_result.getEB() |
BlockInfoException |
MasterService.user_getClientBlockInfo_result.getEB() |
BlockInfoException |
WorkerService.addCheckpoint_result.getEB() |
BlockInfoException |
WorkerService.cacheBlock_result.getEB() |
BlockInfoException |
BlockInfoException.setMessage(String message) |
Modifier and Type | Method and Description |
---|---|
void |
WorkerService.Iface.addCheckpoint(long userId,
int fileId) |
void |
WorkerService.Client.addCheckpoint(long userId,
int fileId) |
boolean |
MasterService.Iface.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
boolean |
MasterService.Client.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
void |
WorkerService.Iface.cacheBlock(long userId,
long blockId) |
void |
WorkerService.Client.cacheBlock(long userId,
long blockId) |
boolean |
MasterService.AsyncClient.addCheckpoint_call.getResult() |
long |
MasterService.AsyncClient.worker_register_call.getResult() |
Command |
MasterService.AsyncClient.worker_heartbeat_call.getResult() |
void |
MasterService.AsyncClient.worker_cacheBlock_call.getResult() |
int |
MasterService.AsyncClient.user_createFile_call.getResult() |
int |
MasterService.AsyncClient.user_createFileOnCheckpoint_call.getResult() |
ClientBlockInfo |
MasterService.AsyncClient.user_getClientBlockInfo_call.getResult() |
void |
WorkerService.AsyncClient.addCheckpoint_call.getResult() |
void |
WorkerService.AsyncClient.cacheBlock_call.getResult() |
boolean |
MasterService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_cacheBlock() |
int |
MasterService.Client.recv_user_createFile() |
int |
MasterService.Client.recv_user_createFileOnCheckpoint() |
ClientBlockInfo |
MasterService.Client.recv_user_getClientBlockInfo() |
void |
MasterService.Client.recv_worker_cacheBlock() |
Command |
MasterService.Client.recv_worker_heartbeat() |
long |
MasterService.Client.recv_worker_register() |
int |
MasterService.Iface.user_createFile(String path,
long blockSizeByte) |
int |
MasterService.Client.user_createFile(String path,
long blockSizeByte) |
int |
MasterService.Iface.user_createFileOnCheckpoint(String path,
String checkpointPath) |
int |
MasterService.Client.user_createFileOnCheckpoint(String path,
String checkpointPath) |
ClientBlockInfo |
MasterService.Iface.user_getClientBlockInfo(long blockId)
Get block's ClientBlockInfo.
|
ClientBlockInfo |
MasterService.Client.user_getClientBlockInfo(long blockId) |
void |
MasterService.Iface.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
void |
MasterService.Client.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
Command |
MasterService.Iface.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlocks) |
Command |
MasterService.Client.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlocks) |
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) |
Copyright © 2013. All rights reserved.