| 826 | } |
| 827 | |
| 828 | Result<std::vector<std::shared_ptr<RecordBatch>>> DeclarationToBatches( |
| 829 | Declaration declaration, bool use_threads, MemoryPool* memory_pool, |
| 830 | FunctionRegistry* function_registry) { |
| 831 | return ::arrow::internal::RunSynchronously< |
| 832 | Future<std::vector<std::shared_ptr<RecordBatch>>>>( |
| 833 | [=, declaration = std::move(declaration)](::arrow::internal::Executor* executor) { |
| 834 | return DeclarationToBatchesImpl( |
| 835 | std::move(declaration), QueryOptionsFromArgs(memory_pool, function_registry), |
| 836 | executor); |
| 837 | }, |
| 838 | use_threads); |
| 839 | } |
| 840 | |
| 841 | Result<std::vector<std::shared_ptr<RecordBatch>>> DeclarationToBatches( |
| 842 | Declaration declaration, QueryOptions query_options) { |