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

Function ReadContiguousPayload

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

Source from the content-addressed store, hash-verified

779}
780
781Status ReadContiguousPayload(io::InputStream* file, std::unique_ptr<Message>* message) {
782 ARROW_ASSIGN_OR_RAISE(*message, ReadMessage(file));
783 if (*message == nullptr) {
784 return Status::Invalid("Unable to read metadata at offset");
785 }
786 return Status::OK();
787}
788
789Result<RecordBatchWithMetadata> ReadRecordBatchInternal(
790 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