more linting fixes

Author: bradmiro

dataproc/src/main/java/CreateClusterWithAutoscaling.java

@@ -13,8 +13,8 @@
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
-* This sample creates a Dataproc cluster with an autoscaling policy enabled. The policy we will be creating mirrors
-* the following YAML representation:
+* This sample creates a Dataproc cluster with an autoscaling policy enabled.
+* The policy we will be creating mirrors the following YAML representation:
 *
    workerConfig:
      minInstances: 2
@@ -37,7 +37,20 @@
 // [START dataproc_create_autoscaling_cluster]
 
 import com.google.api.gax.longrunning.OperationFuture;
-import com.google.cloud.dataproc.v1.*;
+import com.google.cloud.dataproc.v1.AutoscalingConfig;
+import com.google.cloud.dataproc.v1.AutoscalingPolicy;
+import com.google.cloud.dataproc.v1.AutoscalingPolicyServiceClient;
+import com.google.cloud.dataproc.v1.AutoscalingPolicyServiceSettings;
+import com.google.cloud.dataproc.v1.BasicAutoscalingAlgorithm;
+import com.google.cloud.dataproc.v1.BasicYarnAutoscalingConfig;
+import com.google.cloud.dataproc.v1.Cluster;
+import com.google.cloud.dataproc.v1.ClusterConfig;
+import com.google.cloud.dataproc.v1.ClusterControllerClient;
+import com.google.cloud.dataproc.v1.ClusterControllerSettings;
+import com.google.cloud.dataproc.v1.ClusterOperationMetadata;
+import com.google.cloud.dataproc.v1.InstanceGroupAutoscalingPolicyConfig;
+import com.google.cloud.dataproc.v1.InstanceGroupConfig;
+import com.google.cloud.dataproc.v1.RegionName;
 import com.google.protobuf.Duration;
 
 import java.io.IOException;
@@ -74,7 +87,7 @@ public static void createClusterwithAutoscaling(
     // method.
     try (ClusterControllerClient clusterControllerClient =
             ClusterControllerClient.create(clusterControllerSettings);
-        AutoscalingPolicyServiceClient autoscalingPolicyServiceClient =
+         AutoscalingPolicyServiceClient autoscalingPolicyServiceClient =
             AutoscalingPolicyServiceClient.create(autoscalingPolicyServiceSettings)) {
 
       // Create the Autoscaling policy.

dataproc/src/main/java/SubmitHadoopFsJob.java

@@ -15,8 +15,14 @@
  */
 
 // [START dataproc_submit_hadoop_fs_job]
+
 import com.google.api.gax.longrunning.OperationFuture;
-import com.google.cloud.dataproc.v1.*;
+import com.google.cloud.dataproc.v1.HadoopJob;
+import com.google.cloud.dataproc.v1.Job;
+import com.google.cloud.dataproc.v1.JobControllerClient;
+import com.google.cloud.dataproc.v1.JobControllerSettings;
+import com.google.cloud.dataproc.v1.JobMetadata;
+import com.google.cloud.dataproc.v1.JobPlacement;
 import com.google.cloud.storage.Blob;
 import com.google.cloud.storage.Storage;
 import com.google.cloud.storage.StorageOptions;
@@ -28,22 +34,22 @@
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
-public class SubmitHadoopFSJob {
+public class SubmitHadoopFsJob {
 
   public static ArrayList<String> stringToList(String s) {
     return new ArrayList<>(Arrays.asList(s.split(" ")));
   }
 
-  public static void submitHadoopFSJob() throws IOException, InterruptedException {
+  public static void submitHadoopFsJob() throws IOException, InterruptedException {
     // TODO(developer): Replace these variables before running the sample.
     String projectId = "your-project-id";
     String region = "your-project-region";
     String clusterName = "your-cluster-name";
     String hadoopFSQuery = "your-hadoop-fs-query";
-    submitHadoopFSJob(projectId, region, clusterName, hadoopFSQuery);
+    submitHadoopFsJob(projectId, region, clusterName, hadoopFSQuery);
   }
 
-  public static void submitHadoopFSJob(
+  public static void submitHadoopFsJob(
       String projectId, String region, String clusterName, String hadoopFSQuery)
       throws IOException, InterruptedException {
     String myEndpoint = String.format("%s-dataproc.googleapis.com:443", region);