| 187 | } |
| 188 | |
| 189 | fn finish(mut self, schema: SchemaRef) -> RecordBatch { |
| 190 | RecordBatch::try_new( |
| 191 | schema, |
| 192 | vec![ |
| 193 | Arc::new(self.service.finish()), |
| 194 | Arc::new(self.host.finish()), |
| 195 | Arc::new(self.pod.finish()), |
| 196 | Arc::new(self.container.finish()), |
| 197 | Arc::new(self.image.finish()), |
| 198 | Arc::new(self.time.finish()), |
| 199 | Arc::new(self.client_addr.finish()), |
| 200 | Arc::new(self.request_duration.finish()), |
| 201 | Arc::new(self.request_user_agent.finish()), |
| 202 | Arc::new(self.request_method.finish()), |
| 203 | Arc::new(self.request_host.finish()), |
| 204 | Arc::new(self.request_bytes.finish()), |
| 205 | Arc::new(self.response_bytes.finish()), |
| 206 | Arc::new(self.response_status.finish()), |
| 207 | Arc::new( |
| 208 | self.prices_status |
| 209 | .finish() |
| 210 | .with_precision_and_scale(38, 0) |
| 211 | .unwrap(), |
| 212 | ), |
| 213 | ], |
| 214 | ) |
| 215 | .unwrap() |
| 216 | } |
| 217 | } |
| 218 | |
| 219 | fn random_string(rng: &mut StdRng, len_range: Range<usize>) -> String { |