polars_parquet_format::thrift::protocol

Struct TCompactInputProtocol

Source
pub struct TCompactInputProtocol<R>
where R: Read,
{ /* private fields */ }
Expand description

Read messages encoded in the Thrift compact protocol.

Implementations§

Source§

impl<R> TCompactInputProtocol<R>
where R: Read,

Source

pub fn new(reader: R, max_bytes: usize) -> Self

Create a TCompactInputProtocol that reads bytes from reader.

Trait Implementations§

Source§

impl<R> Debug for TCompactInputProtocol<R>
where R: Read + Debug,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<R> Seek for TCompactInputProtocol<R>
where R: Seek + Read,

Source§

fn seek(&mut self, pos: SeekFrom) -> Result<u64>

Seek to an offset, in bytes, in a stream. Read more
1.55.0 · Source§

fn rewind(&mut self) -> Result<(), Error>

Rewind to the beginning of a stream. Read more
Source§

fn stream_len(&mut self) -> Result<u64, Error>

🔬This is a nightly-only experimental API. (seek_stream_len)
Returns the length of this stream (in bytes). Read more
1.51.0 · Source§

fn stream_position(&mut self) -> Result<u64, Error>

Returns the current seek position from the start of the stream. Read more
1.80.0 · Source§

fn seek_relative(&mut self, offset: i64) -> Result<(), Error>

Seeks relative to the current position. Read more
Source§

impl<R> TInputProtocol for TCompactInputProtocol<R>
where R: Read,

Source§

fn read_message_begin(&mut self) -> Result<TMessageIdentifier>

Read the beginning of a Thrift message.
Source§

fn read_message_end(&mut self) -> Result<()>

Read the end of a Thrift message.
Source§

fn read_struct_begin(&mut self) -> Result<Option<TStructIdentifier>>

Read the beginning of a Thrift struct.
Source§

fn read_struct_end(&mut self) -> Result<()>

Read the end of a Thrift struct.
Source§

fn read_field_begin(&mut self) -> Result<TFieldIdentifier>

Read the beginning of a Thrift struct field.
Source§

fn read_field_end(&mut self) -> Result<()>

Read the end of a Thrift struct field.
Source§

fn read_bool(&mut self) -> Result<bool>

Read a bool.
Source§

fn read_bytes(&mut self) -> Result<Vec<u8>>

Read a fixed-length byte array.
Source§

fn read_i8(&mut self) -> Result<i8>

Read a word.
Source§

fn read_i16(&mut self) -> Result<i16>

Read a 16-bit signed integer.
Source§

fn read_i32(&mut self) -> Result<i32>

Read a 32-bit signed integer.
Source§

fn read_i64(&mut self) -> Result<i64>

Read a 64-bit signed integer.
Source§

fn read_double(&mut self) -> Result<f64>

Read a 64-bit float.
Source§

fn read_string(&mut self) -> Result<String>

Read a fixed-length string (not null terminated).
Source§

fn read_list_begin(&mut self) -> Result<TListIdentifier>

Read the beginning of a list.
Source§

fn read_list_end(&mut self) -> Result<()>

Read the end of a list.
Source§

fn read_set_begin(&mut self) -> Result<TSetIdentifier>

Read the beginning of a set.
Source§

fn read_set_end(&mut self) -> Result<()>

Read the end of a set.
Source§

fn read_map_begin(&mut self) -> Result<TMapIdentifier>

Read the beginning of a map.
Source§

fn read_map_end(&mut self) -> Result<()>

Read the end of a map.
Source§

fn read_byte(&mut self) -> Result<u8>

Read an unsigned byte. Read more
Source§

fn skip(&mut self, field_type: TType) -> Result<()>

Skip a field with type field_type recursively until the default maximum skip depth is reached.
Source§

fn skip_till_depth(&mut self, field_type: TType, depth: i8) -> Result<()>

Skip a field with type field_type recursively up to depth levels.
Source§

fn read_list<P: ReadThrift>(&mut self) -> Result<Vec<P>>

Auto Trait Implementations§

§

impl<R> Freeze for TCompactInputProtocol<R>
where R: Freeze,

§

impl<R> RefUnwindSafe for TCompactInputProtocol<R>
where R: RefUnwindSafe,

§

impl<R> Send for TCompactInputProtocol<R>
where R: Send,

§

impl<R> Sync for TCompactInputProtocol<R>
where R: Sync,

§

impl<R> Unpin for TCompactInputProtocol<R>
where R: Unpin,

§

impl<R> UnwindSafe for TCompactInputProtocol<R>
where R: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.