I had customized some execution plan struct. In datafusion 7.1.0 the ExecutionPlan::exec method is async so I can directly call some async functions in it when I Implement some methods for ExecutionPlan. After upgrade datafusion to 9.0.0 the ExecutionPlan::exec becomes sync. So how can I call an async function in ExecutionPlan::exec method?
I have seen that SortExec in datafusion-core use futures::stream::once to wrap async calls. But futures::stream::once is not public for me. So how can I make it?
I had customized some execution plan struct. In datafusion 7.1.0 the
ExecutionPlan::execmethod is async so I can directly call some async functions in it when I Implement some methods forExecutionPlan. After upgrade datafusion to 9.0.0 theExecutionPlan::execbecomes sync. So how can I call an async function inExecutionPlan::execmethod?I have seen that
SortExecin datafusion-core usefutures::stream::onceto wrap async calls. Butfutures::stream::onceis not public for me. So how can I make it?