refactored

Author: Amit-CloudSufi

src/main/java/io/cdap/plugin/snowflake/sink/batch/SnowflakeOutputFormat.java

@@ -83,7 +83,7 @@ public void commitJob(JobContext jobContext) {
         snowflakeAccessor.populateTable(destinationStagePath);
         snowflakeAccessor.removeDirectory(destinationStagePath);
       }
-      
+
       @Override
       public void setupTask(TaskAttemptContext taskAttemptContext) {
 

src/main/java/io/cdap/plugin/snowflake/sink/batch/StructuredRecordToCSVRecordTransformer.java

@@ -104,7 +104,7 @@ public static String convertSchemaFieldToString(Object value, Schema.Field field
           return instant.atZone(ZoneOffset.UTC).toLocalTime().toString();
         case DECIMAL:
           try {
-            return Objects.requireNonNull(record.getDecimal(field.getName())).toString();
+            return record.getDecimal(field.getName()).toString();
           } catch (Exception e) {
             String errorReason = String.format("Field '%s' is expected to be a decimal, but is a %s.",
               field.getName(), value.getClass().getSimpleName());

src/main/java/io/cdap/plugin/snowflake/source/batch/SnowflakeSourceAccessor.java

@@ -103,7 +103,6 @@ public List<String> prepareStageSplits() {
     return stageSplits;
   }
 
-
   /**
    * Remove a file from stage.
    * @param stageSplit  path to file in Snowflake stage.