MCPcopy Create free account
hub / github.com/apache/arrow / DeclarationToExecBatchesAsync

Function DeclarationToExecBatchesAsync

cpp/src/arrow/acero/exec_plan.cc:854–859  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

852}
853
854Future<BatchesWithCommonSchema> DeclarationToExecBatchesAsync(Declaration declaration,
855 ExecContext exec_context) {
856 return DeclarationToExecBatchesImpl(std::move(declaration),
857 QueryOptionsFromCustomExecContext(exec_context),
858 exec_context.executor());
859}
860
861Future<BatchesWithCommonSchema> DeclarationToExecBatchesAsync(
862 Declaration declaration, bool use_threads, MemoryPool* memory_pool,

Callers 1

TestBackpressureFunction · 0.85

Calls 9

QueryOptionsFromArgsFunction · 0.85
GetCpuThreadPoolFunction · 0.85
ThenMethod · 0.80
ARROW_ASSIGN_OR_RAISEFunction · 0.70
MakeFunction · 0.50
executorMethod · 0.45
getMethod · 0.45

Tested by 1

TestBackpressureFunction · 0.68