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

Method ScanBatch

cpp/src/arrow/dataset/file_csv.cc:80–86  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

78 best_guess_bytes_per_batch_(best_guess_bytes_per_batch) {}
79
80 Future<std::shared_ptr<RecordBatch>> ScanBatch(int batch_number) override {
81 // This should be called in increasing order but let's verify that in case it changes.
82 // It would be easy enough to handle out of order but no need for that complexity at
83 // the moment.
84 DCHECK_EQ(scanned_so_far_++, batch_number);
85 return reader_->ReadNextAsync();
86 }
87
88 int64_t EstimatedDataBytes(int batch_number) override {
89 return best_guess_bytes_per_batch_;

Callers 1

operator()Method · 0.45

Calls 1

ReadNextAsyncMethod · 0.45

Tested by

no test coverage detected