fn test_bytes_merge_operator()

in src/columnar_storage/src/operator.rs [140:159]

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

    fn test_bytes_merge_operator() {
        let operator = BytesMergeOperator::new(vec![2]);

        let batch = record_batch!(
            ("pk1", UInt8, vec![11, 11, 11, 11]),
            ("pk2", UInt8, vec![100, 100, 100, 100]),
            ("value", Binary, vec![b"one", b"two", b"three", b"four"])
        )
        .unwrap();

        let actual = operator.merge(batch).unwrap();
        let expected = record_batch!(
            ("pk1", UInt8, vec![11]),
            ("pk2", UInt8, vec![100]),
            ("value", Binary, vec![b"onetwothreefour"])
        )
        .unwrap();

        assert_eq!(actual, expected);
    }