File tree Expand file tree Collapse file tree 8 files changed +33
-25
lines changed
src/main/java/org/apache/arrow/datafusion Expand file tree Collapse file tree 8 files changed +33
-25
lines changed Original file line number Diff line number Diff line change @@ -64,3 +64,4 @@ gradle-app.setting
6464.idea /
6565out /
6666bin /
67+ .vscode /
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ plugins {
33}
44
55group = ' io.github.datafusion-contrib'
6- version = ' 0.13.0-SNAPSHOT '
6+ version = ' 0.13.0'
77
88repositories {
99 mavenCentral()
Original file line number Diff line number Diff line change @@ -14,8 +14,8 @@ dependencies {
1414 implementation project(' :datafusion-java' )
1515 implementation ' org.slf4j:slf4j-api:1.7.36'
1616 implementation ' ch.qos.logback:logback-classic:1.4.0'
17- implementation ' org.apache.arrow:arrow-format:9 .0.0'
18- implementation ' org.apache.arrow:arrow-vector:9 .0.0'
17+ implementation ' org.apache.arrow:arrow-format:13 .0.0'
18+ implementation ' org.apache.arrow:arrow-vector:13 .0.0'
1919}
2020
2121application {
Original file line number Diff line number Diff line change @@ -9,9 +9,9 @@ plugins {
99
1010dependencies {
1111 implementation ' org.slf4j:slf4j-api:1.7.36'
12- implementation ' org.apache.arrow:arrow-format:9 .0.0'
13- implementation ' org.apache.arrow:arrow-vector:9 .0.0'
14- runtimeOnly ' org.apache.arrow:arrow-memory-unsafe:9 .0.0'
12+ implementation ' org.apache.arrow:arrow-format:13 .0.0'
13+ implementation ' org.apache.arrow:arrow-vector:13 .0.0'
14+ runtimeOnly ' org.apache.arrow:arrow-memory-unsafe:13 .0.0'
1515}
1616
1717spotless {
Original file line number Diff line number Diff line change @@ -46,6 +46,7 @@ public interface DataFrame extends NativeProxy {
4646
4747 /**
4848 * Register this dataframe as a temporary table.
49+ *
4950 * @param context SessionContext to register table to
5051 * @param name name of the tmp table
5152 * @return null
Original file line number Diff line number Diff line change @@ -105,24 +105,24 @@ public CompletableFuture<Void> writeCsv(Path path) {
105105 }
106106
107107 public CompletableFuture <Void > registerTable (SessionContext ctx , String name ) {
108- Runtime runtime = context .getRuntime ();
109- long runtimePointer = runtime .getPointer ();
110- long dataframe = getPointer ();
111- long contextPointer = ctx .getPointer ();
112- CompletableFuture <Void > future = new CompletableFuture <>();
113- DataFrames .registerTable (
114- runtimePointer ,
115- dataframe ,
116- contextPointer ,
117- name ,
118- (String errString ) -> {
119- if (containsError (errString )) {
120- future .completeExceptionally (new RuntimeException (errString ));
121- } else {
122- future .complete (null );
123- }
124- });
125- return future ;
108+ Runtime runtime = context .getRuntime ();
109+ long runtimePointer = runtime .getPointer ();
110+ long dataframe = getPointer ();
111+ long contextPointer = ctx .getPointer ();
112+ CompletableFuture <Void > future = new CompletableFuture <>();
113+ DataFrames .registerTable (
114+ runtimePointer ,
115+ dataframe ,
116+ contextPointer ,
117+ name ,
118+ (String errString ) -> {
119+ if (containsError (errString )) {
120+ future .completeExceptionally (new RuntimeException (errString ));
121+ } else {
122+ future .complete (null );
123+ }
124+ });
125+ return future ;
126126 }
127127
128128 @ Override
Original file line number Diff line number Diff line change 11[package ]
22name = " datafusion_jni"
3- version = " 0.12 .0"
3+ version = " 0.13 .0"
44homepage = " https://github.com/apache/arrow-datafusion"
55repository = " https://github.com/apache/arrow-datafusion"
66authors = [" Apache Arrow <dev@arrow.apache.org>" ]
Original file line number Diff line number Diff line change 1+ // https://docs.gradle.org/current/userguide/toolchains.html#sub:download_repositories
2+ plugins {
3+ id ' org.gradle.toolchains.foojay-resolver-convention' version ' 0.4.0'
4+ }
5+
16rootProject. name = ' datafusion-java'
7+
28include ' datafusion-java' , ' datafusion-examples'
You can’t perform that action at this time.
0 commit comments