(self, collector, benchmark_name)
| 85 | return res |
| 86 | |
| 87 | def load_lineitem(self, collector, benchmark_name) -> BenchmarkResult: |
| 88 | query = 'SELECT * FROM lineitem' |
| 89 | result = BenchmarkResult(benchmark_name) |
| 90 | for _ in range(nruns): |
| 91 | duration = 0.0 |
| 92 | start = time.time() |
| 93 | rel = self.conn.sql(query) |
| 94 | res = collector(rel) |
| 95 | end = time.time() |
| 96 | duration = float(end - start) |
| 97 | del res |
| 98 | padding = " " * len(str(nruns)) |
| 99 | print_msg(f"T{padding}: {duration}s") |
| 100 | result.add(duration) |
| 101 | return result |
| 102 | |
| 103 | |
| 104 | class TPCHBenchmarker: |
no test coverage detected