Function nullif_list

datafusion/functions/src/core/nullif.rs:309–338

()

    #[test]
    fn nullif_list() -> Result<()> {
        let lhs = Arc::new(ListArray::from_iter_primitive::<Int64Type, _, _>(vec![
            Some(vec![Some(1), Some(2)]),
            Some(vec![Some(3)]),
            Some(vec![]),
            Some(vec![Some(5), Some(6), Some(7)]),
            None,
        ]));
        let lhs = ColumnarValue::Array(lhs);

        let rhs = Arc::new(ListArray::from_iter_primitive::<Int64Type, _, _>(vec![
            Some(vec![Some(1), Some(2)]),
        ]));
        let rhs = ColumnarValue::Scalar(ScalarValue::List(rhs));

        let result = nullif_func(&[lhs, rhs])?;
        let result = result.into_array(0).expect("Failed to convert to array");

        let expected = Arc::new(ListArray::from_iter_primitive::<Int64Type, _, _>(vec![
            None,
            Some(vec![Some(3)]),
            Some(vec![]),
            Some(vec![Some(5), Some(6), Some(7)]),
            None,
        ])) as ArrayRef;

        assert_eq!(expected.as_ref(), result.as_ref());

        Ok(())
    }

    #[test]
    fn nullif_compare_nested_to_unnested() -> Result<()> {