Trying a new way by pushing/polling from DF

Signed-off-by: Marc Handalian <marc.handalian@gmail.com>
mch2 · Feb 10, 2025 · 13deb30 · 13deb30
1 parent 98cd054
commit 13deb30
Show file tree

Hide file tree

Showing 10 changed files with 1,304 additions and 87 deletions.
diff --git a/libs/arrow-spi/src/main/java/org/opensearch/arrow/spi/StreamProducer.java b/libs/arrow-spi/src/main/java/org/opensearch/arrow/spi/StreamProducer.java
@@ -100,6 +100,10 @@ public interface StreamProducer extends Closeable {
      */
     BatchedJob createJob(BufferAllocator allocator);
 
+    /**
+     *
+     * @return
+     */
     default Set<StreamTicket> partitions() {
         return Collections.emptySet();
     }