Add setter and getter methods for iops and throughput

Author: bambadiouf1

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java

@@ -193,16 +193,19 @@ public String getAlgorithm() {
 
   void setWorkerDiskType(String value);
 
-@Description("IOPS provisioned for the root disk for VMs. If zero or " +
-             "unspecified, the service will attempt to choose a reasonable default.")
-Long getDiskProvisionedIops();
-void setDiskProvisionedIops(Long diskProvisionedIops);
+  @Description(
+      "IOPS provisioned for the root disk for VMs. If zero or "
+          + "unspecified, the service will attempt to choose a reasonable default.")
+  Long getDiskProvisionedIops();
+
+  void setDiskProvisionedIops(Long diskProvisionedIops);
 
-@Description("Throughput provisioned in MiB/s for the root disk for VMs. If zero or " +
-             "unspecified, the service will attempt to choose a reasonable default.")
-Long getDiskProvisionedThroughputMibps();
-void setDiskProvisionedThroughputMibps(Long diskProvisionedThroughputMibps);
+  @Description(
+      "Throughput provisioned in MiB/s for the root disk for VMs. If zero or "
+          + "unspecified, the service will attempt to choose a reasonable default.")
+  Long getDiskProvisionedThroughputMibps();
 
+  void setDiskProvisionedThroughputMibps(Long diskProvisionedThroughputMibps);
 
   /**
    * Specifies whether worker pools should be started with public IP addresses.

runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslatorTest.java

@@ -619,29 +619,31 @@ public void testDiskSizeGbConfig() throws IOException {
     assertEquals(diskSizeGb, job.getEnvironment().getWorkerPools().get(0).getDiskSizeGb());
   }
 
-   @Test
-    public void testDiskProvisioningTranslation() {
-        DataflowPipelineOptions options = PipelineOptionsFactory.create().as(DataflowPipelineOptions.class);
-        options.setDiskProvisionedIops(Long.valueOf(7000));
-        options.setDiskProvisionedThroughputMibps(Long.valueOf(250));
-        options.setProject("test-project"); // Required for translator
+  @Test
+  public void testDiskProvisioningTranslation() {
+    DataflowPipelineOptions options =
+        PipelineOptionsFactory.create().as(DataflowPipelineOptions.class);
+    options.setDiskProvisionedIops(Long.valueOf(7000));
+    options.setDiskProvisionedThroughputMibps(Long.valueOf(250));
+    options.setProject("test-project"); // Required for translator
 
-        WorkerPool pool = translateWorkerPool(options);
+    WorkerPool pool = translateWorkerPool(options);
 
-        assertEquals(Long.valueOf(7000), pool.getDiskProvisionedIops());
-        assertEquals(Long.valueOf(250), pool.getDiskProvisionedThroughputMibps());
-    }
+    assertEquals(Long.valueOf(7000), pool.getDiskProvisionedIops());
+    assertEquals(Long.valueOf(250), pool.getDiskProvisionedThroughputMibps());
+  }
 
-    @Test
-    public void testDiskProvisioningTranslationDefaults() {
-        DataflowPipelineOptions options = PipelineOptionsFactory.create().as(DataflowPipelineOptions.class);
-        options.setProject("test-project"); // Required for translator
+  @Test
+  public void testDiskProvisioningTranslationDefaults() {
+    DataflowPipelineOptions options =
+        PipelineOptionsFactory.create().as(DataflowPipelineOptions.class);
+    options.setProject("test-project"); // Required for translator
 
-        WorkerPool pool = translateWorkerPool(options);
+    WorkerPool pool = translateWorkerPool(options);
 
-        assertNull(pool.getDiskProvisionedIops());
-        assertNull(pool.getDiskProvisionedThroughputMibps());
-    }
+    assertNull(pool.getDiskProvisionedIops());
+    assertNull(pool.getDiskProvisionedThroughputMibps());
+  }
 
   /** A composite transform that returns an output that is unrelated to the input. */
   private static class UnrelatedOutputCreator