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

Method Schedule

cpp/src/arrow/acero/fetch_node.cc:190–192  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

188 }
189
190 void Schedule(util::SequencingQueue::Task task) override {
191 plan_->query_context()->ScheduleTask(std::move(task), "FetchNode::ProcessBatch");
192 }
193
194 protected:
195 std::string ToStringExtra(int indent = 0) const override {

Callers 1

DeliverNextUnlockedMethod · 0.45

Calls 2

ScheduleTaskMethod · 0.80
query_contextMethod · 0.80

Tested by

no test coverage detected