pub fn spawn_introspection_sink(
rx: UnboundedReceiver<(IntrospectionType, Vec<(Row, Diff)>)>,
storage_controller: &dyn StorageController,
)Expand description
Spawn a task sinking introspection updates produced by the compute controller to storage.