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

Function threaded_exec_context

cpp/src/arrow/compute/exec.cc:69–72  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

67}
68
69ExecContext* threaded_exec_context() {
70 static ExecContext threaded_ctx(default_memory_pool(), GetCpuThreadPool());
71 return &threaded_ctx;
72}
73
74ExecBatch::ExecBatch(const RecordBatch& batch)
75 : values(batch.num_columns()), length(batch.num_rows()) {

Callers 6

Expression>& guarantees) { // If guarantees are provided we must have one for each batch if (!guarantees.empty()) { EXPECT_EQ(fragment_batch_strs.size(), guarantees.size())Method · 0.85
RunGroupByFunction · 0.85
exec_plan.hFile · 0.85
SourceOrderBySinkExampleFunction · 0.85
SourceKSelectExampleFunction · 0.85
TableSinkExampleFunction · 0.85

Calls 2

default_memory_poolFunction · 0.85
GetCpuThreadPoolFunction · 0.85

Tested by 2

Expression>& guarantees) { // If guarantees are provided we must have one for each batch if (!guarantees.empty()) { EXPECT_EQ(fragment_batch_strs.size(), guarantees.size())Method · 0.68
RunGroupByFunction · 0.68