| /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 | NodeHeartbeatRequestPBImpl.java | 110 this.nodeStatus = convertFromProtoFormat(p.getNodeStatus()); in getNodeStatus()
132 convertFromProtoFormat(p.getLastKnownContainerTokenMasterKey()); in getLastKnownContainerTokenMasterKey()
154 convertFromProtoFormat(p.getLastKnownNmTokenMasterKey()); in getLastKnownNMTokenMasterKey()
166 private NodeStatusPBImpl convertFromProtoFormat(NodeStatusProto p) { in convertFromProtoFormat() method in NodeHeartbeatRequestPBImpl
174 private MasterKeyPBImpl convertFromProtoFormat(MasterKeyProto p) { in convertFromProtoFormat() method in NodeHeartbeatRequestPBImpl
|
| H A D | RegisterNodeManagerResponsePBImpl.java | 98 convertFromProtoFormat(p.getContainerTokenMasterKey()); in getContainerTokenMasterKey()
121 convertFromProtoFormat(p.getNmTokenMasterKey()); in getNMTokenMasterKey()
178 return convertFromProtoFormat(p.getNodeAction()); in getNodeAction()
204 private NodeAction convertFromProtoFormat(NodeActionProto p) { in convertFromProtoFormat() method in RegisterNodeManagerResponsePBImpl
212 private MasterKeyPBImpl convertFromProtoFormat(MasterKeyProto p) { in convertFromProtoFormat() method in RegisterNodeManagerResponsePBImpl
|
| /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 | ContainerStatusPBImpl.java | 115 return convertFromProtoFormat(p.getState()); in getState()
136 this.containerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
175 private ContainerState convertFromProtoFormat(ContainerStateProto e) { in convertFromProtoFormat() method in ContainerStatusPBImpl
176 return ProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
179 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in ContainerStatusPBImpl
|
| H A D | ContainerResourceIncreaseRequestPBImpl.java | 65 this.existingContainerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
87 this.targetCapability = convertFromProtoFormat(p.getCapability()); in getCapability()
101 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in ContainerResourceIncreaseRequestPBImpl
109 private Resource convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in ContainerResourceIncreaseRequestPBImpl
|
| H A D | ContainerResourceDecreasePBImpl.java | 61 this.existingContainerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
82 this.targetCapability = convertFromProtoFormat(p.getCapability()); in getCapability()
96 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in ContainerResourceDecreasePBImpl
104 private Resource convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in ContainerResourceDecreasePBImpl
|
| H A D | QueueInfoPBImpl.java | 102 return convertFromProtoFormat(p.getState()); in getQueueState()
195 applicationsList.add(convertFromProtoFormat(a)); in initLocalApplicationsList()
242 childQueuesList.add(convertFromProtoFormat(a)); in initLocalChildQueuesList()
309 private ApplicationReportPBImpl convertFromProtoFormat(ApplicationReportProto a) { in convertFromProtoFormat() method in QueueInfoPBImpl
317 private QueueInfoPBImpl convertFromProtoFormat(QueueInfoProto a) { in convertFromProtoFormat() method in QueueInfoPBImpl
325 private QueueState convertFromProtoFormat(QueueStateProto q) { in convertFromProtoFormat() method in QueueInfoPBImpl
326 return ProtoUtils.convertFromProtoFormat(q); in convertFromProtoFormat()
|
| H A D | NMTokenPBImpl.java | 60 this.nodeId = convertFromProtoFormat(p.getNodeId()); in getNodeId()
82 this.token = convertFromProtoFormat(p.getToken()); in getToken()
127 private synchronized NodeId convertFromProtoFormat(NodeIdProto p) { in convertFromProtoFormat() method in NMTokenPBImpl
139 private synchronized Token convertFromProtoFormat(TokenProto proto) { in convertFromProtoFormat() method in NMTokenPBImpl
|
| H A D | NodeReportPBImpl.java | 68 this.capability = convertFromProtoFormat(p.getCapability()); in getCapability()
128 this.used = convertFromProtoFormat(p.getUsed()); in getUsed()
142 this.nodeId = convertFromProtoFormat(p.getNodeId()); in getNodeId()
160 return ProtoUtils.convertFromProtoFormat(p.getNodeState()); in getNodeState()
284 private NodeIdPBImpl convertFromProtoFormat(NodeIdProto p) { in convertFromProtoFormat() method in NodeReportPBImpl
292 private ResourcePBImpl convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in NodeReportPBImpl
|
| H A D | PreemptionMessagePBImpl.java | 112 strict = convertFromProtoFormat(p.getStrictContract()); in getStrictContract()
134 contract = convertFromProtoFormat(p.getContract()); in getContract()
147 private StrictPreemptionContractPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in PreemptionMessagePBImpl
157 private PreemptionContractPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in PreemptionMessagePBImpl
|
| H A D | TokenPBImpl.java | 72 protected final ByteBuffer convertFromProtoFormat(ByteString byteString) { in convertFromProtoFormat() method in TokenPBImpl
73 return ProtoUtils.convertFromProtoFormat(byteString); in convertFromProtoFormat()
113 this.identifier = convertFromProtoFormat(p.getIdentifier()); in getIdentifier()
134 this.password = convertFromProtoFormat(p.getPassword()); in getPassword()
|
| H A D | ContainerLaunchContextPBImpl.java | 96 protected final ByteBuffer convertFromProtoFormat(ByteString byteString) { in convertFromProtoFormat() method in ContainerLaunchContextPBImpl
97 return ProtoUtils.convertFromProtoFormat(byteString); in convertFromProtoFormat()
191 this.localResources.put(c.getKey(), convertFromProtoFormat(c.getValue())); in initLocalResources()
250 this.tokens = convertFromProtoFormat(p.getTokens()); in getTokens()
278 this.serviceData.put(c.getKey(), convertFromProtoFormat(c.getValue())); in initServiceData()
406 this.applicationACLS.put(ProtoUtils.convertFromProtoFormat(aclProto in initApplicationACLs()
459 private LocalResourcePBImpl convertFromProtoFormat(LocalResourceProto p) { in convertFromProtoFormat() method in ContainerLaunchContextPBImpl
|
| H A D | ResourceRequestPBImpl.java | 93 this.priority = convertFromProtoFormat(p.getPriority()); in getPriority()
131 this.capability = convertFromProtoFormat(p.getCapability()); in getCapability()
166 private PriorityPBImpl convertFromProtoFormat(PriorityProto p) { in convertFromProtoFormat() method in ResourceRequestPBImpl
174 private ResourcePBImpl convertFromProtoFormat(ResourceProto p) { in convertFromProtoFormat() method in ResourceRequestPBImpl
|
| /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 | ContainerFinishDataPBImpl.java | 60 this.containerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
116 return convertFromProtoFormat(p.getContainerState()); in getContainerState()
191 convertFromProtoFormat(ContainerIdProto containerId) { in convertFromProtoFormat() method in ContainerFinishDataPBImpl
199 private ContainerState convertFromProtoFormat( in convertFromProtoFormat() method in ContainerFinishDataPBImpl
201 return ProtoUtils.convertFromProtoFormat(containerState); in convertFromProtoFormat()
|
| H A D | ApplicationAttemptStartDataPBImpl.java | 64 convertFromProtoFormat(p.getApplicationAttemptId()); in getApplicationAttemptId()
118 this.masterContainerId = convertFromProtoFormat(p.getMasterContainerId()); in getMasterContainerId()
189 private ApplicationAttemptIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ApplicationAttemptStartDataPBImpl
200 convertFromProtoFormat(ContainerIdProto containerId) { in convertFromProtoFormat() method in ApplicationAttemptStartDataPBImpl
|
| /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 | AllocateRequestPBImpl.java | 190 this.blacklistRequest = convertFromProtoFormat(p.getBlacklistRequest()); in getResourceBlacklistRequest()
212 this.ask.add(convertFromProtoFormat(c)); in initAsks()
260 this.increaseRequests.add(convertFromProtoFormat(c)); in initIncreaseRequests()
324 this.release.add(convertFromProtoFormat(c)); in initReleases()
362 private ResourceRequestPBImpl convertFromProtoFormat(ResourceRequestProto p) { in convertFromProtoFormat() method in AllocateRequestPBImpl
370 private ContainerResourceIncreaseRequestPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in AllocateRequestPBImpl
380 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in AllocateRequestPBImpl
388 private ResourceBlacklistRequestPBImpl convertFromProtoFormat(ResourceBlacklistRequestProto p) { in convertFromProtoFormat() method in AllocateRequestPBImpl
|
| H A D | GetContainerStatusesResponsePBImpl.java | 154 this.containerStatuses.add(convertFromProtoFormat(status)); in initLocalContainerStatuses()
166 this.failedRequests.put(convertFromProtoFormat(ce.getContainerId()), in initFailedRequests()
167 convertFromProtoFormat(ce.getException())); in initFailedRequests()
200 private ContainerStatusPBImpl convertFromProtoFormat(ContainerStatusProto p) { in convertFromProtoFormat() method in GetContainerStatusesResponsePBImpl
208 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in GetContainerStatusesResponsePBImpl
216 private SerializedExceptionPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in GetContainerStatusesResponsePBImpl
|
| H A D | ReservationUpdateRequestPBImpl.java | 94 convertFromProtoFormat(p.getReservationDefinition()); in getReservationDefinition()
117 reservationId = convertFromProtoFormat(p.getReservationId()); in getReservationId()
131 private ReservationIdPBImpl convertFromProtoFormat(ReservationIdProto p) { in convertFromProtoFormat() method in ReservationUpdateRequestPBImpl
144 private ReservationDefinitionPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in ReservationUpdateRequestPBImpl
|
| H A D | StopContainersResponsePBImpl.java | 172 this.succeededRequests.add(convertFromProtoFormat(c)); in initSucceededRequests()
184 this.failedRequests.put(convertFromProtoFormat(ce.getContainerId()), in initFailedRequests()
185 convertFromProtoFormat(ce.getException())); in initFailedRequests()
219 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in StopContainersResponsePBImpl
227 private SerializedExceptionPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in StopContainersResponsePBImpl
|
| H A D | GetNewApplicationResponsePBImpl.java | 118 this.applicationId = convertFromProtoFormat(p.getApplicationId()); in getApplicationId()
141 this.maximumResourceCapability = convertFromProtoFormat(p.getMaximumCapability()); in getMaximumResourceCapability()
154 private ApplicationIdPBImpl convertFromProtoFormat(ApplicationIdProto p) { in convertFromProtoFormat() method in GetNewApplicationResponsePBImpl
162 private Resource convertFromProtoFormat(ResourceProto resource) { in convertFromProtoFormat() method in GetNewApplicationResponsePBImpl
|
| H A D | StartContainerRequestPBImpl.java | 117 this.containerLaunchContext = convertFromProtoFormat(p.getContainerLaunchContext()); in getContainerLaunchContext()
138 this.containerToken = convertFromProtoFormat(p.getContainerToken()); in getContainerToken()
151 private ContainerLaunchContextPBImpl convertFromProtoFormat(ContainerLaunchContextProto p) { in convertFromProtoFormat() method in StartContainerRequestPBImpl
161 private TokenPBImpl convertFromProtoFormat(TokenProto containerProto) { in convertFromProtoFormat() method in StartContainerRequestPBImpl
|
| H A D | RegisterApplicationMasterResponsePBImpl.java | 147 this.maximumResourceCapability = convertFromProtoFormat(p.getMaximumCapability()); in getMaximumResourceCapability()
177 this.applicationACLS.put(ProtoUtils.convertFromProtoFormat(aclProto in initApplicationACLs()
293 containersFromPreviousAttempts.add(convertFromProtoFormat(c)); in initContainersPreviousAttemptList()
336 nmTokens.add(convertFromProtoFormat(t)); in initLocalNewNMTokenList()
436 private Resource convertFromProtoFormat(ResourceProto resource) {
444 private ContainerPBImpl convertFromProtoFormat(ContainerProto p) {
456 private NMToken convertFromProtoFormat(NMTokenProto proto) {
|
| /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 | JobReportPBImpl.java | 99 this.jobId = convertFromProtoFormat(p.getJobId()); in getJobId()
116 return convertFromProtoFormat(p.getJobState()); in getJobState()
298 this.amInfos.add(convertFromProtoFormat(amInfoProto)); in initAMInfos()
312 private AMInfoPBImpl convertFromProtoFormat(AMInfoProto p) { in convertFromProtoFormat() method in JobReportPBImpl
320 private JobIdPBImpl convertFromProtoFormat(JobIdProto p) { in convertFromProtoFormat() method in JobReportPBImpl
332 private JobState convertFromProtoFormat(JobStateProto e) { in convertFromProtoFormat() method in JobReportPBImpl
333 return MRProtoUtils.convertFromProtoFormat(e); in convertFromProtoFormat()
|
| H A D | AMInfoPBImpl.java | 94 appAttemptId = convertFromProtoFormat(p.getApplicationAttemptId()); in getAppAttemptId()
128 containerId = convertFromProtoFormat(p.getContainerId()); in getContainerId()
184 private ApplicationAttemptIdPBImpl convertFromProtoFormat( in convertFromProtoFormat() method in AMInfoPBImpl
189 private ContainerIdPBImpl convertFromProtoFormat(ContainerIdProto p) { in convertFromProtoFormat() method in AMInfoPBImpl
|
| /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 | LocalizerHeartbeatResponsePBImpl.java | 90 return convertFromProtoFormat(p.getAction()); in getLocalizerAction()
125 this.resourceSpecs.add(convertFromProtoFormat(c)); in initResources()
167 private ResourceLocalizationSpec convertFromProtoFormat( in convertFromProtoFormat() method in LocalizerHeartbeatResponsePBImpl
176 private LocalizerAction convertFromProtoFormat(LocalizerActionProto a) { in convertFromProtoFormat() method in LocalizerHeartbeatResponsePBImpl
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/ |
| H A D | UpdateNodeResourceRequestPBImpl.java | 100 this.nodeResourceMap.put(convertFromProtoFormat(nodeResourceProto.getNodeId()), in initNodeResourceMap()
101 convertFromProtoFormat(nodeResourceProto.getResourceOption())); in initNodeResourceMap()
116 private NodeId convertFromProtoFormat(NodeIdProto proto) { in convertFromProtoFormat() method in UpdateNodeResourceRequestPBImpl
120 private ResourceOptionPBImpl convertFromProtoFormat(ResourceOptionProto c) { in convertFromProtoFormat() method in UpdateNodeResourceRequestPBImpl
|