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

Method ReadNext

cpp/src/arrow/ipc/reader.cc:1161–1165  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1159 }
1160
1161 Status ReadNext(std::shared_ptr<RecordBatch>* batch) override {
1162 ARROW_ASSIGN_OR_RAISE(auto batch_with_metadata, ReadNext());
1163 *batch = std::move(batch_with_metadata.batch);
1164 return Status::OK();
1165 }
1166
1167 Result<RecordBatchWithMetadata> ReadNext() override {
1168 auto collect_listener = checked_cast<CollectListener*>(raw_listener());

Callers 5

RoundtripBatchFunction · 0.45
ReadStreamFunction · 0.45
ReadBatchMethod · 0.45
TESTFunction · 0.45
WriteTableMethod · 0.45

Calls 5

OnMessageDecodedFunction · 0.85
OKFunction · 0.50
stateFunction · 0.50
InvalidFunction · 0.50
num_record_batchesMethod · 0.45

Tested by 3

RoundtripBatchFunction · 0.36
ReadBatchMethod · 0.36
TESTFunction · 0.36