Package | Description |
---|---|
alluxio.thrift | |
alluxio.worker.block |
Modifier and Type | Method and Description |
---|---|
SessionBlockHeartbeatTResponse |
SessionBlockHeartbeatTResponse.deepCopy() |
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.AsyncClient.sessionBlockHeartbeat_call.getResult() |
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.sessionBlockHeartbeat_result.getSuccess() |
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.Client.recv_sessionBlockHeartbeat() |
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.Iface.sessionBlockHeartbeat(long sessionId,
List<Long> metrics,
SessionBlockHeartbeatTOptions options)
Local session send heartbeat to local worker to keep its temporary folder.
|
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.Client.sessionBlockHeartbeat(long sessionId,
List<Long> metrics,
SessionBlockHeartbeatTOptions options) |
Modifier and Type | Method and Description |
---|---|
org.apache.thrift.async.AsyncMethodCallback<SessionBlockHeartbeatTResponse> |
BlockWorkerClientService.AsyncProcessor.sessionBlockHeartbeat.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
Modifier and Type | Method and Description |
---|---|
int |
SessionBlockHeartbeatTResponse.compareTo(SessionBlockHeartbeatTResponse other) |
boolean |
SessionBlockHeartbeatTResponse.equals(SessionBlockHeartbeatTResponse that) |
BlockWorkerClientService.sessionBlockHeartbeat_result |
BlockWorkerClientService.sessionBlockHeartbeat_result.setSuccess(SessionBlockHeartbeatTResponse success) |
Modifier and Type | Method and Description |
---|---|
void |
BlockWorkerClientService.AsyncProcessor.sessionBlockHeartbeat.start(I iface,
BlockWorkerClientService.sessionBlockHeartbeat_args args,
org.apache.thrift.async.AsyncMethodCallback<SessionBlockHeartbeatTResponse> resultHandler) |
Constructor and Description |
---|
sessionBlockHeartbeat_result(SessionBlockHeartbeatTResponse success,
AlluxioTException e) |
SessionBlockHeartbeatTResponse(SessionBlockHeartbeatTResponse other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
SessionBlockHeartbeatTResponse |
BlockWorkerClientServiceHandler.sessionBlockHeartbeat(long sessionId,
List<Long> metrics,
SessionBlockHeartbeatTOptions options) |
Copyright © 2023. All Rights Reserved.