Lines Matching refs:ScalarValue

26 use crate::scalar::ScalarValue;
111 sum: ScalarValue,
118 sum: ScalarValue::try_from(data_type)?, in try_new()
128 ScalarValue::$SCALAR(delta)
133 pub(super) fn sum_batch(values: &ArrayRef) -> Result<ScalarValue> { in sum_batch() argument
157 ScalarValue::$SCALAR(match ($OLD_VALUE, $DELTA) {
166 pub(super) fn sum(lhs: &ScalarValue, rhs: &ScalarValue) -> Result<ScalarValue> { in sum() argument
169 (ScalarValue::Float64(lhs), ScalarValue::Float64(rhs)) => { in sum()
172 (ScalarValue::Float64(lhs), ScalarValue::Float32(rhs)) => { in sum()
175 (ScalarValue::Float64(lhs), ScalarValue::Int64(rhs)) => { in sum()
178 (ScalarValue::Float64(lhs), ScalarValue::Int32(rhs)) => { in sum()
181 (ScalarValue::Float64(lhs), ScalarValue::Int16(rhs)) => { in sum()
184 (ScalarValue::Float64(lhs), ScalarValue::Int8(rhs)) => { in sum()
187 (ScalarValue::Float64(lhs), ScalarValue::UInt64(rhs)) => { in sum()
190 (ScalarValue::Float64(lhs), ScalarValue::UInt32(rhs)) => { in sum()
193 (ScalarValue::Float64(lhs), ScalarValue::UInt16(rhs)) => { in sum()
196 (ScalarValue::Float64(lhs), ScalarValue::UInt8(rhs)) => { in sum()
200 (ScalarValue::Float32(lhs), ScalarValue::Float32(rhs)) => { in sum()
204 (ScalarValue::UInt64(lhs), ScalarValue::UInt64(rhs)) => { in sum()
207 (ScalarValue::UInt64(lhs), ScalarValue::UInt32(rhs)) => { in sum()
210 (ScalarValue::UInt64(lhs), ScalarValue::UInt16(rhs)) => { in sum()
213 (ScalarValue::UInt64(lhs), ScalarValue::UInt8(rhs)) => { in sum()
217 (ScalarValue::Int64(lhs), ScalarValue::Int64(rhs)) => { in sum()
220 (ScalarValue::Int64(lhs), ScalarValue::Int32(rhs)) => { in sum()
223 (ScalarValue::Int64(lhs), ScalarValue::Int16(rhs)) => { in sum()
226 (ScalarValue::Int64(lhs), ScalarValue::Int8(rhs)) => { in sum()
245 fn update(&mut self, values: &[ScalarValue]) -> Result<()> { in update()
251 fn merge(&mut self, states: &[ScalarValue]) -> Result<()> { in merge()
261 fn state(&self) -> Result<Vec<ScalarValue>> { in state() argument
265 fn evaluate(&self) -> Result<ScalarValue> { in evaluate() argument
285 ScalarValue::from(15i64), in sum_i32()
303 ScalarValue::from(13i64), in sum_i32_with_nulls()
315 ScalarValue::Int64(None), in sum_i32_all_nulls()
328 ScalarValue::from(15u64), in sum_u32()
341 ScalarValue::from(15_f32), in sum_f32()
354 ScalarValue::from(15_f64), in sum_f64()
362 ) -> Result<ScalarValue> { in aggregate() argument