MCPcopy Create free account
hub / github.com/apache/arrow / operator()

Method operator()

cpp/src/arrow/dataset/scan_node.cc:225–232  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

223 }
224
225 Result<Future<>> operator()() override {
226 // Prevent concurrent calls to ScanBatch which might not be thread safe
227 std::lock_guard<std::mutex> lk(scan_->mutex);
228 return scan_->fragment_scanner->ScanBatch(batch_index_)
229 .Then([this](const std::shared_ptr<RecordBatch>& batch) {
230 return HandleBatch(batch);
231 });
232 }
233
234 std::string_view name() const override { return name_; }
235

Callers

nothing calls this directly

Calls 2

ThenMethod · 0.80
ScanBatchMethod · 0.45

Tested by

no test coverage detected