Function test_distinct_on

datafusion/core/tests/dataframe/mod.rs:1395–1424

()

#[tokio::test]
async fn test_distinct_on() -> Result<()> {
    let t = test_table().await?;
    let plan = t
        .distinct_on(vec![col("c1")], vec![col("aggregate_test_100.c1")], None)
        .unwrap();

    let sql_plan =
        create_plan("select distinct on (c1) c1 from aggregate_test_100").await?;

    assert_same_plan(&plan.logical_plan().clone(), &sql_plan);

    let df_results = plan.clone().collect().await?;

    assert_snapshot!(
        batches_to_sort_string(&df_results),
        @r"
    +----+
    | c1 |
    +----+
    | a  |
    | b  |
    | c  |
    | d  |
    | e  |
    +----+
    "
    );

    Ok(())
}

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