diff --git a/timely/src/dataflow/stream.rs b/timely/src/dataflow/stream.rs index b4f634f4d..7959c842a 100644 --- a/timely/src/dataflow/stream.rs +++ b/timely/src/dataflow/stream.rs @@ -60,6 +60,7 @@ impl StreamCore { scope_addr: self.scope.addr().to_vec(), source: (self.name.node, self.name.port), target: (target.node, target.port), + typ: std::any::type_name::().to_string(), })); self.scope.add_edge(self.name, target); diff --git a/timely/src/logging.rs b/timely/src/logging.rs index 5669a3759..80777dc98 100644 --- a/timely/src/logging.rs +++ b/timely/src/logging.rs @@ -91,6 +91,8 @@ pub struct ChannelsEvent { pub source: (usize, usize), /// Target descriptor, indicating operator index and input port. pub target: (usize, usize), + /// The type of data on the channel, as a string. + pub typ: String, } #[derive(Debug, Clone)]