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

Function ExecPlan_create

r/src/compute-exec.cpp:45–57  ·  view source on GitHub ↗

[[acero::export]]

Source from the content-addressed store, hash-verified

43
44// [[acero::export]]
45std::shared_ptr<acero::ExecPlan> ExecPlan_create(bool use_threads) {
46 static compute::ExecContext threaded_context{gc_memory_pool(),
47 arrow::internal::GetCpuThreadPool()};
48 // TODO(weston) using gc_context() in this way is deprecated. Once ordering has
49 // been added we can probably entirely remove all reference to ExecPlan from R
50 // in favor of DeclarationToXyz
51 acero::QueryOptions query_options;
52 query_options.unaligned_buffer_handling = acero::UnalignedBufferHandling::kReallocate;
53 auto plan = ValueOrStop(acero::ExecPlan::Make(
54 std::move(query_options), use_threads ? &threaded_context : gc_context()));
55
56 return plan;
57}
58
59std::shared_ptr<acero::ExecNode> MakeExecNodeOrStop(
60 const std::string& factory_name, acero::ExecPlan* plan,

Callers 1

_arrow_ExecPlan_createFunction · 0.85

Calls 5

gc_memory_poolFunction · 0.85
GetCpuThreadPoolFunction · 0.85
ValueOrStopFunction · 0.85
gc_contextFunction · 0.85
MakeFunction · 0.50

Tested by

no test coverage detected