1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
use std::sync::Arc;
use crate::expressions::{BinaryExpr, Literal};
use crate::PhysicalExpr;
use datafusion_common::ScalarValue;
use datafusion_expr::Operator;
#[allow(clippy::too_many_arguments)]
pub fn gen_conjunctive_numeric_expr(
left_col: Arc<dyn PhysicalExpr>,
right_col: Arc<dyn PhysicalExpr>,
op_1: Operator,
op_2: Operator,
op_3: Operator,
op_4: Operator,
a: i32,
b: i32,
c: i32,
d: i32,
) -> Arc<dyn PhysicalExpr> {
let left_and_1 = Arc::new(BinaryExpr::new(
left_col.clone(),
op_1,
Arc::new(Literal::new(ScalarValue::Int32(Some(a)))),
));
let left_and_2 = Arc::new(BinaryExpr::new(
right_col.clone(),
op_2,
Arc::new(Literal::new(ScalarValue::Int32(Some(b)))),
));
let right_and_1 = Arc::new(BinaryExpr::new(
left_col,
op_3,
Arc::new(Literal::new(ScalarValue::Int32(Some(c)))),
));
let right_and_2 = Arc::new(BinaryExpr::new(
right_col,
op_4,
Arc::new(Literal::new(ScalarValue::Int32(Some(d)))),
));
let left_expr = Arc::new(BinaryExpr::new(left_and_1, Operator::Gt, left_and_2));
let right_expr = Arc::new(BinaryExpr::new(right_and_1, Operator::Lt, right_and_2));
Arc::new(BinaryExpr::new(left_expr, Operator::And, right_expr))
}