reifydb_routine/function/math/
atan2.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2025 ReifyDB
3
4use num_traits::ToPrimitive;
5use reifydb_core::value::column::{Column, columns::Columns, data::ColumnData};
6use reifydb_type::value::r#type::{Type, input_types::InputTypes};
7
8use crate::function::{Function, FunctionCapability, FunctionContext, FunctionInfo, error::FunctionError};
9
10pub struct Atan2 {
11	info: FunctionInfo,
12}
13
14impl Default for Atan2 {
15	fn default() -> Self {
16		Self::new()
17	}
18}
19
20impl Atan2 {
21	pub fn new() -> Self {
22		Self {
23			info: FunctionInfo::new("math::atan2"),
24		}
25	}
26}
27
28fn numeric_to_f64(data: &ColumnData, i: usize) -> Option<f64> {
29	match data {
30		ColumnData::Int1(c) => c.get(i).map(|&v| v as f64),
31		ColumnData::Int2(c) => c.get(i).map(|&v| v as f64),
32		ColumnData::Int4(c) => c.get(i).map(|&v| v as f64),
33		ColumnData::Int8(c) => c.get(i).map(|&v| v as f64),
34		ColumnData::Int16(c) => c.get(i).map(|&v| v as f64),
35		ColumnData::Uint1(c) => c.get(i).map(|&v| v as f64),
36		ColumnData::Uint2(c) => c.get(i).map(|&v| v as f64),
37		ColumnData::Uint4(c) => c.get(i).map(|&v| v as f64),
38		ColumnData::Uint8(c) => c.get(i).map(|&v| v as f64),
39		ColumnData::Uint16(c) => c.get(i).map(|&v| v as f64),
40		ColumnData::Float4(c) => c.get(i).map(|&v| v as f64),
41		ColumnData::Float8(c) => c.get(i).copied(),
42		ColumnData::Int {
43			container,
44			..
45		} => container.get(i).map(|v| v.0.to_f64().unwrap_or(0.0)),
46		ColumnData::Uint {
47			container,
48			..
49		} => container.get(i).map(|v| v.0.to_f64().unwrap_or(0.0)),
50		ColumnData::Decimal {
51			container,
52			..
53		} => container.get(i).map(|v| v.0.to_f64().unwrap_or(0.0)),
54		_ => None,
55	}
56}
57
58impl Function for Atan2 {
59	fn info(&self) -> &FunctionInfo {
60		&self.info
61	}
62
63	fn capabilities(&self) -> &[FunctionCapability] {
64		&[FunctionCapability::Scalar]
65	}
66
67	fn return_type(&self, _input_types: &[Type]) -> Type {
68		Type::Float8
69	}
70
71	fn execute(&self, ctx: &FunctionContext, args: &Columns) -> Result<Columns, FunctionError> {
72		if args.len() != 2 {
73			return Err(FunctionError::ArityMismatch {
74				function: ctx.fragment.clone(),
75				expected: 2,
76				actual: args.len(),
77			});
78		}
79
80		let y_col = &args[0];
81		let x_col = &args[1];
82
83		let (y_data, y_bitvec) = y_col.data().unwrap_option();
84		let (x_data, x_bitvec) = x_col.data().unwrap_option();
85		let row_count = y_data.len();
86
87		if !y_data.get_type().is_number() {
88			return Err(FunctionError::InvalidArgumentType {
89				function: ctx.fragment.clone(),
90				argument_index: 0,
91				expected: InputTypes::numeric().expected_at(0).to_vec(),
92				actual: y_data.get_type(),
93			});
94		}
95
96		if !x_data.get_type().is_number() {
97			return Err(FunctionError::InvalidArgumentType {
98				function: ctx.fragment.clone(),
99				argument_index: 1,
100				expected: InputTypes::numeric().expected_at(0).to_vec(),
101				actual: x_data.get_type(),
102			});
103		}
104
105		let mut result = Vec::with_capacity(row_count);
106		let mut res_bitvec = Vec::with_capacity(row_count);
107
108		for i in 0..row_count {
109			match (numeric_to_f64(y_data, i), numeric_to_f64(x_data, i)) {
110				(Some(y), Some(x)) => {
111					result.push(y.atan2(x));
112					res_bitvec.push(true);
113				}
114				_ => {
115					result.push(0.0);
116					res_bitvec.push(false);
117				}
118			}
119		}
120
121		let result_data = ColumnData::float8_with_bitvec(result, res_bitvec);
122
123		// Combine bitvecs if either column has options
124		let combined_bitvec = match (y_bitvec, x_bitvec) {
125			(Some(y_bv), Some(x_bv)) => Some(y_bv.and(x_bv)),
126			(Some(y_bv), None) => Some(y_bv.clone()),
127			(None, Some(x_bv)) => Some(x_bv.clone()),
128			(None, None) => None,
129		};
130
131		let final_data = if let Some(bv) = combined_bitvec {
132			ColumnData::Option {
133				inner: Box::new(result_data),
134				bitvec: bv,
135			}
136		} else {
137			result_data
138		};
139
140		Ok(Columns::new(vec![Column::new(ctx.fragment.clone(), final_data)]))
141	}
142}
reifydb_routine/function/math/atan2.rs

reifydb_routine/function/math/
atan2.rs
