Skip to content

Commit 728477c

Browse files
authored
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]>
1 parent 19badf1 commit 728477c

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

modules/io/io/i_io_adaptor.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,11 @@ class IIOAdaptor {
8080
return Status::OK();
8181
}
8282

83+
virtual Status ReadTable(
84+
std::function<void(std::shared_ptr<arrow::RecordBatch>)> callback) {
85+
return Status::OK();
86+
}
87+
8388
virtual Status WriteTable(std::shared_ptr<arrow::Table> table) {
8489
return Status::OK();
8590
}

0 commit comments

Comments
 (0)