tests: selective less_than_const filter in fuzz tests

korowa · Sep 6, 2024 · 03423ff · 03423ff
1 parent 23bdb1a
commit 03423ff
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/datafusion/core/tests/fuzz_cases/join_fuzz.rs b/datafusion/core/tests/fuzz_cases/join_fuzz.rs
@@ -67,11 +67,11 @@ async fn test_inner_join_1k() {
     .await
 }
 
-fn less_than_100_join_filter(schema1: Arc<Schema>, _schema2: Arc<Schema>) -> JoinFilter {
+fn less_than_const_join_filter(schema1: Arc<Schema>, _schema2: Arc<Schema>) -> JoinFilter {
     let less_than_100 = Arc::new(BinaryExpr::new(
         Arc::new(Column::new("a", 0)),
         Operator::Lt,
-        Arc::new(Literal::new(ScalarValue::from(100))),
+        Arc::new(Literal::new(ScalarValue::from(70))),
     )) as _;
     let column_indices = vec![ColumnIndex {
         index: 0,
@@ -121,7 +121,7 @@ async fn test_inner_join_1k_filtered() {
         make_staggered_batches(1000),
         make_staggered_batches(1000),
         JoinType::Inner,
-        Some(Box::new(less_than_100_join_filter)),
+        Some(Box::new(less_than_const_join_filter)),
     )
     .run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
     .await
@@ -157,7 +157,7 @@ async fn test_left_join_1k_filtered() {
         make_staggered_batches(1000),
         make_staggered_batches(1000),
         JoinType::Left,
-        Some(Box::new(less_than_100_join_filter)),
+        Some(Box::new(less_than_const_join_filter)),
     )
     .run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
     .await
@@ -182,7 +182,7 @@ async fn test_right_join_1k_filtered() {
         make_staggered_batches(1000),
         make_staggered_batches(1000),
         JoinType::Right,
-        Some(Box::new(less_than_100_join_filter)),
+        Some(Box::new(less_than_const_join_filter)),
     )
     .run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
     .await
@@ -206,7 +206,7 @@ async fn test_full_join_1k_filtered() {
         make_staggered_batches(1000),
         make_staggered_batches(1000),
         JoinType::Full,
-        Some(Box::new(less_than_100_join_filter)),
+        Some(Box::new(less_than_const_join_filter)),
     )
     .run_test(&[JoinTestType::HjSmj, JoinTestType::NljHj], false)
     .await