Function join_coercion_unnamed

datafusion/core/tests/dataframe/mod.rs:1498–1528

()

#[tokio::test]
async fn join_coercion_unnamed() -> Result<()> {
    let ctx = SessionContext::new();

    // Test that join will coerce column types when necessary
    // even when the relations don't have unique names
    let left = ctx.read_batch(record_batch!(
        ("id", Int32, [1, 2, 3]),
        ("name", Utf8, ["a", "b", "c"])
    )?)?;
    let right = ctx.read_batch(record_batch!(
        ("id", Int32, [10, 3]),
        ("name", Utf8View, ["d", "c"]) // Utf8View is a different type
    )?)?;
    let cols = vec!["name", "id"];

    let filter = None;
    let join = right.join(left, JoinType::LeftAnti, &cols, &cols, filter)?;
    let results = join.collect().await?;

    assert_snapshot!(
        batches_to_sort_string(&results),
        @r"
    +----+------+
    | id | name |
    +----+------+
    | 10 | d    |
    +----+------+
    "
    );
    Ok(())
}

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