| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ |
| H A D | ProtoUtils.java | 70 public static ContainerState convertFromProtoFormat(ContainerStateProto e) { in convertFromProtoFormat() method in ProtoUtils
81 public static NodeState convertFromProtoFormat(NodeStateProto e) { in convertFromProtoFormat() method in ProtoUtils
91 public static NodeId convertFromProtoFormat(NodeIdProto e) { in convertFromProtoFormat() method in ProtoUtils
114 public static YarnApplicationAttemptState convertFromProtoFormat( in convertFromProtoFormat() method in ProtoUtils
127 public static ApplicationsRequestScope convertFromProtoFormat in convertFromProtoFormat() method in ProtoUtils
180 public static AMCommand convertFromProtoFormat(AMCommandProto e) { in convertFromProtoFormat() method in ProtoUtils
187 public static ByteBuffer convertFromProtoFormat(ByteString byteString) { in convertFromProtoFormat() method in ProtoUtils
210 public static QueueState convertFromProtoFormat(QueueStateProto e) { in convertFromProtoFormat() method in ProtoUtils
221 public static QueueACL convertFromProtoFormat(QueueACLProto e) { in convertFromProtoFormat() method in ProtoUtils
237 public static ApplicationAccessType convertFromProtoFormat( in convertFromProtoFormat() method in ProtoUtils
[all …]
|
| H A D | ApplicationReportPBImpl.java | 76 this.applicationId = convertFromProtoFormat(p.getApplicationId()); in getApplicationId()
109 return convertFromProtoFormat(p.getAppResourceUsage()); in getApplicationResourceUsageReport()
154 return convertFromProtoFormat(p.getYarnApplicationState()); in getYarnApplicationState()
221 return convertFromProtoFormat(p.getFinalApplicationStatus()); in getFinalApplicationStatus()
248 amRmToken = convertFromProtoFormat(p.getAmRmToken()); in getAMRMToken()
511 return ProtoUtils.convertFromProtoFormat(s); in convertFromProtoFormat()
518 private ApplicationIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationReportPBImpl
523 private ApplicationAttemptIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationReportPBImpl
529 return ProtoUtils.convertFromProtoFormat(s); in convertFromProtoFormat()
537 return ProtoUtils.convertFromProtoFormat(s); in convertFromProtoFormat()
[all …]
|
| H A D | ContainerReportPBImpl.java | 71 this.resource = convertFromProtoFormat(p.getResource()); in getAllocatedResource()
84 this.nodeId = convertFromProtoFormat(p.getNodeId()); in getAssignedNode()
97 this.containerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
116 return convertFromProtoFormat(p.getContainerState()); in getContainerState()
143 this.priority = convertFromProtoFormat(p.getPriority()); in getPriority()
300 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in ContainerReportPBImpl
304 private NodeIdPBImpl convertFromProtoFormat(NodeIdProto p) { in convertFromProtoFormat() method in ContainerReportPBImpl
316 private ResourcePBImpl convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in ContainerReportPBImpl
324 private PriorityPBImpl convertFromProtoFormat(PriorityProto p) { in convertFromProtoFormat() method in ContainerReportPBImpl
337 private ContainerState convertFromProtoFormat( in convertFromProtoFormat() method in ContainerReportPBImpl
[all …]
|
| H A D | LocalResourcePBImpl.java | 125 return convertFromProtoFormat(p.getType()); in getType()
146 this.url = convertFromProtoFormat(p.getResource()); in getResource()
163 return convertFromProtoFormat(p.getVisibility()); in getVisibility()
219 private LocalResourceType convertFromProtoFormat(LocalResourceTypeProto e) { in convertFromProtoFormat() method in LocalResourcePBImpl
220 return ProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
223 private URLPBImpl convertFromProtoFormat(URLProto p) { in convertFromProtoFormat() method in LocalResourcePBImpl
235 private LocalResourceVisibility convertFromProtoFormat(LocalResourceVisibilityProto e) { in convertFromProtoFormat() method in LocalResourcePBImpl
236 return ProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
|
| H A D | ContainerPBImpl.java | 135 this.containerId = convertFromProtoFormat(p.getId()); in getId()
156 this.nodeId = convertFromProtoFormat(p.getNodeId()); in getNodeId()
196 this.resource = convertFromProtoFormat(p.getResource()); in getResource()
217 this.priority = convertFromProtoFormat(p.getPriority()); in getPriority()
239 this.containerToken = convertFromProtoFormat(p.getContainerToken()); in getContainerToken()
251 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in ContainerPBImpl
255 private NodeIdPBImpl convertFromProtoFormat(NodeIdProto p) { in convertFromProtoFormat() method in ContainerPBImpl
267 private ResourcePBImpl convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in ContainerPBImpl
275 private PriorityPBImpl convertFromProtoFormat(PriorityProto p) { in convertFromProtoFormat() method in ContainerPBImpl
283 private TokenPBImpl convertFromProtoFormat(TokenProto p) { in convertFromProtoFormat() method in ContainerPBImpl
|
| H A D | ApplicationSubmissionContextPBImpl.java | 160 this.priority = convertFromProtoFormat(p.getPriority()); in getPriority()
181 applicationId = convertFromProtoFormat(p.getApplicationId()); in getApplicationId()
308 amContainer = convertFromProtoFormat(p.getAmContainerSpec()); in getAMContainerSpec()
367 this.resource = convertFromProtoFormat(p.getResource()); in getResource()
389 reservationId = convertFromProtoFormat(p.getReservationId()); in getReservationID()
416 private PriorityPBImpl convertFromProtoFormat(PriorityProto p) { in convertFromProtoFormat() method in ApplicationSubmissionContextPBImpl
432 private ApplicationIdPBImpl convertFromProtoFormat(ApplicationIdProto p) { in convertFromProtoFormat() method in ApplicationSubmissionContextPBImpl
440 private ContainerLaunchContextPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationSubmissionContextPBImpl
450 private ResourcePBImpl convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in ApplicationSubmissionContextPBImpl
512 private LogAggregationContextPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationSubmissionContextPBImpl
[all …]
|
| H A D | ContainerResourceIncreasePBImpl.java | 64 this.existingContainerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
85 this.targetCapability = convertFromProtoFormat(p.getCapability()); in getCapability()
106 this.token = convertFromProtoFormat(p.getContainerToken()); in getContainerToken()
120 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in ContainerResourceIncreasePBImpl
128 private Resource convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in ContainerResourceIncreasePBImpl
136 private Token convertFromProtoFormat(TokenProto p) { in convertFromProtoFormat() method in ContainerResourceIncreasePBImpl
|
| H A D | ApplicationAttemptReportPBImpl.java | 62 convertFromProtoFormat(p.getApplicationAttemptId()); in getApplicationAttemptId()
114 return convertFromProtoFormat(p.getYarnApplicationAttemptState()); in getYarnApplicationAttemptState()
132 private YarnApplicationAttemptState convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationAttemptReportPBImpl
134 return ProtoUtils.convertFromProtoFormat(yarnApplicationAttemptState); in convertFromProtoFormat()
253 private ContainerIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationAttemptReportPBImpl
263 private ApplicationAttemptIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationAttemptReportPBImpl
278 this.amContainerId = convertFromProtoFormat(p.getAmContainerId()); in getAMContainerId()
|
| H A D | ReservationRequestsPBImpl.java | 100 return (convertFromProtoFormat(p.getInterpreter())); in getInterpreter()
123 reservationRequests.add(convertFromProtoFormat(r)); in initReservationRequestsList()
168 private ReservationRequestPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ReservationRequestsPBImpl
178 private ReservationRequestInterpreter convertFromProtoFormat( in convertFromProtoFormat() method in ReservationRequestsPBImpl
180 return ProtoUtils.convertFromProtoFormat(r); in convertFromProtoFormat()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/records/impl/pb/ |
| H A D | TaskAttemptReportPBImpl.java | 104 this.counters = convertFromProtoFormat(p.getCounters()); in getCounters()
171 this.taskAttemptId = convertFromProtoFormat(p.getTaskAttemptId()); in getTaskAttemptId()
188 return convertFromProtoFormat(p.getTaskAttemptState()); in getTaskAttemptState()
253 return convertFromProtoFormat(p.getPhase()); in getPhase()
318 containerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
335 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in TaskAttemptReportPBImpl
339 private CountersPBImpl convertFromProtoFormat(CountersProto p) { in convertFromProtoFormat() method in TaskAttemptReportPBImpl
347 private TaskAttemptIdPBImpl convertFromProtoFormat(TaskAttemptIdProto p) { in convertFromProtoFormat() method in TaskAttemptReportPBImpl
360 return MRProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
367 private Phase convertFromProtoFormat(PhaseProto e) { in convertFromProtoFormat() method in TaskAttemptReportPBImpl
[all …]
|
| H A D | TaskReportPBImpl.java | 114 this.counters = convertFromProtoFormat(p.getCounters()); in getCounters()
158 this.taskId = convertFromProtoFormat(p.getTaskId()); in getTaskId()
197 return convertFromProtoFormat(p.getTaskState()); in getTaskState()
234 this.runningAttempts.add(convertFromProtoFormat(c)); in initRunningAttempts()
303 this.successfulAttemptId = convertFromProtoFormat(p.getSuccessfulAttempt()); in getSuccessfulAttempt()
374 private CountersPBImpl convertFromProtoFormat(CountersProto p) { in convertFromProtoFormat() method in TaskReportPBImpl
382 private TaskIdPBImpl convertFromProtoFormat(TaskIdProto p) { in convertFromProtoFormat() method in TaskReportPBImpl
394 private TaskState convertFromProtoFormat(TaskStateProto e) { in convertFromProtoFormat() method in TaskReportPBImpl
395 return MRProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
398 private TaskAttemptIdPBImpl convertFromProtoFormat(TaskAttemptIdProto p) { in convertFromProtoFormat() method in TaskReportPBImpl
|
| H A D | TaskIdPBImpl.java | 96 jobId = convertFromProtoFormat(p.getJobId()); in getJobId()
114 return convertFromProtoFormat(p.getTaskType()); in getTaskType()
127 private JobIdPBImpl convertFromProtoFormat(JobIdProto p) { in convertFromProtoFormat() method in TaskIdPBImpl
139 private TaskType convertFromProtoFormat(TaskTypeProto e) { in convertFromProtoFormat() method in TaskIdPBImpl
140 return MRProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
|
| H A D | TaskAttemptCompletionEventPBImpl.java | 89 this.taskAttemptId = convertFromProtoFormat(p.getAttemptId()); in getAttemptId()
106 return convertFromProtoFormat(p.getStatus()); in getStatus()
159 private TaskAttemptIdPBImpl convertFromProtoFormat(TaskAttemptIdProto p) { in convertFromProtoFormat() method in TaskAttemptCompletionEventPBImpl
171 …private TaskAttemptCompletionEventStatus convertFromProtoFormat(TaskAttemptCompletionEventStatusPr… in convertFromProtoFormat() method in TaskAttemptCompletionEventPBImpl
172 return MRProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/records/impl/pb/ |
| H A D | ApplicationFinishDataPBImpl.java | 62 this.applicationId = convertFromProtoFormat(p.getApplicationId()); in getApplicationId()
112 return convertFromProtoFormat(p.getFinalApplicationStatus()); in getFinalApplicationStatus()
133 return convertFromProtoFormat(p.getYarnApplicationState()); in getYarnApplicationState()
201 private ApplicationIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationFinishDataPBImpl
206 private FinalApplicationStatus convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationFinishDataPBImpl
208 return ProtoUtils.convertFromProtoFormat(finalApplicationStatus); in convertFromProtoFormat()
221 private YarnApplicationState convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationFinishDataPBImpl
223 return ProtoUtils.convertFromProtoFormat(yarnApplicationState); in convertFromProtoFormat()
|
| H A D | ApplicationAttemptFinishDataPBImpl.java | 65 convertFromProtoFormat(p.getApplicationAttemptId()); in getApplicationAttemptId()
123 return convertFromProtoFormat(p.getFinalApplicationStatus()); in getFinalApplicationStatus()
144 return convertFromProtoFormat(p.getYarnApplicationAttemptState()); in getYarnApplicationAttemptState()
209 private ApplicationAttemptIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationAttemptFinishDataPBImpl
219 private FinalApplicationStatus convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationAttemptFinishDataPBImpl
221 return ProtoUtils.convertFromProtoFormat(finalApplicationStatus); in convertFromProtoFormat()
234 private YarnApplicationAttemptState convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationAttemptFinishDataPBImpl
236 return ProtoUtils.convertFromProtoFormat(yarnApplicationAttemptState); in convertFromProtoFormat()
|
| H A D | ContainerStartDataPBImpl.java | 68 this.containerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
90 this.resource = convertFromProtoFormat(p.getAllocatedResource()); in getAllocatedResource()
112 this.nodeId = convertFromProtoFormat(p.getAssignedNodeId()); in getAssignedNode()
134 this.priority = convertFromProtoFormat(p.getPriority()); in getPriority()
230 convertFromProtoFormat(ContainerIdProto containerId) { in convertFromProtoFormat() method in ContainerStartDataPBImpl
238 private ResourcePBImpl convertFromProtoFormat(ResourceProto resource) { in convertFromProtoFormat() method in ContainerStartDataPBImpl
246 private NodeIdPBImpl convertFromProtoFormat(NodeIdProto nodeId) { in convertFromProtoFormat() method in ContainerStartDataPBImpl
254 private PriorityPBImpl convertFromProtoFormat(PriorityProto priority) { in convertFromProtoFormat() method in ContainerStartDataPBImpl
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/ |
| H A D | AllocateResponsePBImpl.java | 186 return ProtoUtils.convertFromProtoFormat(p.getAMCommand()); in getAMCommand()
221 this.limit = convertFromProtoFormat(p.getLimit()); in getAvailableResources()
322 this.preempt = convertFromProtoFormat(p.getPreempt()); in getPreemptionMessage()
375 this.amrmToken = convertFromProtoFormat(p.getAmRmToken()); in getAMRMToken()
397 increasedContainers.add(convertFromProtoFormat(c)); in initLocalIncreasedContainerList()
410 decreasedContainers.add(convertFromProtoFormat(c)); in initLocalDecreasedContainerList()
425 updatedNodes.add(convertFromProtoFormat(n)); in initLocalNewNodeReportList()
440 allocatedContainers.add(convertFromProtoFormat(c)); in initLocalNewContainerList()
452 nmTokens.add(convertFromProtoFormat(t)); in initLocalNewNMTokenList()
687 private synchronized ContainerPBImpl convertFromProtoFormat(
[all …]
|
| H A D | StartContainersResponsePBImpl.java | 106 protected final ByteBuffer convertFromProtoFormat(ByteString byteString) { in convertFromProtoFormat() method in StartContainersResponsePBImpl
107 return ProtoUtils.convertFromProtoFormat(byteString); in convertFromProtoFormat()
114 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in StartContainersResponsePBImpl
122 private SerializedExceptionPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in StartContainersResponsePBImpl
173 convertFromProtoFormat(c.getValue())); in initServicesMetaData()
272 this.succeededContainers.add(convertFromProtoFormat(c)); in initSucceededContainers()
300 this.failedContainers.put(convertFromProtoFormat(ce.getContainerId()), in initFailedContainers()
301 convertFromProtoFormat(ce.getException())); in initFailedContainers()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/ |
| H A D | NMContainerStatusPBImpl.java | 96 this.resource = convertFromProtoFormat(p.getResource()); in getAllocatedResource()
109 this.containerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
128 return convertFromProtoFormat(p.getContainerState()); in getContainerState()
187 this.priority = convertFromProtoFormat(p.getPriority()); in getPriority()
244 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in NMContainerStatusPBImpl
252 private ResourcePBImpl convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in NMContainerStatusPBImpl
265 private ContainerState convertFromProtoFormat( in convertFromProtoFormat() method in NMContainerStatusPBImpl
267 return ProtoUtils.convertFromProtoFormat(containerState); in convertFromProtoFormat()
270 private PriorityPBImpl convertFromProtoFormat(PriorityProto p) { in convertFromProtoFormat() method in NMContainerStatusPBImpl
|
| H A D | NodeHeartbeatResponsePBImpl.java | 150 convertFromProtoFormat(p.getContainerTokenMasterKey()); in getContainerTokenMasterKey()
172 convertFromProtoFormat(p.getNmTokenMasterKey()); in getNMTokenMasterKey()
190 return (convertFromProtoFormat(p.getNodeAction())); in getNodeAction()
243 this.containersToCleanup.add(convertFromProtoFormat(c)); in initContainersToCleanup()
256 this.containersToBeRemovedFromNM.add(convertFromProtoFormat(c)); in initContainersToBeRemovedFromNM()
363 this.applicationsToCleanup.add(convertFromProtoFormat(c)); in initApplicationsToCleanup()
426 ApplicationId appId = convertFromProtoFormat(c.getAppId()); in initSystemCredentials()
455 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in NodeHeartbeatResponsePBImpl
463 private ApplicationIdPBImpl convertFromProtoFormat(ApplicationIdProto p) { in convertFromProtoFormat() method in NodeHeartbeatResponsePBImpl
471 private NodeAction convertFromProtoFormat(NodeActionProto p) { in convertFromProtoFormat() method in NodeHeartbeatResponsePBImpl
[all …]
|
| H A D | RegisterNodeManagerRequestPBImpl.java | 129 this.resource = convertFromProtoFormat(p.getResource()); in getResource()
150 this.nodeId = convertFromProtoFormat(p.getNodeId()); in getNodeId()
191 this.runningApplications.add(convertFromProtoFormat(c)); in initRunningApplications()
251 this.containerStatuses.add(convertFromProtoFormat(c)); in initContainerRecoveryReports()
295 private ApplicationIdPBImpl convertFromProtoFormat(ApplicationIdProto p) { in convertFromProtoFormat() method in RegisterNodeManagerRequestPBImpl
303 private NodeIdPBImpl convertFromProtoFormat(NodeIdProto p) { in convertFromProtoFormat() method in RegisterNodeManagerRequestPBImpl
311 private ResourcePBImpl convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in RegisterNodeManagerRequestPBImpl
319 private NMContainerStatusPBImpl convertFromProtoFormat(NMContainerStatusProto c) { in convertFromProtoFormat() method in RegisterNodeManagerRequestPBImpl
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/util/ |
| H A D | MRProtoUtils.java | 43 public static JobState convertFromProtoFormat(JobStateProto e) { in convertFromProtoFormat() method in MRProtoUtils
54 public static Phase convertFromProtoFormat(PhaseProto e) { in convertFromProtoFormat() method in MRProtoUtils
65 …public static TaskAttemptCompletionEventStatus convertFromProtoFormat(TaskAttemptCompletionEventSt… in convertFromProtoFormat() method in MRProtoUtils
76 public static TaskAttemptState convertFromProtoFormat(TaskAttemptStateProto e) { in convertFromProtoFormat() method in MRProtoUtils
87 public static TaskState convertFromProtoFormat(TaskStateProto e) { in convertFromProtoFormat() method in MRProtoUtils
97 public static TaskType convertFromProtoFormat(TaskTypeProto e) { in convertFromProtoFormat() method in MRProtoUtils
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/api/protocolrecords/impl/pb/ |
| H A D | LocalResourceStatusPBImpl.java | 106 this.resource = convertFromProtoFormat(p.getResource()); in getResource()
116 return convertFromProtoFormat(p.getStatus()); in getStatus()
128 this.localPath = convertFromProtoFormat(p.getLocalPath()); in getLocalPath()
147 this.exception = convertFromProtoFormat(p.getException()); in getException()
196 private LocalResourcePBImpl convertFromProtoFormat(LocalResourceProto rsrc) { in convertFromProtoFormat() method in LocalResourceStatusPBImpl
200 private URLPBImpl convertFromProtoFormat(URLProto p) { in convertFromProtoFormat() method in LocalResourceStatusPBImpl
212 private ResourceStatusType convertFromProtoFormat(ResourceStatusTypeProto e) { in convertFromProtoFormat() method in LocalResourceStatusPBImpl
216 private SerializedExceptionPBImpl convertFromProtoFormat(SerializedExceptionProto p) { in convertFromProtoFormat() method in LocalResourceStatusPBImpl
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/records/impl/pb/ |
| H A D | NodeStatusPBImpl.java | 201 this.nodeId = convertFromProtoFormat(p.getNodeId()); in getNodeId()
253 this.containers.add(convertFromProtoFormat(c)); in initContainers()
267 this.keepAliveApplications.add(convertFromProtoFormat(c)); in initKeepAliveApplications()
281 nodeHealthStatus = convertFromProtoFormat(p.getNodeHealthStatus()); in getNodeHealthStatus()
298 private NodeId convertFromProtoFormat(NodeIdProto proto) { in convertFromProtoFormat() method in NodeStatusPBImpl
307 private NodeHealthStatus convertFromProtoFormat(NodeHealthStatusProto proto) { in convertFromProtoFormat() method in NodeStatusPBImpl
311 private ContainerStatusPBImpl convertFromProtoFormat(ContainerStatusProto c) { in convertFromProtoFormat() method in NodeStatusPBImpl
319 private ApplicationIdPBImpl convertFromProtoFormat(ApplicationIdProto c) { in convertFromProtoFormat() method in NodeStatusPBImpl
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/ |
| H A D | GetTaskReportsRequestPBImpl.java | 90 this.jobId = convertFromProtoFormat(p.getJobId()); in getJobId()
107 return convertFromProtoFormat(p.getTaskType()); in getTaskType()
120 private JobIdPBImpl convertFromProtoFormat(JobIdProto p) { in convertFromProtoFormat() method in GetTaskReportsRequestPBImpl
132 private TaskType convertFromProtoFormat(TaskTypeProto e) { in convertFromProtoFormat() method in GetTaskReportsRequestPBImpl
133 return MRProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
|