Package | Description |
---|---|
alluxio.grpc | |
alluxio.master.job | |
alluxio.master.job.command | |
alluxio.worker.job |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<JobCommand> |
JobCommand.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JobCommand |
JobCommand.Builder.build() |
JobCommand |
JobCommand.Builder.buildPartial() |
JobCommand |
JobHeartbeatPResponse.getCommands(int index)
repeated .alluxio.grpc.job.JobCommand commands = 1; |
JobCommand |
JobHeartbeatPResponse.Builder.getCommands(int index)
repeated .alluxio.grpc.job.JobCommand commands = 1; |
JobCommand |
JobHeartbeatPResponseOrBuilder.getCommands(int index)
repeated .alluxio.grpc.job.JobCommand commands = 1; |
static JobCommand |
JobCommand.getDefaultInstance() |
JobCommand |
JobCommand.getDefaultInstanceForType() |
JobCommand |
JobCommand.Builder.getDefaultInstanceForType() |
static JobCommand |
JobCommand.parseDelimitedFrom(InputStream input) |
static JobCommand |
JobCommand.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobCommand |
JobCommand.parseFrom(byte[] data) |
static JobCommand |
JobCommand.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobCommand |
JobCommand.parseFrom(ByteBuffer data) |
static JobCommand |
JobCommand.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobCommand |
JobCommand.parseFrom(com.google.protobuf.ByteString data) |
static JobCommand |
JobCommand.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobCommand |
JobCommand.parseFrom(com.google.protobuf.CodedInputStream input) |
static JobCommand |
JobCommand.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobCommand |
JobCommand.parseFrom(InputStream input) |
static JobCommand |
JobCommand.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
JobHeartbeatPResponse.getCommandsList()
repeated .alluxio.grpc.job.JobCommand commands = 1; |
List<JobCommand> |
JobHeartbeatPResponse.Builder.getCommandsList()
repeated .alluxio.grpc.job.JobCommand commands = 1; |
List<JobCommand> |
JobHeartbeatPResponseOrBuilder.getCommandsList()
repeated .alluxio.grpc.job.JobCommand commands = 1; |
com.google.protobuf.Parser<JobCommand> |
JobCommand.getParserForType() |
static com.google.protobuf.Parser<JobCommand> |
JobCommand.parser() |
Modifier and Type | Method and Description |
---|---|
JobHeartbeatPResponse.Builder |
JobHeartbeatPResponse.Builder.addCommands(int index,
JobCommand value)
repeated .alluxio.grpc.job.JobCommand commands = 1; |
JobHeartbeatPResponse.Builder |
JobHeartbeatPResponse.Builder.addCommands(JobCommand value)
repeated .alluxio.grpc.job.JobCommand commands = 1; |
JobCommand.Builder |
JobCommand.Builder.mergeFrom(JobCommand other) |
static JobCommand.Builder |
JobCommand.newBuilder(JobCommand prototype) |
JobHeartbeatPResponse.Builder |
JobHeartbeatPResponse.Builder.setCommands(int index,
JobCommand value)
repeated .alluxio.grpc.job.JobCommand commands = 1; |
Modifier and Type | Method and Description |
---|---|
JobHeartbeatPResponse.Builder |
JobHeartbeatPResponse.Builder.addAllCommands(Iterable<? extends JobCommand> values)
repeated .alluxio.grpc.job.JobCommand commands = 1; |
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
JobMaster.workerHeartbeat(JobWorkerHealth jobWorkerHealth,
List<TaskInfo> taskInfoList)
Updates the tasks' status when a worker periodically heartbeats with the master, and sends the
commands for the worker to execute.
|
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
CommandManager.pollAllPendingCommands(long workerId)
Polls all the pending commands to a worker and removes the commands from the queue.
|
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
RetryHandlingJobMasterClient.heartbeat(JobWorkerHealth jobWorkerHealth,
List<JobInfo> taskInfoList) |
List<JobCommand> |
JobMasterClient.heartbeat(JobWorkerHealth jobWorkerHealth,
List<JobInfo> taskInfoList)
Periodic heartbeats to update the tasks' status from a worker, and returns the commands.
|
Copyright © 2023. All Rights Reserved.