@@ -3,7 +3,6 @@ use itertools::Itertools;
3
3
4
4
use re_byte_size:: SizeBytes as _;
5
5
use re_log_types:: { LogMsg , SetStoreInfo } ;
6
- use re_sdk:: log:: Chunk ;
7
6
8
7
use crate :: commands:: read_rrd_streams_from_file_or_stdin;
9
8
@@ -81,31 +80,32 @@ fn print_msg(verbose: u8, msg: LogMsg) -> anyhow::Result<()> {
81
80
}
82
81
83
82
LogMsg :: ArrowMsg ( _row_id, arrow_msg) => {
84
- let chunk = Chunk :: from_arrow_msg ( & arrow_msg) . context ( "skipped corrupt chunk" ) ?;
83
+ let chunk =
84
+ re_sorbet:: ChunkBatch :: try_from ( & arrow_msg. batch ) . context ( "corrupt chunk" ) ?;
85
85
86
86
print ! (
87
87
"Chunk({}) with {} rows ({}) - {:?} - " ,
88
- chunk. id ( ) ,
88
+ chunk. chunk_id ( ) ,
89
89
chunk. num_rows( ) ,
90
90
re_format:: format_bytes( chunk. total_size_bytes( ) as _) ,
91
91
chunk. entity_path( ) ,
92
92
) ;
93
93
94
94
if verbose == 0 {
95
95
let column_names = chunk
96
- . component_names ( )
97
- . map ( |name| name . short_name ( ) )
96
+ . component_columns ( )
97
+ . map ( |( descr , _ ) | descr . component_name . short_name ( ) )
98
98
. join ( " " ) ;
99
99
println ! ( "columns: [{column_names}]" ) ;
100
100
} else if verbose == 1 {
101
101
let column_descriptors = chunk
102
- . component_descriptors ( )
103
- . map ( |descr| descr. short_name ( ) )
102
+ . component_columns ( )
103
+ . map ( |( descr, _ ) | descr. to_string ( ) )
104
104
. collect_vec ( )
105
105
. join ( " " ) ;
106
106
println ! ( "columns: [{column_descriptors}]" , ) ;
107
107
} else if verbose == 2 {
108
- println ! ( "\n {}" , chunk. emptied ( ) ) ; // headers only
108
+ println ! ( "\n {}" , chunk. drop_all_rows ( ) ) ; // headers only
109
109
} else {
110
110
println ! ( "\n {chunk}" ) ;
111
111
}
0 commit comments