@@ -8345,6 +8345,41 @@ ORDER BY "source"."str0" ASC
83458345 order: Some(vec![]),
83468346 ..Default::default()
83478347 }
8348+ );
8349+
8350+ let logical_plan = convert_select_to_query_plan(
8351+ "SELECT DISTINCT * FROM KibanaSampleDataEcommerce".to_string(),
8352+ DatabaseProtocol::PostgreSQL,
8353+ )
8354+ .await
8355+ .as_logical_plan();
8356+
8357+ println!("logical_plan: {:?}", logical_plan);
8358+
8359+ assert_eq!(
8360+ logical_plan.find_cube_scan().request,
8361+ V1LoadRequestQuery {
8362+ measures: Some(vec![
8363+ "KibanaSampleDataEcommerce.count".to_string(),
8364+ "KibanaSampleDataEcommerce.maxPrice".to_string(),
8365+ "KibanaSampleDataEcommerce.sumPrice".to_string(),
8366+ "KibanaSampleDataEcommerce.minPrice".to_string(),
8367+ "KibanaSampleDataEcommerce.avgPrice".to_string(),
8368+ "KibanaSampleDataEcommerce.countDistinct".to_string(),
8369+ ]),
8370+ dimensions: Some(vec![
8371+ "KibanaSampleDataEcommerce.order_date".to_string(),
8372+ "KibanaSampleDataEcommerce.last_mod".to_string(),
8373+ "KibanaSampleDataEcommerce.customer_gender".to_string(),
8374+ "KibanaSampleDataEcommerce.notes".to_string(),
8375+ "KibanaSampleDataEcommerce.taxful_total_price".to_string(),
8376+ "KibanaSampleDataEcommerce.has_subscription".to_string(),
8377+ ]),
8378+ segments: Some(vec![]),
8379+ order: Some(vec![]),
8380+ ungrouped: Some(true),
8381+ ..Default::default()
8382+ }
83488383 )
83498384 }
83508385
0 commit comments