File tree Expand file tree Collapse file tree 3 files changed +14
-0
lines changed
java/org/apache/arrow/dataset/jni Expand file tree Collapse file tree 3 files changed +14
-0
lines changed Original file line number Diff line number Diff line change 2323#include " arrow/array/concatenate.h"
2424#include " arrow/c/bridge.h"
2525#include " arrow/c/helpers.h"
26+ #include " arrow/compute/initialize.h"
2627#include " arrow/dataset/api.h"
2728#include " arrow/dataset/file_base.h"
2829#ifdef ARROW_CSV
@@ -807,6 +808,13 @@ JNIEXPORT void JNICALL Java_org_apache_arrow_dataset_jni_JniWrapper_ensureS3Fina
807808 JNI_METHOD_END ()
808809}
809810
811+ JNIEXPORT void JNICALL Java_org_apache_arrow_dataset_jni_JniWrapper_initialize (
812+ JNIEnv* env, jobject) {
813+ JNI_METHOD_START
814+ JniAssertOkOrThrow (arrow::compute::Initialize ());
815+ JNI_METHOD_END ()
816+ }
817+
810818/*
811819 * Class: org_apache_arrow_dataset_file_JniWrapper
812820 * Method: makeFileSystemDatasetFactory
Original file line number Diff line number Diff line change @@ -56,6 +56,7 @@ public void ensureLoaded() {
5656 }
5757 loadRemaining ();
5858 ensureS3FinalizedOnShutdown ();
59+ JniWrapper .get ().initialize ();
5960 }
6061
6162 private synchronized void loadRemaining () {
Original file line number Diff line number Diff line change @@ -124,4 +124,9 @@ public native long createScanner(
124124 * uninitialized, then this is a noop.
125125 */
126126 public native void ensureS3Finalized ();
127+
128+ /**
129+ * Initialize Arrow Compute.
130+ */
131+ public native void initialize ();
127132}
You can’t perform that action at this time.
0 commit comments