Function test_fill_null

datafusion/core/tests/dataframe/mod.rs:6457–6483

()

#[tokio::test]
async fn test_fill_null() -> Result<()> {
    let df = create_null_table().await?;

    // Use fill_null to replace nulls on each column.
    let df_filled = df
        .fill_null(ScalarValue::Int32(Some(0)), vec!["a".to_string()])?
        .fill_null(
            ScalarValue::Utf8(Some("default".to_string())),
            vec!["b".to_string()],
        )?;

    let results = df_filled.collect().await?;
    assert_snapshot!(
        batches_to_sort_string(&results),
        @r"
    +---+---------+
    | a | b       |
    +---+---------+
    | 0 | default |
    | 1 | x       |
    | 3 | z       |
    +---+---------+
    "
    );

    Ok(())
}

#[tokio::test]
async fn test_fill_null_all_columns() -> Result<()> {