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

Function ReadContiguousPayload

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

Source from the content-addressed store, hash-verified

778}
779
780Status ReadContiguousPayload(io::InputStream* file, std::unique_ptr<Message>* message) {
781 ARROW_ASSIGN_OR_RAISE(*message, ReadMessage(file));
782 if (*message == nullptr) {
783 return Status::Invalid("Unable to read metadata at offset");
784 }
785 return Status::OK();
786}
787
788Result<RecordBatchWithMetadata> ReadRecordBatchInternal(
789 const Buffer& metadata, const std::shared_ptr<Schema>& schema,

Callers 3

ReadRecordBatchFunction · 0.85
ReadTensorFunction · 0.85
ReadSparseTensorFunction · 0.85

Calls 4

ReadMessageFunction · 0.85
ARROW_ASSIGN_OR_RAISEFunction · 0.70
InvalidFunction · 0.50
OKFunction · 0.50

Tested by

no test coverage detected