Trait ChunkProcessor 

pub trait ChunkProcessor<T> {
    // Required methods
    fn process(&mut self, chunk: ArrayView<'_, T, IxDyn>) -> Result<()>;
    fn finalize(self) -> Result<()>;
}

Chunk processor for streaming operations

Required Methods

fn process(&mut self, chunk: ArrayView<'_, T, IxDyn>) -> Result<()>

Process a chunk of data

fn finalize(self) -> Result<()>

Finalize processing

Implementors