Package | Description |
---|---|
tachyon.master | |
tachyon.thrift | |
tachyon.worker |
Worker process and utils for working with the worker remotely.
|
Modifier and Type | Method and Description |
---|---|
Command |
MasterServiceHandler.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlockIds,
Map<Long,List<Long>> addedBlockIds) |
Command |
MasterClient.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlockIds,
Map<Long,List<Long>> addedBlockIds) |
Command |
MasterInfo.workerHeartbeat(long workerId,
long usedBytes,
List<Long> removedBlockIds,
Map<Long,List<Long>> addedBlockIds)
The heartbeat of the worker.
|
Modifier and Type | Field and Description |
---|---|
Command |
MasterService.worker_heartbeat_result.success |
Modifier and Type | Method and Description |
---|---|
Command |
Command.deepCopy() |
Command |
MasterService.AsyncClient.worker_heartbeat_call.getResult() |
Command |
MasterService.worker_heartbeat_result.getSuccess() |
Command |
MasterService.Client.recv_worker_heartbeat() |
Command |
Command.setMCommandType(CommandType mCommandType) |
Command |
Command.setMData(List<Long> mData) |
Command |
MasterService.Iface.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlockIds,
Map<Long,List<Long>> addedBlockIds)
Heart beat between worker and master, worker update used Tachyon space in bytes, removed
blocks and added blocks in each storage directory by eviction and promotion to master, and
return the command from master to worker.
|
Command |
MasterService.Client.worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlockIds,
Map<Long,List<Long>> addedBlockIds) |
Modifier and Type | Method and Description |
---|---|
org.apache.thrift.async.AsyncMethodCallback<Command> |
MasterService.AsyncProcessor.worker_heartbeat.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
Modifier and Type | Method and Description |
---|---|
int |
Command.compareTo(Command other) |
boolean |
Command.equals(Command that) |
MasterService.worker_heartbeat_result |
MasterService.worker_heartbeat_result.setSuccess(Command success) |
Modifier and Type | Method and Description |
---|---|
void |
MasterService.AsyncProcessor.worker_heartbeat.start(I iface,
MasterService.worker_heartbeat_args args,
org.apache.thrift.async.AsyncMethodCallback<Command> resultHandler) |
Constructor and Description |
---|
Command(Command other)
Performs a deep copy on other.
|
MasterService.worker_heartbeat_result(Command success,
BlockInfoException e) |
Modifier and Type | Method and Description |
---|---|
Command |
WorkerStorage.heartbeat()
Heartbeat with the TachyonMaster.
|
Copyright © 2015. All Rights Reserved.