Struct SequenceWriter

pub struct SequenceWriter { /* private fields */ }

Utility struct to associate SequenceId’s with chunks in an array stream. It wraps a SegmentWriter and enforces SegmentId’s sent to it are monotonically increasing. See SequenceId docs for more information.

Implementations

impl SequenceWriter

pub fn new(segment_writer: Box<dyn SegmentWriter>) -> Self

pub async fn put( &self, sequence_id: SequenceId, buffer: Vec<ByteBuffer>, ) -> VortexResult<SegmentId>

Wait until the given SequenceId is the first non dropped instance among all that self::new_sequential is created. Calls SegmentWriter::put with the resulting SegmentId. See SequenceId::collapse docs for more information.

pub fn new_sequential( &self, stream: SendableArrayStream, ) -> SendableSequentialStream

Annotate an array stream with sequence identifiers.

Each sequence id on an item in the stream would come after all others that come before it.

Consecutive calls would guarantee that all sequence id’s associated on the latter stream would come after all that were associated with the former stream.

Trait Implementations

impl Clone for SequenceWriter

fn clone(&self) -> SequenceWriter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.