fn test_last_value_operator()

in src/columnar_storage/src/operator.rs [120:137]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    fn test_last_value_operator() {
        let operator = LastValueOperator;
        let batch = record_batch!(
            ("pk1", UInt8, vec![11, 11, 11, 11]),
            ("pk2", UInt8, vec![100, 100, 100, 100]),
            ("value", Int64, vec![2, 7, 4, 1])
        )
        .unwrap();

        let actual = operator.merge(batch).unwrap();
        let expected = record_batch!(
            ("pk1", UInt8, vec![11]),
            ("pk2", UInt8, vec![100]),
            ("value", Int64, vec![1])
        )
        .unwrap();
        assert_eq!(actual, expected);
    }