remove unnecessary dependency to TileDB-Java

Author: DimitrisStaratzis

build.gradle

@@ -158,12 +158,10 @@ dependencies {
     implementation group: 'org.apache.arrow', name: 'arrow-vector', version: '9.0.0'
     implementation group: 'org.apache.arrow', name: 'arrow-compression', version: '9.0.0'
     implementation group: 'org.apache.arrow', name: 'arrow-memory-unsafe', version: '9.0.0'
-    implementation 'io.tiledb:tiledb-java:0.17.2'
     testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.2'
     testImplementation 'org.mockito:mockito-core:3.12.4'
     testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.8.2'
     testImplementation 'junit:junit:4.13.1'
-
 }
 
 import org.gradle.plugins.signing.Sign

src/main/java/io/tiledb/cloud/Pair.java

@@ -0,0 +1,39 @@
+package io.tiledb.cloud;
+
+public class Pair<F, S> implements java.io.Serializable {
+    private F first;
+    private S second;
+
+    private Pair() {}
+
+    public Pair(F first, S second) {
+        this.first = first;
+        this.second = second;
+    }
+
+    public F getFirst() {
+        return first;
+    }
+
+    public void setFirst(F first) {
+        this.first = first;
+    }
+
+    public S getSecond() {
+        return second;
+    }
+
+    public void setSecond(S second) {
+        this.second = second;
+    }
+
+    /**
+     * Returns an empty Pair
+     *
+     * @return The Pair
+     */
+    public static Pair empty() {
+        return new Pair();
+    }
+}
+

src/main/java/io/tiledb/cloud/TileDBLogin.java

@@ -1,7 +1,5 @@
 package io.tiledb.cloud;
 
-import java.util.Objects;
-
 public class TileDBLogin {
     /** The client password */
     private String password;

src/main/java/io/tiledb/cloud/TileDBSQL.java

@@ -54,7 +54,7 @@ public TileDBSQL(TileDBClient tileDBClient, String namespace, SQLParameters sql)
      * @return A pair that consists of an ArrayList of all valueVectors and the
      * number of batches read.
      */
-    public io.tiledb.java.api.Pair<ArrayList<ValueVector>, Integer> execArrow(){
+    public Pair<ArrayList<ValueVector>, Integer> execArrow(){
         try {
             assert sql.getResultFormat() != null;
             byte[] bytes =  apiInstance.runSQLBytes(namespace, sql, "none");
@@ -81,7 +81,7 @@ public io.tiledb.java.api.Pair<ArrayList<ValueVector>, Integer> execArrow(){
                 }
             }
             reader.close();
-            return new io.tiledb.java.api.Pair<>(valueVectors, readBatchesCount);
+            return new Pair<>(valueVectors, readBatchesCount);
 
         } catch (IOException | ApiException e) {
             throw new RuntimeException(e);

src/main/java/io/tiledb/cloud/TileDBUDF.java

@@ -1,25 +1,14 @@
 package io.tiledb.cloud;
 
-import com.google.gson.Gson;
 import io.tiledb.cloud.rest_api.ApiException;
 import io.tiledb.cloud.rest_api.api.UdfApi;
 import io.tiledb.cloud.rest_api.model.*;
-import io.tiledb.java.api.Pair;
-import org.apache.arrow.compression.CommonsCompressionFactory;
-import org.apache.arrow.memory.RootAllocator;
-import org.apache.arrow.memory.UnsafeAllocationManager;
-import org.apache.arrow.vector.FieldVector;
 import org.apache.arrow.vector.ValueVector;
-import org.apache.arrow.vector.VectorSchemaRoot;
-import org.apache.arrow.vector.ipc.ArrowStreamReader;
-import org.apache.arrow.vector.util.TransferPair;
 import org.json.JSONArray;
 import org.json.JSONObject;
 
-import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 
@@ -134,7 +123,7 @@ public JSONArray executeGenericJSONArray(GenericUDF genericUDF){
      * @param arguments The UDF arguments
      * @return A pair that consists of an ArrayList of all valueVectors and the number of batches read.
      */
-    public io.tiledb.java.api.Pair<ArrayList<ValueVector>, Integer> executeGenericArrow(GenericUDF genericUDF,
+    public Pair<ArrayList<ValueVector>, Integer> executeGenericArrow(GenericUDF genericUDF,
                                                                                         HashMap<String, Object> arguments){
         String serializedArgs = serializeArgs(arguments);
         genericUDF.setArgument(serializedArgs);
@@ -154,7 +143,7 @@ public io.tiledb.java.api.Pair<ArrayList<ValueVector>, Integer> executeGenericAr
      * @param genericUDF The generic UDF definition
      * @return A pair that consists of an ArrayList of all valueVectors and the number of batches read.
      */
-    public io.tiledb.java.api.Pair<ArrayList<ValueVector>, Integer> executeGenericArrow(GenericUDF genericUDF){
+    public Pair<ArrayList<ValueVector>, Integer> executeGenericArrow(GenericUDF genericUDF){
         genericUDF.setResultFormat(ResultFormat.ARROW);
         try {
             byte[] bytes = apiInstance.submitGenericUDFBytes(namespace, genericUDF, "none");

src/main/java/io/tiledb/cloud/TileDBUtils.java

@@ -36,7 +36,7 @@ public static String serializeArgs(HashMap<String, Object> arguments) {
      * @return A pair that consists of an ArrayList of all valueVectors and the number of batches read.
      * @throws IOException
      */
-    protected static io.tiledb.java.api.Pair<ArrayList<ValueVector>, Integer> createValueVectors(byte[] bytes) throws IOException {
+    protected static Pair<ArrayList<ValueVector>, Integer> createValueVectors(byte[] bytes) throws IOException {
         ArrayList<ValueVector> valueVectors = null;
         int readBatchesCount = 0;
 
@@ -59,6 +59,6 @@ protected static io.tiledb.java.api.Pair<ArrayList<ValueVector>, Integer> create
             }
         }
         reader.close();
-        return new io.tiledb.java.api.Pair<>(valueVectors, readBatchesCount);
+        return new Pair<>(valueVectors, readBatchesCount);
     }
 }