Struct SchemaSplitter 

pub struct SchemaSplitter<E, F> { /* private fields */ }

Splits a stream by schema.

Implementations

impl<E, F> SchemaSplitter<E, F>

where F: Fn(Schema, Option<Metadata>) -> Result<E>,

pub fn new(build_encoder: F, no_schema_behavior: NoSchemaBehavior) -> Self

Creates a new splitter that will split the input stream by schema, creating a separate sub-encoder for each schema using build_encoder.

The no_schema_behavior determines how records with rtypes that don’t map to a schema (such as ErrorMsg) are handled.

Trait Implementations

impl<E: Debug, F: Debug> Debug for SchemaSplitter<E, F>

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

Formats the value using the given formatter.

impl<E, F> Splitter<E> for SchemaSplitter<E, F>

where F: Fn(Schema, Option<Metadata>) -> Result<E>, E: EncodeRecordRef,

fn sub_encoder<R>( &mut self, metadata: Option<&Metadata>, record: &R, ) -> Result<Option<&mut E>>

where R: Record,

Returns the encoder for the given record, or None if the record should be ignored.

fn sub_encoders<'a>(&'a mut self) -> impl Iterator<Item = &'a mut E>

where E: 'a,

Returns an iterator over all active sub-encoders.