Convert to a set of ScalarValues
(&self)
| 736 | |
| 737 | /// Convert to a set of ScalarValues |
| 738 | fn to_state(&self) -> Result<ScalarValue> { |
| 739 | let f64arr = Arc::new(Float64Array::from(vec![self.value])) as ArrayRef; |
| 740 | let timearr = |
| 741 | Arc::new(TimestampNanosecondArray::from(vec![self.time])) as ArrayRef; |
| 742 | |
| 743 | let struct_arr = |
| 744 | StructArray::try_new(Self::fields(), vec![f64arr, timearr], None)?; |
| 745 | Ok(ScalarValue::Struct(Arc::new(struct_arr))) |
| 746 | } |
| 747 | } |
| 748 | |
| 749 | impl Accumulator for FirstSelector { |