Skip to content

Commit 93ac90f

Browse files
committed
moved libs:arrow-spi to server module
Signed-off-by: Rishabh Maurya <[email protected]>
1 parent 4e30c7e commit 93ac90f

File tree

9 files changed

+2
-23
lines changed

9 files changed

+2
-23
lines changed

libs/arrow-spi/build.gradle

-20
This file was deleted.

plugins/arrow-flight-rpc/build.gradle

-2
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,6 @@ opensearchplugin {
1818
}
1919

2020
dependencies {
21-
implementation project(':libs:opensearch-arrow-spi')
22-
2321
// all transitive dependencies exported to use arrow-vector and arrow-memory-core
2422
api "org.apache.arrow:arrow-memory-netty:${versions.arrow}"
2523
api "org.apache.arrow:arrow-memory-core:${versions.arrow}"

server/build.gradle

-1
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,6 @@ dependencies {
6969
api project(":libs:opensearch-geo")
7070
api project(":libs:opensearch-telemetry")
7171
api project(":libs:opensearch-task-commons")
72-
implementation project(':libs:opensearch-arrow-spi')
7372

7473
compileOnly project(':libs:opensearch-plugin-classloader')
7574
testRuntimeOnly project(':libs:opensearch-plugin-classloader')

libs/arrow-spi/src/main/java/org/opensearch/arrow/spi/StreamProducer.java server/src/main/java/org/opensearch/arrow/spi/StreamProducer.java

+2
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,7 @@ public interface StreamProducer<VectorRoot, Allocator> extends Closeable {
111111
/**
112112
* BatchedJob interface for producing stream data in batches.
113113
*/
114+
@ExperimentalApi
114115
interface BatchedJob<VectorRoot> {
115116

116117
/**
@@ -144,6 +145,7 @@ interface BatchedJob<VectorRoot> {
144145
* Functional interface for managing stream consumption signals.
145146
*/
146147
@FunctionalInterface
148+
@ExperimentalApi
147149
interface FlushSignal {
148150
/**
149151
* Blocks until the current batch has been consumed or timeout occurs.

0 commit comments

Comments
 (0)