Package | Description |
---|---|
alluxio.grpc | |
alluxio.job | |
alluxio.job.wire | |
alluxio.worker.job |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<JobInfo> |
JobInfo.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JobInfo |
JobInfo.Builder.build() |
JobInfo |
JobInfo.Builder.buildPartial() |
JobInfo |
JobInfoOrBuilder.getChildren(int index)
repeated .alluxio.grpc.job.JobInfo children = 11; |
JobInfo |
JobInfo.getChildren(int index)
repeated .alluxio.grpc.job.JobInfo children = 11; |
JobInfo |
JobInfo.Builder.getChildren(int index)
repeated .alluxio.grpc.job.JobInfo children = 11; |
static JobInfo |
JobInfo.getDefaultInstance() |
JobInfo |
JobInfo.getDefaultInstanceForType() |
JobInfo |
JobInfo.Builder.getDefaultInstanceForType() |
JobInfo |
GetJobStatusDetailedPResponseOrBuilder.getJobInfo()
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
JobInfo |
GetJobStatusDetailedPResponse.getJobInfo()
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
JobInfo |
GetJobStatusDetailedPResponse.Builder.getJobInfo()
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
JobInfo |
GetJobStatusPResponseOrBuilder.getJobInfo()
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
JobInfo |
GetJobStatusPResponse.getJobInfo()
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
JobInfo |
GetJobStatusPResponse.Builder.getJobInfo()
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
JobInfo |
ListAllPResponseOrBuilder.getJobInfos(int index)
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
JobInfo |
ListAllPResponse.getJobInfos(int index)
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
JobInfo |
ListAllPResponse.Builder.getJobInfos(int index)
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
JobInfo |
JobServiceSummaryOrBuilder.getLongestRunning(int index)
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
JobInfo |
JobServiceSummary.getLongestRunning(int index)
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
JobInfo |
JobServiceSummary.Builder.getLongestRunning(int index)
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
JobInfo |
JobServiceSummaryOrBuilder.getRecentActivities(int index)
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
JobInfo |
JobServiceSummary.getRecentActivities(int index)
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
JobInfo |
JobServiceSummary.Builder.getRecentActivities(int index)
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
JobInfo |
JobServiceSummaryOrBuilder.getRecentFailures(int index)
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
JobInfo |
JobServiceSummary.getRecentFailures(int index)
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
JobInfo |
JobServiceSummary.Builder.getRecentFailures(int index)
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
JobInfo |
JobHeartbeatPRequestOrBuilder.getTaskInfos(int index)
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
JobInfo |
JobHeartbeatPRequest.getTaskInfos(int index)
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
JobInfo |
JobHeartbeatPRequest.Builder.getTaskInfos(int index)
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
static JobInfo |
JobInfo.parseDelimitedFrom(InputStream input) |
static JobInfo |
JobInfo.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobInfo |
JobInfo.parseFrom(byte[] data) |
static JobInfo |
JobInfo.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobInfo |
JobInfo.parseFrom(ByteBuffer data) |
static JobInfo |
JobInfo.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobInfo |
JobInfo.parseFrom(com.google.protobuf.ByteString data) |
static JobInfo |
JobInfo.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobInfo |
JobInfo.parseFrom(com.google.protobuf.CodedInputStream input) |
static JobInfo |
JobInfo.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static JobInfo |
JobInfo.parseFrom(InputStream input) |
static JobInfo |
JobInfo.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<JobInfo> |
JobInfoOrBuilder.getChildrenList()
repeated .alluxio.grpc.job.JobInfo children = 11; |
List<JobInfo> |
JobInfo.getChildrenList()
repeated .alluxio.grpc.job.JobInfo children = 11; |
List<JobInfo> |
JobInfo.Builder.getChildrenList()
repeated .alluxio.grpc.job.JobInfo children = 11; |
List<JobInfo> |
ListAllPResponseOrBuilder.getJobInfosList()
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
List<JobInfo> |
ListAllPResponse.getJobInfosList()
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
List<JobInfo> |
ListAllPResponse.Builder.getJobInfosList()
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
List<JobInfo> |
JobServiceSummaryOrBuilder.getLongestRunningList()
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
List<JobInfo> |
JobServiceSummary.getLongestRunningList()
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
List<JobInfo> |
JobServiceSummary.Builder.getLongestRunningList()
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
com.google.protobuf.Parser<JobInfo> |
JobInfo.getParserForType() |
List<JobInfo> |
JobServiceSummaryOrBuilder.getRecentActivitiesList()
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
List<JobInfo> |
JobServiceSummary.getRecentActivitiesList()
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
List<JobInfo> |
JobServiceSummary.Builder.getRecentActivitiesList()
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
List<JobInfo> |
JobServiceSummaryOrBuilder.getRecentFailuresList()
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
List<JobInfo> |
JobServiceSummary.getRecentFailuresList()
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
List<JobInfo> |
JobServiceSummary.Builder.getRecentFailuresList()
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
List<JobInfo> |
JobHeartbeatPRequestOrBuilder.getTaskInfosList()
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
List<JobInfo> |
JobHeartbeatPRequest.getTaskInfosList()
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
List<JobInfo> |
JobHeartbeatPRequest.Builder.getTaskInfosList()
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
static com.google.protobuf.Parser<JobInfo> |
JobInfo.parser() |
Modifier and Type | Method and Description |
---|---|
JobInfo.Builder |
JobInfo.Builder.addChildren(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo children = 11; |
JobInfo.Builder |
JobInfo.Builder.addChildren(JobInfo value)
repeated .alluxio.grpc.job.JobInfo children = 11; |
ListAllPResponse.Builder |
ListAllPResponse.Builder.addJobInfos(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
ListAllPResponse.Builder |
ListAllPResponse.Builder.addJobInfos(JobInfo value)
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addLongestRunning(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addLongestRunning(JobInfo value)
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addRecentActivities(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addRecentActivities(JobInfo value)
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addRecentFailures(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addRecentFailures(JobInfo value)
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.addTaskInfos(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.addTaskInfos(JobInfo value)
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
JobInfo.Builder |
JobInfo.Builder.mergeFrom(JobInfo other) |
GetJobStatusDetailedPResponse.Builder |
GetJobStatusDetailedPResponse.Builder.mergeJobInfo(JobInfo value)
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
GetJobStatusPResponse.Builder |
GetJobStatusPResponse.Builder.mergeJobInfo(JobInfo value)
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
static JobInfo.Builder |
JobInfo.newBuilder(JobInfo prototype) |
JobInfo.Builder |
JobInfo.Builder.setChildren(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo children = 11; |
GetJobStatusDetailedPResponse.Builder |
GetJobStatusDetailedPResponse.Builder.setJobInfo(JobInfo value)
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
GetJobStatusPResponse.Builder |
GetJobStatusPResponse.Builder.setJobInfo(JobInfo value)
optional .alluxio.grpc.job.JobInfo jobInfo = 1; |
ListAllPResponse.Builder |
ListAllPResponse.Builder.setJobInfos(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.setLongestRunning(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.setRecentActivities(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.setRecentFailures(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.setTaskInfos(int index,
JobInfo value)
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
Modifier and Type | Method and Description |
---|---|
JobInfo.Builder |
JobInfo.Builder.addAllChildren(Iterable<? extends JobInfo> values)
repeated .alluxio.grpc.job.JobInfo children = 11; |
ListAllPResponse.Builder |
ListAllPResponse.Builder.addAllJobInfos(Iterable<? extends JobInfo> values)
repeated .alluxio.grpc.job.JobInfo jobInfos = 2; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addAllLongestRunning(Iterable<? extends JobInfo> values)
repeated .alluxio.grpc.job.JobInfo longestRunning = 4; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addAllRecentActivities(Iterable<? extends JobInfo> values)
repeated .alluxio.grpc.job.JobInfo recentActivities = 2; |
JobServiceSummary.Builder |
JobServiceSummary.Builder.addAllRecentFailures(Iterable<? extends JobInfo> values)
repeated .alluxio.grpc.job.JobInfo recentFailures = 3; |
JobHeartbeatPRequest.Builder |
JobHeartbeatPRequest.Builder.addAllTaskInfos(Iterable<? extends JobInfo> values)
repeated .alluxio.grpc.job.JobInfo taskInfos = 2; |
Modifier and Type | Method and Description |
---|---|
static JobInfo |
ProtoUtils.fromProto(JobInfo jobInfo) |
Modifier and Type | Method and Description |
---|---|
JobInfo |
WorkflowInfo.toProto() |
JobInfo |
PlanInfo.toProto() |
JobInfo |
JobInfo.toProto() |
JobInfo |
TaskInfo.toProto() |
Constructor and Description |
---|
PlanInfo(JobInfo jobInfo)
Constructs a new instance of
PlanInfo from a proto object. |
TaskInfo(JobInfo taskInfo)
Constructs from the proto format.
|
WorkflowInfo(JobInfo jobInfo)
Constructor from the proto object.
|
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
JobMasterClient.heartbeat(JobWorkerHealth jobWorkerHealth,
List<JobInfo> taskInfoList)
Periodic heartbeats to update the tasks' status from a worker, and returns the commands.
|
List<JobCommand> |
RetryHandlingJobMasterClient.heartbeat(JobWorkerHealth jobWorkerHealth,
List<JobInfo> taskInfoList) |
Copyright © 2023. All Rights Reserved.