Skip to main content

CompressorPlugin

Trait CompressorPlugin 

Source
pub trait CompressorPlugin:
    Send
    + Sync
    + 'static {
    // Required method
    fn compress_chunk(
        &self,
        chunk: &ArrayRef,
        ctx: &mut ExecutionCtx,
    ) -> VortexResult<ArrayRef>;
}
Expand description

A boxed compressor function from arrays into compressed arrays.

API consumers are free to implement this trait to provide new plugin compressors.

Required Methods§

Source

fn compress_chunk( &self, chunk: &ArrayRef, ctx: &mut ExecutionCtx, ) -> VortexResult<ArrayRef>

Implementations on Foreign Types§

Source§

impl CompressorPlugin for Arc<dyn CompressorPlugin>

Source§

impl CompressorPlugin for BtrBlocksCompressor

Implementors§

Source§

impl<F> CompressorPlugin for F
where F: Fn(&ArrayRef, &mut ExecutionCtx) -> VortexResult<ArrayRef> + Send + Sync + 'static,