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

Function DeclarationToBatchesAsync

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

Source from the content-addressed store, hash-verified

803}
804
805Future<std::vector<std::shared_ptr<RecordBatch>>> DeclarationToBatchesAsync(
806 Declaration declaration, ExecContext exec_context) {
807 return DeclarationToBatchesImpl(std::move(declaration),
808 QueryOptionsFromCustomExecContext(exec_context),
809 exec_context.executor());
810}
811
812Future<std::vector<std::shared_ptr<RecordBatch>>> DeclarationToBatchesAsync(
813 Declaration declaration, bool use_threads, MemoryPool* memory_pool,

Callers 3

CountRowsAsyncMethod · 0.85
RunNodeMethod · 0.85
CheckScannerBackpressureFunction · 0.85

Calls 9

DeclarationToBatchesImplFunction · 0.85
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 2

RunNodeMethod · 0.68
CheckScannerBackpressureFunction · 0.68