lint

Author: giwa

src/main/java/org/embulk/output/SnowflakeOutputPlugin.java

@@ -159,8 +159,7 @@ protected BatchInsert newBatchInsert(PluginTask task, Optional<MergeConfig> merg
         this.stageIdentifier,
         false,
         pluginTask.getMaxUploadRetries(),
-        pluginTask.getEmtpyFieldAsNull()
-    );
+        pluginTask.getEmtpyFieldAsNull());
   }
 
   @Override

src/main/java/org/embulk/output/snowflake/SnowflakeCopyBatchInsert.java

@@ -8,7 +8,6 @@
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.zip.GZIPOutputStream;
-
 import org.embulk.output.jdbc.BatchInsert;
 import org.embulk.output.jdbc.JdbcOutputConnector;
 import org.embulk.output.jdbc.JdbcSchema;
@@ -42,11 +41,11 @@ public class SnowflakeCopyBatchInsert implements BatchInsert {
   private boolean emptyFieldAsNull;
 
   public SnowflakeCopyBatchInsert(
-          JdbcOutputConnector connector,
-          StageIdentifier stageIdentifier,
-          boolean deleteStageFile,
-          int maxUploadRetries,
-          boolean emptyFieldAsNull)
+      JdbcOutputConnector connector,
+      StageIdentifier stageIdentifier,
+      boolean deleteStageFile,
+      int maxUploadRetries,
+      boolean emptyFieldAsNull)
       throws IOException {
     this.index = 0;
     openNewFile();
@@ -399,7 +398,8 @@ private class CopyTask implements Callable<Void> {
     private final String snowflakeStageFileName;
     private final boolean emptyFieldAsNull;
 
-    public CopyTask(Future<Void> uploadFuture, String snowflakeStageFileName, boolean emptyFieldAsNull) {
+    public CopyTask(
+        Future<Void> uploadFuture, String snowflakeStageFileName, boolean emptyFieldAsNull) {
       this.uploadFuture = uploadFuture;
       this.snowflakeStageFileName = snowflakeStageFileName;
       this.emptyFieldAsNull = emptyFieldAsNull;
@@ -414,7 +414,12 @@ public Void call() throws SQLException, InterruptedException, ExecutionException
           logger.info("Running COPY from file {}", snowflakeStageFileName);
 
           long startTime = System.currentTimeMillis();
-          con.runCopy(tableIdentifier, stageIdentifier, snowflakeStageFileName, delimiterString, emptyFieldAsNull);
+          con.runCopy(
+              tableIdentifier,
+              stageIdentifier,
+              snowflakeStageFileName,
+              delimiterString,
+              emptyFieldAsNull);
 
           double seconds = (System.currentTimeMillis() - startTime) / 1000.0;
 

src/main/java/org/embulk/output/snowflake/SnowflakeOutputConnection.java

@@ -21,7 +21,8 @@ public void runCopy(
       String delimiterString,
       boolean emptyFieldAsNull)
       throws SQLException {
-    String sql = buildCopySQL(tableIdentifier, stageIdentifier, filename, delimiterString, emptyFieldAsNull);
+    String sql =
+        buildCopySQL(tableIdentifier, stageIdentifier, filename, delimiterString, emptyFieldAsNull);
     runUpdate(sql);
   }
 
@@ -114,7 +115,7 @@ protected String buildCopySQL(
     sb.append(" FILE_FORMAT = ( TYPE = CSV FIELD_DELIMITER = '");
     sb.append(delimiterString);
     sb.append("') ");
-    if (!emptyFieldAsNull){
+    if (!emptyFieldAsNull) {
       sb.append("EMPTY_FIELD_AS_NULL = FALSE");
     }
     sb.append(";");