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

Method ReadNext

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

Source from the content-addressed store, hash-verified

1164 }
1165
1166 Status ReadNext(std::shared_ptr<RecordBatch>* batch) override {
1167 ARROW_ASSIGN_OR_RAISE(auto batch_with_metadata, ReadNext());
1168 *batch = std::move(batch_with_metadata.batch);
1169 return Status::OK();
1170 }
1171
1172 Result<RecordBatchWithMetadata> ReadNext() override {
1173 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