Skip to main content

DirectPathPieceBuffer

Struct DirectPathPieceBuffer 

Source
pub struct DirectPathPieceBuffer { /* private fields */ }
Expand description

Streaming encoder for the direct path column-array piece format.

Port of the reference PieceBuffer (direct_path_load_stream.pyx). Usage: start_row() / add_column_value(..) per column / finish_row(), then DirectPathPieceBuffer::finish.

Implementations§

Source§

impl DirectPathPieceBuffer

Source

pub fn new() -> Self

Source

pub fn start_row(&mut self) -> Result<()>

Source

pub fn finish_row(&mut self) -> Result<()>

Source

pub fn add_column_value( &mut self, metadata: &ColumnMetadata, value: &DirectPathColumnValue, row_num: u64, ) -> Result<()>

Source

pub fn finish(self) -> Result<(Vec<DirectPathPiece>, u32)>

Finalizes the stream and returns the pieces plus the total piece length (piece data plus piece headers) for the load stream message.

Trait Implementations§

Source§

impl Debug for DirectPathPieceBuffer

Source§

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

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

impl Default for DirectPathPieceBuffer

Source§

fn default() -> DirectPathPieceBuffer

Returns the “default value” for a type. Read more

Auto Trait Implementations§

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

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> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
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.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V