private void addFailedRequestsToProto() { maybeInitBuilder(); builder.clearFailedRequests(); if (this.failedRequests == null) return; List<ContainerExceptionMapProto> protoList = new ArrayList<ContainerExceptionMapProto>(); for (Map.Entry<ContainerId, SerializedException> entry : this.failedRequests .entrySet()) { protoList.add(ContainerExceptionMapProto.newBuilder() .setContainerId(convertToProtoFormat(entry.getKey())) .setException(convertToProtoFormat(entry.getValue())).build()); } builder.addAllFailedRequests(protoList); }
private void addFailedContainersToProto() { maybeInitBuilder(); builder.clearFailedRequests(); if (this.failedContainers == null) return; List<ContainerExceptionMapProto> protoList = new ArrayList<ContainerExceptionMapProto>(); for (Map.Entry<ContainerId, SerializedException> entry : this.failedContainers .entrySet()) { protoList.add(ContainerExceptionMapProto.newBuilder() .setContainerId(convertToProtoFormat(entry.getKey())) .setException(convertToProtoFormat(entry.getValue())).build()); } builder.addAllFailedRequests(protoList); }
private void addFailedRequestsToProto() { maybeInitBuilder(); builder.clearFailedRequests(); if (this.failedRequests == null) { return; } List<ContainerExceptionMapProto> protoList = new ArrayList<ContainerExceptionMapProto>(); for (Map.Entry<ContainerId, SerializedException> entry : this.failedRequests .entrySet()) { protoList.add(ContainerExceptionMapProto.newBuilder() .setContainerId(convertToProtoFormat(entry.getKey())) .setException(convertToProtoFormat(entry.getValue())).build()); } builder.addAllFailedRequests(protoList); }
private void initFailedRequests() { if (this.failedRequests != null) { return; } StopContainersResponseProtoOrBuilder p = viaProto ? proto : builder; List<ContainerExceptionMapProto> protoList = p.getFailedRequestsList(); this.failedRequests = new HashMap<ContainerId, SerializedException>(); for (ContainerExceptionMapProto ce : protoList) { this.failedRequests.put(convertFromProtoFormat(ce.getContainerId()), convertFromProtoFormat(ce.getException())); } }
private void initFailedRequests() { if (this.failedRequests != null) { return; } GetContainerStatusesResponseProtoOrBuilder p = viaProto ? proto : builder; List<ContainerExceptionMapProto> protoList = p.getFailedRequestsList(); this.failedRequests = new HashMap<ContainerId, SerializedException>(); for (ContainerExceptionMapProto ce : protoList) { this.failedRequests.put(convertFromProtoFormat(ce.getContainerId()), convertFromProtoFormat(ce.getException())); } }
private void initFailedContainers() { if (this.failedContainers != null) { return; } StartContainersResponseProtoOrBuilder p = viaProto ? proto : builder; List<ContainerExceptionMapProto> protoList = p.getFailedRequestsList(); this.failedContainers = new HashMap<ContainerId, SerializedException>(); for (ContainerExceptionMapProto ce : protoList) { this.failedContainers.put(convertFromProtoFormat(ce.getContainerId()), convertFromProtoFormat(ce.getException())); } }
private void initFailedRequests() { if (this.failedRequests != null) { return; } IncreaseContainersResourceResponseProtoOrBuilder p = viaProto ? proto : builder; List<ContainerExceptionMapProto> protoList = p.getFailedRequestsList(); this.failedRequests = new HashMap<ContainerId, SerializedException>(); for (ContainerExceptionMapProto ce : protoList) { this.failedRequests.put(convertFromProtoFormat(ce.getContainerId()), convertFromProtoFormat(ce.getException())); } }