Replace import from shaded dep with native java

Author: qqndrew

Core/pom.xml

@@ -12,13 +12,6 @@
 
     <artifactId>core</artifactId>
 
-    <pluginRepositories>
-        <pluginRepository>
-            <id>com.github.sampov2.onejar-maven-plugin</id>
-            <url>http://maven.codeforcode.com/repository</url>
-        </pluginRepository>
-    </pluginRepositories>
-
     <properties>
         <backbone.runner>Unspecified</backbone.runner>
     </properties>
@@ -155,7 +148,7 @@
             <dependencies>
                 <dependency>
                     <groupId>org.apache.beam</groupId>
-                    <artifactId>beam-runners-flink-1.10</artifactId>
+                    <artifactId>beam-runners-flink-1.13</artifactId>
                     <version>${beam.version}</version>
                 </dependency>
             </dependencies>

IO/src/main/java/org/ohnlp/backbone/io/local/FileSystemLoad.java

@@ -2,13 +2,9 @@
 
 import com.fasterxml.jackson.databind.JsonNode;
 import org.apache.beam.sdk.io.FileIO;
-import org.apache.beam.sdk.io.WriteFilesResult;
-import org.apache.beam.sdk.transforms.DoFn;
-import org.apache.beam.sdk.transforms.ParDo;
 import org.apache.beam.sdk.values.PCollection;
 import org.apache.beam.sdk.values.PDone;
 import org.apache.beam.sdk.values.Row;
-import org.apache.beam.vendor.grpc.v1p26p0.com.google.common.base.Joiner;
 import org.apache.commons.text.StringEscapeUtils;
 import org.ohnlp.backbone.api.Load;
 import org.ohnlp.backbone.api.exceptions.ComponentInitializationException;
@@ -17,8 +13,6 @@
 import java.io.PrintWriter;
 import java.nio.channels.Channels;
 import java.nio.channels.WritableByteChannel;
-import java.util.Collections;
-import java.util.List;
 import java.util.stream.Collectors;
 
 /**
@@ -68,7 +62,7 @@ public void write(Row element) throws IOException {
                 writer.println(element.getSchema().getFieldNames().stream().map(StringEscapeUtils::escapeCsv).collect(Collectors.joining(",")));
                 wroteHeader = true;
             }
-            writer.println(Joiner.on(",").join(element.getValues().stream().map(o -> StringEscapeUtils.escapeCsv(o.toString())).collect(Collectors.toList())));
+            writer.println(element.getValues().stream().map(o -> StringEscapeUtils.escapeCsv(o.toString())).collect(Collectors.joining(",")));
         }
 
         public void flush() throws IOException {