Function encode_f64_pipeline

nodedb-codec/src/pipeline.rs:59–89

Encode f64 values through a cascading pipeline.

(values: &[f64], codec: ColumnCodec)

/// Encode f64 values through a cascading pipeline.
pub fn encode_f64_pipeline(values: &[f64], codec: ColumnCodec) -> Result<Vec<u8>, CodecError> {
    match codec {
        // Cascading chains — lz4 terminal.
        ColumnCodec::AlpFastLanesLz4 => encode_alp_fastlanes_lz4(values),
        ColumnCodec::AlpRdLz4 => {
            let alp_rd_bytes = crate::alp_rd::encode(values)?;
            Ok(crate::lz4::encode(&alp_rd_bytes))
        }
        ColumnCodec::PcodecLz4 => {
            let pco_bytes = crate::pcodec::encode_f64(values)?;
            Ok(crate::lz4::encode(&pco_bytes))
        }
        // Cascading chains — rANS terminal (cold tier).
        ColumnCodec::AlpFastLanesRans => encode_alp_fastlanes_rans(values),
        // Single-step codecs (small partitions / non-ALP-encodable data).
        ColumnCodec::Gorilla => Ok(crate::gorilla::encode_f64(values)),
        ColumnCodec::Raw => {
            let raw: Vec<u8> = values.iter().flat_map(|v| v.to_le_bytes()).collect();
            Ok(crate::raw::encode(&raw))
        }
        ColumnCodec::Lz4 => {
            let raw: Vec<u8> = values.iter().flat_map(|v| v.to_le_bytes()).collect();
            Ok(crate::lz4::encode(&raw))
        }
        ColumnCodec::Zstd => {
            let raw: Vec<u8> = values.iter().flat_map(|v| v.to_le_bytes()).collect();
            crate::zstd_codec::encode(&raw)
        }
        _ => Ok(crate::gorilla::encode_f64(values)),
    }
}

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