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

Method ReadNext

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

Source from the content-addressed store, hash-verified

865 int64_t bytes_read() const override { return bytes_decoded_->load(); }
866
867 Status ReadNext(std::shared_ptr<RecordBatch>* batch) override {
868 auto next_fut = ReadNextAsync();
869 auto next_result = next_fut.result();
870 return std::move(next_result).Value(batch);
871 }
872
873 Future<std::shared_ptr<RecordBatch>> ReadNextAsync() override {
874 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