Function decode_i64_pipeline

nodedb-codec/src/pipeline.rs:127–156

Decode i64 values from a cascading pipeline.

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

/// Decode i64 values from a cascading pipeline.
pub fn decode_i64_pipeline(data: &[u8], codec: ColumnCodec) -> Result<Vec<i64>, CodecError> {
    match codec {
        // Cascading — lz4 terminal.
        ColumnCodec::DeltaFastLanesLz4 => decode_delta_fastlanes_lz4(data),
        ColumnCodec::FastLanesLz4 => decode_fastlanes_lz4_i64(data),
        ColumnCodec::PcodecLz4 => {
            let pco_bytes = crate::lz4::decode(data)?;
            crate::pcodec::decode_i64(&pco_bytes)
        }
        // Cascading — rANS terminal.
        ColumnCodec::DeltaFastLanesRans => decode_delta_fastlanes_rans(data),
        // Single-step codecs (small partitions / non-ALP-encodable data).
        ColumnCodec::DoubleDelta => crate::double_delta::decode(data),
        ColumnCodec::Delta => crate::delta::decode(data),
        ColumnCodec::Gorilla => crate::gorilla::decode_timestamps(data),
        ColumnCodec::Raw => {
            let raw = crate::raw::decode(data)?;
            raw_to_i64(&raw)
        }
        ColumnCodec::Lz4 => {
            let raw = crate::lz4::decode(data)?;
            raw_to_i64(&raw)
        }
        ColumnCodec::Zstd => {
            let raw = crate::zstd_codec::decode(data)?;
            raw_to_i64(&raw)
        }
        _ => crate::delta::decode(data),
    }
}

/// Decode f64 values from a cascading pipeline.
pub fn decode_f64_pipeline(data: &[u8], codec: ColumnCodec) -> Result<Vec<f64>, CodecError> {