MCPcopy Create free account
hub / github.com/apache/arrow-rs / read_message

Method read_message

arrow-ipc/src/reader.rs:1080–1090  ·  view source on GitHub ↗
(&self, buf: &'a [u8])

Source from the content-addressed store, hash-verified

1078 }
1079
1080 fn read_message<'a>(&self, buf: &'a [u8]) -> Result<Message::Message<'a>, ArrowError> {
1081 let message = parse_message(buf)?;
1082
1083 // some old test data's footer metadata is not set, so we account for that
1084 if self.version != MetadataVersion::V1 && message.version() != self.version {
1085 return Err(ArrowError::IpcError(
1086 "Could not read IPC message as metadata versions mismatch".to_string(),
1087 ));
1088 }
1089 Ok(message)
1090 }
1091
1092 /// Read the dictionary with the given block and data buffer
1093 pub fn read_dictionary(&mut self, block: &Block, buf: &Buffer) -> Result<(), ArrowError> {

Callers 2

read_dictionaryMethod · 0.80
read_record_batchMethod · 0.80

Calls 2

parse_messageFunction · 0.85
versionMethod · 0.45

Tested by

no test coverage detected