Lines Matching refs:ScalarValue
27 use crate::logicalplan::{Operator, ScalarValue};
167 Some(ScalarValue::$SCALAR_VARIANT(n)) => {
168 Some(ScalarValue::$SCALAR_VARIANT(n + $VALUE as $TY))
175 None => Some(ScalarValue::$SCALAR_VARIANT($VALUE as $TY)),
181 sum: Option<ScalarValue>,
185 fn accumulate_scalar(&mut self, value: Option<ScalarValue>) -> Result<()> { in accumulate_scalar()
188 ScalarValue::Int8(value) => { in accumulate_scalar()
191 ScalarValue::Int16(value) => { in accumulate_scalar()
194 ScalarValue::Int32(value) => { in accumulate_scalar()
197 ScalarValue::Int64(value) => { in accumulate_scalar()
200 ScalarValue::UInt8(value) => { in accumulate_scalar()
203 ScalarValue::UInt16(value) => { in accumulate_scalar()
206 ScalarValue::UInt32(value) => { in accumulate_scalar()
209 ScalarValue::UInt64(value) => { in accumulate_scalar()
212 ScalarValue::Float32(value) => { in accumulate_scalar()
215 ScalarValue::Float64(value) => { in accumulate_scalar()
233 Some(n) => Ok(Some(ScalarValue::UInt8(n))), in accumulate_batch()
240 Some(n) => Ok(Some(ScalarValue::UInt16(n))), in accumulate_batch()
247 Some(n) => Ok(Some(ScalarValue::UInt32(n))), in accumulate_batch()
254 Some(n) => Ok(Some(ScalarValue::UInt64(n))), in accumulate_batch()
260 Some(n) => Ok(Some(ScalarValue::Int8(n))), in accumulate_batch()
266 Some(n) => Ok(Some(ScalarValue::Int16(n))), in accumulate_batch()
272 Some(n) => Ok(Some(ScalarValue::Int32(n))), in accumulate_batch()
278 Some(n) => Ok(Some(ScalarValue::Int64(n))), in accumulate_batch()
285 Some(n) => Ok(Some(ScalarValue::Float32(n))), in accumulate_batch()
292 Some(n) => Ok(Some(ScalarValue::Float64(n))), in accumulate_batch()
303 fn get_value(&self) -> Result<Option<ScalarValue>> { in get_value() argument
385 fn accumulate_scalar(&mut self, value: Option<ScalarValue>) -> Result<()> { in accumulate_scalar()
388 ScalarValue::Int8(value) => avg_accumulate!(self, value, Int8Array), in accumulate_scalar()
389 ScalarValue::Int16(value) => avg_accumulate!(self, value, Int16Array), in accumulate_scalar()
390 ScalarValue::Int32(value) => avg_accumulate!(self, value, Int32Array), in accumulate_scalar()
391 ScalarValue::Int64(value) => avg_accumulate!(self, value, Int64Array), in accumulate_scalar()
392 ScalarValue::UInt8(value) => avg_accumulate!(self, value, UInt8Array), in accumulate_scalar()
393 ScalarValue::UInt16(value) => avg_accumulate!(self, value, UInt16Array), in accumulate_scalar()
394 ScalarValue::UInt32(value) => avg_accumulate!(self, value, UInt32Array), in accumulate_scalar()
395 ScalarValue::UInt64(value) => avg_accumulate!(self, value, UInt64Array), in accumulate_scalar()
396 ScalarValue::Float32(value) => avg_accumulate!(self, value, Float32Array), in accumulate_scalar()
397 ScalarValue::Float64(value) => avg_accumulate!(self, value, Float64Array), in accumulate_scalar()
416 fn get_value(&self) -> Result<Option<ScalarValue>> { in get_value() argument
419 Ok(Some(ScalarValue::Float64(sum / count as f64))) in get_value()
481 Some(ScalarValue::$SCALAR_VARIANT(n)) => {
483 Some(ScalarValue::$SCALAR_VARIANT(n))
485 Some(ScalarValue::$SCALAR_VARIANT($VALUE as $TY))
493 None => Some(ScalarValue::$SCALAR_VARIANT($VALUE as $TY)),
498 max: Option<ScalarValue>,
502 fn accumulate_scalar(&mut self, value: Option<ScalarValue>) -> Result<()> { in accumulate_scalar()
505 ScalarValue::Int8(value) => { in accumulate_scalar()
508 ScalarValue::Int16(value) => { in accumulate_scalar()
511 ScalarValue::Int32(value) => { in accumulate_scalar()
514 ScalarValue::Int64(value) => { in accumulate_scalar()
517 ScalarValue::UInt8(value) => { in accumulate_scalar()
520 ScalarValue::UInt16(value) => { in accumulate_scalar()
523 ScalarValue::UInt32(value) => { in accumulate_scalar()
526 ScalarValue::UInt64(value) => { in accumulate_scalar()
529 ScalarValue::Float32(value) => { in accumulate_scalar()
532 ScalarValue::Float64(value) => { in accumulate_scalar()
550 Some(n) => Ok(Some(ScalarValue::UInt8(n))), in accumulate_batch()
557 Some(n) => Ok(Some(ScalarValue::UInt16(n))), in accumulate_batch()
564 Some(n) => Ok(Some(ScalarValue::UInt32(n))), in accumulate_batch()
571 Some(n) => Ok(Some(ScalarValue::UInt64(n))), in accumulate_batch()
577 Some(n) => Ok(Some(ScalarValue::Int8(n))), in accumulate_batch()
583 Some(n) => Ok(Some(ScalarValue::Int16(n))), in accumulate_batch()
589 Some(n) => Ok(Some(ScalarValue::Int32(n))), in accumulate_batch()
595 Some(n) => Ok(Some(ScalarValue::Int64(n))), in accumulate_batch()
602 Some(n) => Ok(Some(ScalarValue::Float32(n))), in accumulate_batch()
609 Some(n) => Ok(Some(ScalarValue::Float64(n))), in accumulate_batch()
620 fn get_value(&self) -> Result<Option<ScalarValue>> { in get_value() argument
680 Some(ScalarValue::$SCALAR_VARIANT(n)) => {
682 Some(ScalarValue::$SCALAR_VARIANT(n))
684 Some(ScalarValue::$SCALAR_VARIANT($VALUE as $TY))
692 None => Some(ScalarValue::$SCALAR_VARIANT($VALUE as $TY)),
697 min: Option<ScalarValue>,
701 fn accumulate_scalar(&mut self, value: Option<ScalarValue>) -> Result<()> { in accumulate_scalar()
704 ScalarValue::Int8(value) => { in accumulate_scalar()
707 ScalarValue::Int16(value) => { in accumulate_scalar()
710 ScalarValue::Int32(value) => { in accumulate_scalar()
713 ScalarValue::Int64(value) => { in accumulate_scalar()
716 ScalarValue::UInt8(value) => { in accumulate_scalar()
719 ScalarValue::UInt16(value) => { in accumulate_scalar()
722 ScalarValue::UInt32(value) => { in accumulate_scalar()
725 ScalarValue::UInt64(value) => { in accumulate_scalar()
728 ScalarValue::Float32(value) => { in accumulate_scalar()
731 ScalarValue::Float64(value) => { in accumulate_scalar()
749 Some(n) => Ok(Some(ScalarValue::UInt8(n))), in accumulate_batch()
756 Some(n) => Ok(Some(ScalarValue::UInt16(n))), in accumulate_batch()
763 Some(n) => Ok(Some(ScalarValue::UInt32(n))), in accumulate_batch()
770 Some(n) => Ok(Some(ScalarValue::UInt64(n))), in accumulate_batch()
776 Some(n) => Ok(Some(ScalarValue::Int8(n))), in accumulate_batch()
782 Some(n) => Ok(Some(ScalarValue::Int16(n))), in accumulate_batch()
788 Some(n) => Ok(Some(ScalarValue::Int32(n))), in accumulate_batch()
794 Some(n) => Ok(Some(ScalarValue::Int64(n))), in accumulate_batch()
801 Some(n) => Ok(Some(ScalarValue::Float32(n))), in accumulate_batch()
808 Some(n) => Ok(Some(ScalarValue::Float64(n))), in accumulate_batch()
819 fn get_value(&self) -> Result<Option<ScalarValue>> { in get_value() argument
869 fn accumulate_scalar(&mut self, value: Option<ScalarValue>) -> Result<()> { in accumulate_scalar()
881 fn get_value(&self) -> Result<Option<ScalarValue>> { in get_value() argument
882 Ok(Some(ScalarValue::UInt64(self.count))) in get_value()
1192 value: ScalarValue,
1197 pub fn new(value: ScalarValue) -> Self { in new()
1225 ScalarValue::Int8(value) => build_literal_array!(batch, Int8Builder, *value), in evaluate()
1226 ScalarValue::Int16(value) => { in evaluate()
1229 ScalarValue::Int32(value) => { in evaluate()
1232 ScalarValue::Int64(value) => { in evaluate()
1235 ScalarValue::UInt8(value) => { in evaluate()
1238 ScalarValue::UInt16(value) => { in evaluate()
1241 ScalarValue::UInt32(value) => { in evaluate()
1244 ScalarValue::UInt64(value) => { in evaluate()
1247 ScalarValue::Float32(value) => { in evaluate()
1250 ScalarValue::Float64(value) => { in evaluate()
1253 ScalarValue::Utf8(value) => build_literal_array!(batch, StringBuilder, value), in evaluate()
1263 pub fn lit(value: ScalarValue) -> Arc<dyn PhysicalExpr> { in lit()
1348 let literal_expr = lit(ScalarValue::Int32(42)); in literal_i32()
1500 assert_eq!(do_sum(&batch)?, Some(ScalarValue::Int64(15))); in sum_i32()
1512 assert_eq!(do_avg(&batch)?, Some(ScalarValue::Float64(3_f64))); in avg_i32()
1524 assert_eq!(do_max(&batch)?, Some(ScalarValue::Int64(5))); in max_i32()
1536 assert_eq!(do_min(&batch)?, Some(ScalarValue::Int64(1))); in min_i32()
1548 assert_eq!(do_sum(&batch)?, Some(ScalarValue::Int64(13))); in sum_i32_with_nulls()
1560 assert_eq!(do_avg(&batch)?, Some(ScalarValue::Float64(3.25))); in avg_i32_with_nulls()
1572 assert_eq!(do_max(&batch)?, Some(ScalarValue::Int64(5))); in max_i32_with_nulls()
1584 assert_eq!(do_min(&batch)?, Some(ScalarValue::Int64(1))); in min_i32_with_nulls()
1644 assert_eq!(do_sum(&batch)?, Some(ScalarValue::UInt64(15_u64))); in sum_u32()
1656 assert_eq!(do_avg(&batch)?, Some(ScalarValue::Float64(3_f64))); in avg_u32()
1668 assert_eq!(do_max(&batch)?, Some(ScalarValue::UInt64(5_u64))); in max_u32()
1680 assert_eq!(do_min(&batch)?, Some(ScalarValue::UInt64(1_u64))); in min_u32()
1692 assert_eq!(do_sum(&batch)?, Some(ScalarValue::Float32(15_f32))); in sum_f32()
1704 assert_eq!(do_avg(&batch)?, Some(ScalarValue::Float64(3_f64))); in avg_f32()
1716 assert_eq!(do_max(&batch)?, Some(ScalarValue::Float32(5_f32))); in max_f32()
1728 assert_eq!(do_min(&batch)?, Some(ScalarValue::Float32(1_f32))); in min_f32()
1740 assert_eq!(do_sum(&batch)?, Some(ScalarValue::Float64(15_f64))); in sum_f64()
1752 assert_eq!(do_avg(&batch)?, Some(ScalarValue::Float64(3_f64))); in avg_f64()
1764 assert_eq!(do_max(&batch)?, Some(ScalarValue::Float64(5_f64))); in max_f64()
1776 assert_eq!(do_min(&batch)?, Some(ScalarValue::Float64(1_f64))); in min_f64()
1786 assert_eq!(do_count(&batch)?, Some(ScalarValue::UInt64(5))); in count_elements()
1795 assert_eq!(do_count(&batch)?, Some(ScalarValue::UInt64(3))); in count_with_nulls()
1804 assert_eq!(do_count(&batch)?, Some(ScalarValue::UInt64(0))); in count_all_nulls()
1813 assert_eq!(do_count(&batch)?, Some(ScalarValue::UInt64(0))); in count_empty()
1817 fn do_sum(batch: &RecordBatch) -> Result<Option<ScalarValue>> { in do_sum() argument
1828 fn do_max(batch: &RecordBatch) -> Result<Option<ScalarValue>> { in do_max() argument
1839 fn do_min(batch: &RecordBatch) -> Result<Option<ScalarValue>> { in do_min() argument
1850 fn do_count(batch: &RecordBatch) -> Result<Option<ScalarValue>> { in do_count() argument
1861 fn do_avg(batch: &RecordBatch) -> Result<Option<ScalarValue>> { in do_avg() argument