public T decorate()

in spark-operator/src/main/java/org/apache/spark/k8s/operator/decorators/DriverResourceDecorator.java [49:72]

• 24 lines of code
• 8 McCabe index (conditional complexity)

  public <T extends HasMetadata> T decorate(T resource) {
    boolean ownerReferenceExists = false;
    if (resource.getMetadata().getOwnerReferences() != null
        && !resource.getMetadata().getOwnerReferences().isEmpty()) {
      for (OwnerReference o : resource.getMetadata().getOwnerReferences()) {
        if (driverPod.getKind().equals(o.getKind())
            && driverPod.getMetadata().getName().equals(o.getName())
            && driverPod.getMetadata().getUid().equals(o.getUid())) {
          ownerReferenceExists = true;
          break;
        }
      }
    }
    if (!ownerReferenceExists) {
      log.debug("Adding OwnerReference to driver for secondary resource");
      ObjectMeta metaData =
          new ObjectMetaBuilder(resource.getMetadata())
              .addToOwnerReferences(buildOwnerReferenceTo(driverPod))
              .addToLabels(driverPod.getMetadata().getLabels())
              .build();
      resource.setMetadata(metaData);
    }
    return resource;
  }