Function decode_f64_pipeline

nodedb-codec/src/pipeline.rs:159–189

Decode f64 values from a cascading pipeline.

(data: &[u8], codec: ColumnCodec)

/// Decode f64 values from a cascading pipeline.
pub fn decode_f64_pipeline(data: &[u8], codec: ColumnCodec) -> Result<Vec<f64>, CodecError> {
    match codec {
        // Cascading — lz4 terminal.
        ColumnCodec::AlpFastLanesLz4 => decode_alp_fastlanes_lz4(data),
        ColumnCodec::AlpRdLz4 => {
            let alp_rd_bytes = crate::lz4::decode(data)?;
            crate::alp_rd::decode(&alp_rd_bytes)
        }
        ColumnCodec::PcodecLz4 => {
            let pco_bytes = crate::lz4::decode(data)?;
            crate::pcodec::decode_f64(&pco_bytes)
        }
        // Cascading — rANS terminal.
        ColumnCodec::AlpFastLanesRans => decode_alp_fastlanes_rans(data),
        // Single-step codecs (small partitions / non-ALP-encodable data).
        ColumnCodec::Gorilla => crate::gorilla::decode_f64(data),
        ColumnCodec::Raw => {
            let raw = crate::raw::decode(data)?;
            raw_to_f64(&raw)
        }
        ColumnCodec::Lz4 => {
            let raw = crate::lz4::decode(data)?;
            raw_to_f64(&raw)
        }
        ColumnCodec::Zstd => {
            let raw = crate::zstd_codec::decode(data)?;
            raw_to_f64(&raw)
        }
        _ => crate::gorilla::decode_f64(data),
    }
}

/// Decode raw bytes (symbol columns or string data) from a pipeline.
pub fn decode_bytes_pipeline(data: &[u8], codec: ColumnCodec) -> Result<Vec<u8>, CodecError> {