upgrade arrow maven dependencies (version 9) (#61)

* upgrade arrow maven dependencies

* bump version of java toolchain

* add java open

Author: jimexist

buildSrc/src/main/groovy/datafusion.java-conventions.gradle

@@ -11,7 +11,7 @@ repositories {
 
 java {
     toolchain {
-        languageVersion = JavaLanguageVersion.of(15)
+        languageVersion = JavaLanguageVersion.of(17)
     }
 }
 

datafusion-examples/build.gradle

@@ -13,15 +13,15 @@ spotless {
 dependencies {
     implementation project(':datafusion-java')
     implementation 'org.slf4j:slf4j-api:1.7.36'
-    implementation 'ch.qos.logback:logback-classic:1.2.11'
-    implementation 'org.apache.arrow:arrow-format:8.0.0'
-    implementation 'org.apache.arrow:arrow-vector:8.0.0'
+    implementation 'ch.qos.logback:logback-classic:1.4.0'
+    implementation 'org.apache.arrow:arrow-format:9.0.0'
+    implementation 'org.apache.arrow:arrow-vector:9.0.0'
 }
 
 application {
     mainClass = 'org.apache.arrow.datafusion.examples.ExampleMain'
     def libraryPath = findProperty("JNI_PATH") ?: "$rootDir/datafusion-java/build/jni_libs/dev"
-    applicationDefaultJvmArgs += "-Djava.library.path=$libraryPath"
+    applicationDefaultJvmArgs += ["-Djava.library.path=$libraryPath", "--add-opens=java.base/java.nio=ALL-UNNAMED"]
 }
 
 tasks.named("run").configure {

datafusion-examples/src/main/java/org/apache/arrow/datafusion/examples/ExampleMain.java

@@ -1,6 +1,8 @@
 package org.apache.arrow.datafusion.examples;
 
 import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.concurrent.CompletableFuture;
 import org.apache.arrow.datafusion.DataFrame;
@@ -39,14 +41,16 @@ public static void main(String[] args) throws Exception {
           .thenAccept(ExampleMain::consumeReader)
           .join();
 
+      Path tempPath = Files.createTempDirectory("datafusion-examples");
+
       context
           .sql("select * from test_parquet limit 3")
-          .thenComposeAsync(df -> df.writeCsv(Paths.get("build/tmp/csv-out")))
+          .thenComposeAsync(df -> df.writeCsv(tempPath.resolve("csv-out")))
           .join();
 
       context
           .sql("select * from test_parquet limit 3")
-          .thenComposeAsync(df -> df.writeParquet(Paths.get("build/tmp/parquet-out")))
+          .thenComposeAsync(df -> df.writeParquet(tempPath.resolve("parquet-out")))
           .join();
     }
   }

datafusion-java/build.gradle

@@ -9,9 +9,9 @@ plugins {
 
 dependencies {
     implementation 'org.slf4j:slf4j-api:1.7.36'
-    implementation 'org.apache.arrow:arrow-format:8.0.0'
-    implementation 'org.apache.arrow:arrow-vector:8.0.0'
-    runtimeOnly 'org.apache.arrow:arrow-memory-unsafe:8.0.0'
+    implementation 'org.apache.arrow:arrow-format:9.0.0'
+    implementation 'org.apache.arrow:arrow-vector:9.0.0'
+    runtimeOnly 'org.apache.arrow:arrow-memory-unsafe:9.0.0'
 }
 
 spotless {

datafusion-java/src/main/java/org/apache/arrow/datafusion/DataFrame.java

@@ -38,6 +38,7 @@ public interface DataFrame extends NativeProxy {
 
   /**
    * Write results to a csv file.
+   *
    * @param path path to write csv file to
    * @return null
    */

datafusion-java/src/main/java/org/apache/arrow/datafusion/DataFrames.java

@@ -16,8 +16,7 @@ static native void collectDataframe(
       long runtime, long dataframe, BiConsumer<String, byte[]> callback);
 
   static native void writeParquet(
-          long runtime, long dataframe, String path, Consumer<String> callback);
+      long runtime, long dataframe, String path, Consumer<String> callback);
 
-  static native void writeCsv(
-          long runtime, long dataframe, String path, Consumer<String> callback);
+  static native void writeCsv(long runtime, long dataframe, String path, Consumer<String> callback);
 }