Skip to main content

MaterializingSink

graphos_core::execution::sink

Struct MaterializingSink 

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

Materializing sink that buffers all data in memory.

Used for pipeline breakers that need to see all input before producing output.

Implementations§

Source§

impl MaterializingSink

Source

pub fn new() -> Self

Create a new materializing sink.

Source

pub fn chunks(&self) -> &[DataChunk]

Get all materialized data.

Source

pub fn into_chunks(self) -> Vec<DataChunk>

Take ownership of materialized chunks.

Source

pub fn row_count(&self) -> usize

Get total row count.

Source

pub fn memory_bytes(&self) -> usize

Get estimated memory usage in bytes.

Source

pub fn into_single_chunk(self) -> DataChunk

Merge all chunks into a single chunk.

Trait Implementations§

Source§

impl Default for MaterializingSink

Source§

fn default() -> Self

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

impl Sink for MaterializingSink

Source§

fn consume(&mut self, chunk: DataChunk) -> Result<bool, OperatorError>

Consume a chunk of data. Read more
Source§

fn finalize(&mut self) -> Result<(), OperatorError>

Called when all input has been processed.
Source§

fn name(&self) -> &'static str

Name of this sink for debugging.

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<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> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
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.