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

Method ReadNext

cpp/src/arrow/csv/reader.cc:873–877  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

871 int64_t bytes_read() const override { return bytes_decoded_->load(); }
872
873 Status ReadNext(std::shared_ptr<RecordBatch>* batch) override {
874 auto next_fut = ReadNextAsync();
875 auto next_result = next_fut.result();
876 return std::move(next_result).Value(batch);
877 }
878
879 Future<std::shared_ptr<RecordBatch>> ReadNextAsync() override {
880 return record_batch_gen_();

Callers 4

TestHeaderOnlyStreamingFunction · 0.45
TESTFunction · 0.45
WriteTableMethod · 0.45

Calls 2

resultMethod · 0.45
ValueMethod · 0.45

Tested by 3

TestHeaderOnlyStreamingFunction · 0.36
TESTFunction · 0.36