Package | Description |
---|---|
alluxio.grpc | |
alluxio.job.wire | |
alluxio.worker.job | |
alluxio.worker.job.task |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<TaskInfo> |
TaskInfo.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TaskInfo |
TaskInfo.Builder.build() |
TaskInfo |
TaskInfo.Builder.buildPartial() |
static TaskInfo |
TaskInfo.getDefaultInstance() |
TaskInfo |
TaskInfo.getDefaultInstanceForType() |
TaskInfo |
TaskInfo.Builder.getDefaultInstanceForType() |
TaskInfo |
JobHeartbeatPRequest.getTaskInfos(int index)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
TaskInfo |
JobHeartbeatPRequest.Builder.getTaskInfos(int index)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
TaskInfo |
JobHeartbeatPRequestOrBuilder.getTaskInfos(int index)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
TaskInfo |
JobInfo.getTaskInfos(int index)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
TaskInfo |
JobInfo.Builder.getTaskInfos(int index)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
TaskInfo |
JobInfoOrBuilder.getTaskInfos(int index)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
static TaskInfo |
TaskInfo.parseDelimitedFrom(InputStream input) |
static TaskInfo |
TaskInfo.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TaskInfo |
TaskInfo.parseFrom(byte[] data) |
static TaskInfo |
TaskInfo.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TaskInfo |
TaskInfo.parseFrom(ByteBuffer data) |
static TaskInfo |
TaskInfo.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TaskInfo |
TaskInfo.parseFrom(com.google.protobuf.ByteString data) |
static TaskInfo |
TaskInfo.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TaskInfo |
TaskInfo.parseFrom(com.google.protobuf.CodedInputStream input) |
static TaskInfo |
TaskInfo.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static TaskInfo |
TaskInfo.parseFrom(InputStream input) |
static TaskInfo |
TaskInfo.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<TaskInfo> |
TaskInfo.getParserForType() |
List<TaskInfo> |
JobHeartbeatPRequest.getTaskInfosList()
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
List<TaskInfo> |
JobHeartbeatPRequest.Builder.getTaskInfosList()
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
List<TaskInfo> |
JobHeartbeatPRequestOrBuilder.getTaskInfosList()
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
List<TaskInfo> |
JobInfo.getTaskInfosList()
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
List<TaskInfo> |
JobInfo.Builder.getTaskInfosList()
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
List<TaskInfo> |
JobInfoOrBuilder.getTaskInfosList()
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
static com.google.protobuf.Parser<TaskInfo> |
TaskInfo.parser() |
Modifier and Type | Method and Description |
---|---|
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.addTaskInfos(int index,
TaskInfo value)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
JobInfo.Builder |
JobInfo.Builder.addTaskInfos(int index,
TaskInfo value)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.addTaskInfos(TaskInfo value)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
JobInfo.Builder |
JobInfo.Builder.addTaskInfos(TaskInfo value)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
TaskInfo.Builder |
TaskInfo.Builder.mergeFrom(TaskInfo other) |
static TaskInfo.Builder |
TaskInfo.newBuilder(TaskInfo prototype) |
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.setTaskInfos(int index,
TaskInfo value)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
JobInfo.Builder |
JobInfo.Builder.setTaskInfos(int index,
TaskInfo value)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
Modifier and Type | Method and Description |
---|---|
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.addAllTaskInfos(Iterable<? extends TaskInfo> values)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 2; |
JobInfo.Builder |
JobInfo.Builder.addAllTaskInfos(Iterable<? extends TaskInfo> values)
repeated .alluxio.grpc.job.TaskInfo taskInfos = 3; |
Modifier and Type | Method and Description |
---|---|
TaskInfo |
TaskInfo.toProto() |
Constructor and Description |
---|
TaskInfo(TaskInfo taskInfo)
Constructs from the proto format.
|
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
JobMasterClient.heartbeat(long workerId,
List<TaskInfo> taskInfoList)
Periodic heartbeats to update the tasks' status from a worker, and returns the commands.
|
List<JobCommand> |
RetryHandlingJobMasterClient.heartbeat(long workerId,
List<TaskInfo> taskInfoList) |
Modifier and Type | Method and Description |
---|---|
List<TaskInfo> |
TaskExecutorManager.getAndClearTaskUpdates() |
Modifier and Type | Method and Description |
---|---|
void |
TaskExecutorManager.restoreTaskUpdates(List<TaskInfo> tasks)
Adds the given tasks to the task updates data structure.
|
Copyright © 2023. All Rights Reserved.