class PersistentVolumeExample {
  private static final Logger logger = LoggerFactory.getLogger(PersistentVolumeExample.class);

  public static void main(String[] args) {<FILL_FUNCTION_BODY>}

}

    final ConfigBuilder configBuilder = new ConfigBuilder();
    if (args.length > 0) {
      configBuilder.withMasterUrl(args[0]);
      logger.info("Using master with URL: {}", args[0]);
    }
    try (KubernetesClient client = new KubernetesClientBuilder().withConfig(configBuilder.build()).build()) {
      logger.info("Creating persistent volume object");
      PersistentVolume pv = new PersistentVolumeBuilder()
          .withNewMetadata().withName("example-local-pv").endMetadata()
          .withNewSpec()
          .addToCapacity(Collections.singletonMap("storage", new Quantity("500Gi")))
          .withAccessModes("ReadWriteOnce")
          .withPersistentVolumeReclaimPolicy("Retain")
          .withStorageClassName("local-storage")
          .withNewLocal()
          .withPath("/mnt/disks/vol1")
          .endLocal()
          .withNewNodeAffinity()
          .withNewRequired()
          .addNewNodeSelectorTerm()
          .withMatchExpressions(Collections.singletonList(new NodeSelectorRequirementBuilder()
              .withKey("kubernetes.io/hostname")
              .withOperator("In")
              .withValues("my-node")
              .build()))
          .endNodeSelectorTerm()
          .endRequired()
          .endNodeAffinity()
          .endSpec()
          .build();

      client.persistentVolumes().resource(pv).create();
      logger.info("Successfully created Persistent Volume object");
    } catch (KubernetesClientException e) {
      logger.error("Could not create resource: {}", e.getMessage(), e);
    }
  
<no_super_class>