(&mut self, states: &[ArrayRef])
| 242 | } |
| 243 | |
| 244 | fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()> { |
| 245 | let states_c = [ |
| 246 | Arc::clone(&states[0]), |
| 247 | Arc::clone(&states[1]), |
| 248 | Arc::clone(&states[3]), |
| 249 | Arc::clone(&states[5]), |
| 250 | ]; |
| 251 | let states_s1 = [ |
| 252 | Arc::clone(&states[0]), |
| 253 | Arc::clone(&states[1]), |
| 254 | Arc::clone(&states[2]), |
| 255 | ]; |
| 256 | let states_s2 = [ |
| 257 | Arc::clone(&states[0]), |
| 258 | Arc::clone(&states[3]), |
| 259 | Arc::clone(&states[4]), |
| 260 | ]; |
| 261 | |
| 262 | self.covar.merge_batch(&states_c)?; |
| 263 | self.stddev1.merge_batch(&states_s1)?; |
| 264 | self.stddev2.merge_batch(&states_s2)?; |
| 265 | Ok(()) |
| 266 | } |
| 267 | |
| 268 | fn retract_batch(&mut self, values: &[ArrayRef]) -> Result<()> { |
| 269 | let values = if values[0].null_count() != 0 || values[1].null_count() != 0 { |
nothing calls this directly
no test coverage detected