diff --git a/wal_inspect/src/lib.rs b/wal_inspect/src/lib.rs index 9ceae88483..fda7527c47 100644 --- a/wal_inspect/src/lib.rs +++ b/wal_inspect/src/lib.rs @@ -133,13 +133,17 @@ where .entry(ns) .or_insert((self.new_write_sink)(ns)?); - write_batches_as_line_proto(sink, &self.table_name_index, table_batches.into_iter()) + write_batches_as_line_proto( + sink, + self.table_name_index.as_ref(), + table_batches.into_iter(), + ) } } fn write_batches_as_line_proto( sink: &mut W, - table_name_index: &Option>, + table_name_index: Option<&HashMap>, table_batches: B, ) -> Result<(), WriteError> where @@ -386,7 +390,7 @@ m2,t=bar v="arĂ¡n" 1"#, .map(|(i, (_table_name, batch))| (i as i64, batch)), ); - write_batches_as_line_proto(&mut sink, &None, batches.into_iter()) + write_batches_as_line_proto(&mut sink, None, batches.into_iter()) .expect("write back to line proto should succeed"); assert_eq!(