Trait connectorx::destinations::Consume

source · 
pub trait Consume<T> {
    type Error: From<ConnectorXError> + Send;

    // Required method
    fn consume(&mut self, value: T) -> Result<(), Self::Error>;
}
Expand description

A type implemented Consume<T> means that it can consume a value T by adding it to it’s own buffer.

Required Associated Types§

source

type Error: From<ConnectorXError> + Send

Required Methods§

source

fn consume(&mut self, value: T) -> Result<(), Self::Error>

Implementors§

source§

impl<'a, T> Consume<T> for connectorx::destinations::arrow2::ArrowPartitionWriter
where T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,

§

type Error = Arrow2DestinationError

source§

impl<'a, T> Consume<T> for connectorx::destinations::arrow::ArrowPartitionWriter
where T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,

§

type Error = ArrowDestinationError

source§

impl<'a, T> Consume<T> for connectorx::destinations::arrowstream::ArrowPartitionWriter
where T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,

§

type Error = ArrowDestinationError