Function create_null_table

datafusion/core/tests/dataframe/mod.rs:6429–6454

()

}

async fn create_null_table() -> Result<DataFrame> {
    // create a DataFrame with null values
    //    "+---+----+",
    //    "| a | b |",
    //    "+---+---+",
    //    "| 1 | x |",
    //    "|   |   |",
    //    "| 3 | z |",
    //    "+---+---+",
    let schema = Arc::new(Schema::new(vec![
        Field::new("a", DataType::Int32, true),
        Field::new("b", DataType::Utf8, true),
    ]));
    let a_values = Int32Array::from(vec![Some(1), None, Some(3)]);
    let b_values = StringArray::from(vec![Some("x"), None, Some("z")]);
    let batch = RecordBatch::try_new(
        schema.clone(),
        vec![Arc::new(a_values), Arc::new(b_values)],
    )?;

    let ctx = SessionContext::new();
    let table = MemTable::try_new(schema.clone(), vec![vec![batch]])?;
    ctx.register_table("t_null", Arc::new(table))?;
    let df = ctx.table("t_null").await?;
    Ok(df)
}

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