(self, dtype)
| 268 | param_names = ["dtype"] |
| 269 | |
| 270 | def setup(self, dtype): |
| 271 | rows = 10000 |
| 272 | cols = 50 |
| 273 | if dtype == "float": |
| 274 | df = DataFrame(np.random.randn(rows, cols)) |
| 275 | elif dtype == "datetime": |
| 276 | df = DataFrame( |
| 277 | np.random.randn(rows, cols), index=date_range("1/1/2000", periods=rows) |
| 278 | ) |
| 279 | elif dtype == "object": |
| 280 | df = DataFrame( |
| 281 | "foo", index=range(rows), columns=["object%03d" for _ in range(5)] |
| 282 | ) |
| 283 | else: |
| 284 | raise NotImplementedError |
| 285 | |
| 286 | self.fname = f"__test_{dtype}__.csv" |
| 287 | df.to_csv(self.fname) |
| 288 | |
| 289 | @run_parallel(num_threads=2) |
| 290 | def parallel_read_csv(): |
| 291 | read_csv(self.fname) |
| 292 | |
| 293 | self.parallel_read_csv = parallel_read_csv |
| 294 | |
| 295 | def time_read_csv(self, dtype): |
| 296 | self.parallel_read_csv() |
nothing calls this directly
no test coverage detected