File tree 8 files changed +33
-25
lines changed
src/main/java/org/apache/arrow/datafusion
8 files changed +33
-25
lines changed Original file line number Diff line number Diff line change @@ -64,3 +64,4 @@ gradle-app.setting
64
64
.idea /
65
65
out /
66
66
bin /
67
+ .vscode /
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ plugins {
3
3
}
4
4
5
5
group = ' io.github.datafusion-contrib'
6
- version = ' 0.13.0-SNAPSHOT '
6
+ version = ' 0.13.0'
7
7
8
8
repositories {
9
9
mavenCentral()
Original file line number Diff line number Diff line change @@ -14,8 +14,8 @@ dependencies {
14
14
implementation project(' :datafusion-java' )
15
15
implementation ' org.slf4j:slf4j-api:1.7.36'
16
16
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'
19
19
}
20
20
21
21
application {
Original file line number Diff line number Diff line change @@ -9,9 +9,9 @@ plugins {
9
9
10
10
dependencies {
11
11
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'
15
15
}
16
16
17
17
spotless {
Original file line number Diff line number Diff line change @@ -46,6 +46,7 @@ public interface DataFrame extends NativeProxy {
46
46
47
47
/**
48
48
* Register this dataframe as a temporary table.
49
+ *
49
50
* @param context SessionContext to register table to
50
51
* @param name name of the tmp table
51
52
* @return null
Original file line number Diff line number Diff line change @@ -105,24 +105,24 @@ public CompletableFuture<Void> writeCsv(Path path) {
105
105
}
106
106
107
107
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 ;
126
126
}
127
127
128
128
@ Override
Original file line number Diff line number Diff line change 1
1
[package ]
2
2
name = " datafusion_jni"
3
- version = " 0.12 .0"
3
+ version = " 0.13 .0"
4
4
homepage = " https://github.com/apache/arrow-datafusion"
5
5
repository = " https://github.com/apache/arrow-datafusion"
6
6
authors = [
" Apache Arrow <[email protected] >" ]
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
+
1
6
rootProject. name = ' datafusion-java'
7
+
2
8
include ' datafusion-java' , ' datafusion-examples'
You can’t perform that action at this time.
0 commit comments