pub(crate) enum IpcMessage {
Schema(Schema),
RecordBatch(RecordBatch),
DictionaryBatch {
id: i64,
is_delta: bool,
values: ArrayRef,
},
}
Expand description
Representation of a fully parsed IpcMessage from the underlying stream.
Parsing this kind of message is done by higher level constructs such as
StreamReader
, because fully interpreting the messages into a record
batch or dictionary batch requires access to stream state such as schema
and the full dictionary cache.
Variants§
Trait Implementations§
Auto Trait Implementations§
impl Freeze for IpcMessage
impl !RefUnwindSafe for IpcMessage
impl Send for IpcMessage
impl Sync for IpcMessage
impl Unpin for IpcMessage
impl !UnwindSafe for IpcMessage
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more