alamb commented on PR #10309: URL: https://github.com/apache/datafusion/pull/10309#issuecomment-2090432837
I think the idea would be to create a `StreamingTableExec` directly and then read data from it, ensuring that the limit was applied I didn't see any existing unit tests for `StreamingTableExec` so we would have to write some I think https://github.com/apache/datafusion/blob/fa31c781d2cb0bdfba06dcc07bc75d9a5f9686b2/datafusion/physical-plan/src/streaming.rs#L221 Maybe I missed it -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org For additional commands, e-mail: github-h...@datafusion.apache.org