Merge pull request #99 from trocco-io/feature/embulk-v0.1x-apply-google-java-format

enable spotless googleJavaFormat

Author: NamedPython

build.gradle

@@ -92,6 +92,6 @@ spotless {
     java {
         importOrder()
         removeUnusedImports()
-        // googleJavaFormat()
+        googleJavaFormat()
     }
 }

src/main/java/org/embulk/output/bigquery_java/BigqueryClient.java

@@ -5,83 +5,79 @@
 import java.io.IOException;
 import java.io.OutputStream;
 import java.util.zip.GZIPOutputStream;
-
 import org.embulk.output.bigquery_java.config.PluginTask;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public class BigqueryFileWriter {
-    private final Logger logger = LoggerFactory.getLogger(BigqueryFileWriter.class);
-    private PluginTask task;
-    private String compression;
-    private OutputStream os;
-    private long count = 0;
+  private final Logger logger = LoggerFactory.getLogger(BigqueryFileWriter.class);
+  private PluginTask task;
+  private String compression;
+  private OutputStream os;
+  private long count = 0;
 
-    public BigqueryFileWriter(PluginTask task) {
-        this.task = task;
-        this.compression = this.task.getCompression();
-    }
+  public BigqueryFileWriter(PluginTask task) {
+    this.task = task;
+    this.compression = this.task.getCompression();
+  }
 
-    public BigqueryFileWriter() {
-    }
+  public BigqueryFileWriter() {}
 
-    public void setTask(PluginTask task) {
-        this.task = task;
-    }
-
-    public void setCompression(String compression) {
-        this.compression = compression;
-    }
+  public void setTask(PluginTask task) {
+    this.task = task;
+  }
 
-    public OutputStream open(String path) throws IOException {
-        logger.info("embulk-output-bigquery: create {}", path);
+  public void setCompression(String compression) {
+    this.compression = compression;
+  }
 
-        this.os = new FileOutputStream(path);
-        if (this.compression.equals("GZIP")) {
-            this.os = new GZIPOutputStream(this.os);
-        }
-        // embulk default page size
-        this.os = new BufferedOutputStream(this.os, 1024 * 32);
+  public OutputStream open(String path) throws IOException {
+    logger.info("embulk-output-bigquery: create {}", path);
 
-        return this.os;
+    this.os = new FileOutputStream(path);
+    if (this.compression.equals("GZIP")) {
+      this.os = new GZIPOutputStream(this.os);
     }
+    // embulk default page size
+    this.os = new BufferedOutputStream(this.os, 1024 * 32);
 
-    public OutputStream outputStream() throws IOException {
-        if (this.os != null) {
-            return this.os;
-        }
-        // TODO: pid, thread id format config
-        String path = String.format("%s.%d.%d%s",
-                this.task.getPathPrefix().get(),
-                BigqueryUtil.getPID(),
-                Thread.currentThread().getId(),
-                this.task.getFileExt().get());
-        return open(path);
-    }
+    return this.os;
+  }
 
-    public void write(byte[] bytes) {
-        try {
-            outputStream().write(bytes);
-            this.count++;
-        } catch (Exception e) {
-            logger.info(e.getMessage());
-        }
+  public OutputStream outputStream() throws IOException {
+    if (this.os != null) {
+      return this.os;
     }
-
-    public long getCount() {
-        return this.count;
+    // TODO: pid, thread id format config
+    String path =
+        String.format(
+            "%s.%d.%d%s",
+            this.task.getPathPrefix().get(),
+            BigqueryUtil.getPID(),
+            Thread.currentThread().getId(),
+            this.task.getFileExt().get());
+    return open(path);
+  }
+
+  public void write(byte[] bytes) {
+    try {
+      outputStream().write(bytes);
+      this.count++;
+    } catch (Exception e) {
+      logger.info(e.getMessage());
     }
-
-    public void close() {
-        try {
-            this.outputStream().flush();
-            this.outputStream().close();
-        } catch (Exception e) {
-            logger.info(e.getMessage());
-        }
+  }
+
+  public long getCount() {
+    return this.count;
+  }
+
+  public void close() {
+    try {
+      this.outputStream().flush();
+      this.outputStream().close();
+    } catch (Exception e) {
+      logger.info(e.getMessage());
     }
+  }
 }
-
-
-