add callback option to IO interface (#2001)

Enable user to process the results of `ReadTable` in a streaming way --------- Signed-off-by: siyuan0322 <[email protected]>
v6d-io · Oct 14, 2024 · 728477c · 728477c
1 parent 19badf1
commit 728477c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/modules/io/io/i_io_adaptor.h b/modules/io/io/i_io_adaptor.h
@@ -80,6 +80,11 @@ class IIOAdaptor {
     return Status::OK();
   }
 
+  virtual Status ReadTable(
+      std::function<void(std::shared_ptr<arrow::RecordBatch>)> callback) {
+    return Status::OK();
+  }
+
   virtual Status WriteTable(std::shared_ptr<arrow::Table> table) {
     return Status::OK();
   }