Commit ea71acf 1 parent d526a2e commit ea71acf Copy full SHA for ea71acf
File tree 2 files changed +4
-0
lines changed
2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -37,6 +37,7 @@ arrow = { workspace = true }
37
37
datafusion = { path = " ../datafusion/core" , version = " 27.0.0" }
38
38
env_logger = " 0.10"
39
39
futures = " 0.3"
40
+ log = " ^0.4"
40
41
mimalloc = { version = " 0.1" , optional = true , default-features = false }
41
42
num_cpus = " 1.13.0"
42
43
parquet = { workspace = true }
Original file line number Diff line number Diff line change 16
16
// under the License.
17
17
18
18
//! Benchmark derived from TPC-H. This is not an official TPC-H benchmark.
19
+ use log:: info;
19
20
21
+ use arrow:: util:: pretty:: pretty_format_batches;
20
22
use datafusion:: datasource:: file_format:: { csv:: CsvFormat , FileFormat } ;
21
23
use datafusion:: datasource:: { MemTable , TableProvider } ;
22
24
use datafusion:: error:: { DataFusionError , Result } ;
@@ -235,6 +237,7 @@ async fn benchmark_query(
235
237
let elapsed = start. elapsed ( ) ; //.as_secs_f64() * 1000.0;
236
238
let ms = elapsed. as_secs_f64 ( ) * 1000.0 ;
237
239
millis. push ( ms) ;
240
+ info ! ( "output:\n \n {}\n \n " , pretty_format_batches( & result) ?) ;
238
241
let row_count = result. iter ( ) . map ( |b| b. num_rows ( ) ) . sum ( ) ;
239
242
println ! (
240
243
"Query {query_id} iteration {i} took {ms:.1} ms and returned {row_count} rows"
You can’t perform that action at this time.
0 commit comments