Fixed checkstyle issues

Author: shweta-deosarkar

src/main/java/io/cdap/plugin/gcp/gcs/source/GCSSource.java

@@ -68,6 +68,7 @@
 @Description("Reads objects from a path in a Google Cloud Storage bucket.")
 @Metadata(properties = {@MetadataProperty(key = Connector.PLUGIN_TYPE, value = GCSConnector.NAME)})
 public class GCSSource extends AbstractFileSource<GCSSource.GCSSourceConfig> {
+
   public static final String NAME = "GCSFile";
   private final GCSSourceConfig config;
   private Asset asset;
@@ -121,34 +122,35 @@ public void prepareRun(BatchSourceContext context) throws Exception {
     }
 
     Storage storage = GCPUtils.getStorage(config.connection.getProject(), credentials);
-    Bucket bucket = storage.get(bucketName);
-    if (Objects.isNull(bucket)) {
-      String errorReason = String.format("Unable to access GCS bucket '%s'.",
-              bucketName);
-      collector.addFailure(String.format("%s Ensure you entered the correct bucket path.", errorReason),
-              null);
-      collector.getOrThrowException();
-    }
     String location = null;
     try {
       // Get location of the source for lineage
+      Bucket bucket = storage.get(bucketName);
+      if (Objects.isNull(bucket)) {
+        String errorReason = String.format("Unable to access GCS bucket '%s'.",
+          bucketName);
+        collector.addFailure(
+          String.format("%s Ensure you entered the correct bucket path.", errorReason),
+          null);
+        collector.getOrThrowException();
+      }
       location = bucket.getLocation();
     } catch (StorageException e) {
       String errorReason = String.format("Error code: %s, Unable to access GCS bucket '%s'. ",
-              e.getCode(), bucketName);
+        e.getCode(), bucketName);
       collector.addFailure(String.format("%s %s", errorReason, e.getMessage()),
-                      "Ensure you entered the correct bucket path and have permissions for it.")
-              .withStacktrace(e.getStackTrace());
+          "Ensure you entered the correct bucket path and have permissions for it.")
+        .withStacktrace(e.getStackTrace());
       collector.getOrThrowException();
     }
 
     // create asset for lineage
     String fqn = GCSPath.getFQN(path);
     String referenceName = Strings.isNullOrEmpty(config.getReferenceName())
-        ? ReferenceNames.normalizeFqn(fqn)
-        : config.getReferenceName();
+      ? ReferenceNames.normalizeFqn(fqn)
+      : config.getReferenceName();
     asset = Asset.builder(referenceName)
-        .setFqn(fqn).setLocation(location).build();
+      .setFqn(fqn).setLocation(location).build();
 
     // set error details provider
     context.setErrorDetailsProvider(
@@ -160,17 +162,20 @@ public void prepareRun(BatchSourceContext context) throws Exception {
 
   @Override
   protected Map<String, String> getFileSystemProperties(BatchSourceContext context) {
-    Map<String, String> properties = GCPUtils.getFileSystemProperties(config.connection, config.getPath(),
-                                                                      new HashMap<>(config.getFileSystemProperties()));
+    Map<String, String> properties =
+      GCPUtils.getFileSystemProperties(config.connection, config.getPath(),
+        new HashMap<>(config.getFileSystemProperties()));
     if (config.isCopyHeader()) {
       properties.put(PathTrackingInputFormat.COPY_HEADER, Boolean.TRUE.toString());
     }
     if (config.getFileEncoding() != null
-      && !config.getFileEncoding().equalsIgnoreCase(AbstractFileSourceConfig.DEFAULT_FILE_ENCODING)) {
+      && !config.getFileEncoding()
+      .equalsIgnoreCase(AbstractFileSourceConfig.DEFAULT_FILE_ENCODING)) {
       properties.put(PathTrackingInputFormat.SOURCE_FILE_ENCODING, config.getFileEncoding());
     }
     if (config.getMinSplitSize() != null) {
-      properties.put("mapreduce.input.fileinputformat.split.minsize", String.valueOf(config.getMinSplitSize()));
+      properties.put("mapreduce.input.fileinputformat.split.minsize",
+        String.valueOf(config.getMinSplitSize()));
     }
     if (config.isEncrypted()) {
       TinkDecryptor.configure(config.getEncryptedMetadataSuffix(), properties);
@@ -189,24 +194,27 @@ protected LineageRecorder getLineageRecorder(BatchSourceContext context) {
   @Override
   protected void recordLineage(LineageRecorder lineageRecorder, List<String> outputFields) {
     lineageRecorder.recordRead("Read", String.format("Read %s from Google Cloud Storage.",
-                                                     config.isEncrypted() ? " and decrypt " : " "), outputFields);
+      config.isEncrypted() ? " and decrypt " : " "), outputFields);
   }
 
   @Override
   protected boolean shouldGetSchema() {
     return !config.containsMacro(GCPConnectorConfig.NAME_PROJECT) &&
-             !config.containsMacro(GCSSourceConfig.NAME_PATH) && !config.containsMacro(GCSSourceConfig.NAME_FORMAT) &&
-             !config.containsMacro(GCSSourceConfig.NAME_DELIMITER) &&
-             !config.containsMacro(GCSSourceConfig.NAME_FILE_SYSTEM_PROPERTIES) &&
-             !config.containsMacro(GCPConnectorConfig.NAME_SERVICE_ACCOUNT_FILE_PATH) &&
-             !config.containsMacro(GCPConnectorConfig.NAME_SERVICE_ACCOUNT_JSON);
+      !config.containsMacro(GCSSourceConfig.NAME_PATH) && !config.containsMacro(
+      GCSSourceConfig.NAME_FORMAT) &&
+      !config.containsMacro(GCSSourceConfig.NAME_DELIMITER) &&
+      !config.containsMacro(GCSSourceConfig.NAME_FILE_SYSTEM_PROPERTIES) &&
+      !config.containsMacro(GCPConnectorConfig.NAME_SERVICE_ACCOUNT_FILE_PATH) &&
+      !config.containsMacro(GCPConnectorConfig.NAME_SERVICE_ACCOUNT_JSON);
   }
 
   /**
    * Config for the plugin.
    */
   @SuppressWarnings("ConstantConditions")
-  public static class GCSSourceConfig extends AbstractFileSourceConfig implements FileSourceProperties {
+  public static class GCSSourceConfig extends AbstractFileSourceConfig
+    implements FileSourceProperties {
+
     public static final String NAME_PATH = "path";
     public static final String NAME_FORMAT = "format";
     private static final String NAME_FILE_SYSTEM_PROPERTIES = "fileSystemProperties";
@@ -216,7 +224,8 @@ public static class GCSSourceConfig extends AbstractFileSourceConfig implements
     private static final String DEFAULT_ENCRYPTED_METADATA_SUFFIX = ".metadata";
 
     private static final Gson GSON = new Gson();
-    private static final Type MAP_STRING_STRING_TYPE = new TypeToken<Map<String, String>>() { }.getType();
+    private static final Type MAP_STRING_STRING_TYPE = new TypeToken<Map<String, String>>() {
+    }.getType();
 
     @Macro
     @Description("The path to read from. For example, gs://<bucket>/path/to/directory/")
@@ -234,8 +243,9 @@ public static class GCSSourceConfig extends AbstractFileSourceConfig implements
 
     @Macro
     @Nullable
-    @Description("Whether the data file is encrypted. If it is set to 'true', a associated metadata file needs to be "
-      + "provided for each data file. Please refer to the Documentation for the details of the metadata file content.")
+    @Description(
+      "Whether the data file is encrypted. If it is set to 'true', a associated metadata file needs to be "
+        + "provided for each data file. Please refer to the Documentation for the details of the metadata file content.")
     private Boolean encrypted;
 
     @Macro
@@ -246,8 +256,10 @@ public static class GCSSourceConfig extends AbstractFileSourceConfig implements
 
     @Macro
     @Nullable
-    @Description("A list of columns with the corresponding data types for whom the automatic data type detection gets" +
-      " skipped.")
+    @Description(
+      "A list of columns with the corresponding data types for whom the automatic data type detection gets"
+        +
+        " skipped.")
     private String override;
 
     @Macro