Function distribute_by

datafusion/optimizer/tests/optimizer_integration.rs:184–197

()

#[test]
fn distribute_by() -> Result<()> {
    // regression test for https://github.com/apache/datafusion/issues/3234
    let sql = "SELECT col_int32, col_utf8 FROM test DISTRIBUTE BY (col_utf8)";
    let plan = test_sql(sql)?;

    assert_snapshot!(
    format!("{plan}"),
    @r"
    Repartition: DistributeBy(test.col_utf8)
      TableScan: test projection=[col_int32, col_utf8]
    "
    );
    Ok(())
}

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