Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
RowWriter in datafusion_row::writer - Rust

datafusion_row::writer

Struct RowWriter

pub struct RowWriter { /* private fields */ }

Expand description

Reusable row writer backed by Vec<u8>

                            ┌ ─ ─ ─ ─ ─ ─ ─ ─
                                RowWriter    │
┌───────────────────────┐   │  [RowFormat]
│                       │                    │
│                       │   │(copy from Array
│                       │        to [u8])    │          ┌───────────────────────┐
│      RecordBatch      │   └ ─ ─ ─ ─ ─ ─ ─ ─           │       RowFormat       │
│                       │──────────────────────────────▶│        Vec<u8>        │
│   (... N Rows ...)    │                               │                       │
│                       │                               └───────────────────────┘
│                       │
│                       │
└───────────────────────┘

Implementations§

impl RowWriter

pub fn new(schema: &Schema) -> Self

New

pub fn reset(&mut self)

Reset the row writer state for new tuple

pub fn get_row(&self) -> &[u8] ⓘ

Get raw bytes

Auto Trait Implementations§

impl Freeze for RowWriter

impl RefUnwindSafe for RowWriter

impl Send for RowWriter

impl Sync for RowWriter

impl Unpin for RowWriter

impl UnwindSafe for RowWriter

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

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

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,