Closed dacort closed 1 year ago
The initial implementation does not include pagination. 😢
lance has a good example of how this could be implemented.
let batch = match crate::RUNTIME.block_on(async { (*(*init_data).stream).next().await }) {
Essentially we can create a stream using GetQueryResultsPaginator and have .next() called until no results are left.
GetQueryResultsPaginator
.next()
The initial implementation does not include pagination. 😢
lance has a good example of how this could be implemented.
Essentially we can create a stream using
GetQueryResultsPaginator
and have.next()
called until no results are left.