pub fn advance_source_handles(&mut self) {
        let frontier: Vec<_> = self.frontier.frontier().to_owned().elements().to_vec();
        for handle in self.source_handles.iter_mut() {
            handle.maybe_advance(frontier.iter().cloned());
        }
    }
/// Allow all sources that the sink transitively depends on to advance their compaction/since
/// frontiers up to the sink's write frontier, if they so choose.
///
/// This function needs to be called periodically, otherwise sink's source dependencies will
/// never compact their timestamp bindings in memory or in the catalog. However, this doesn't
/// have to happen in lockstep with write frontier updates.
Allow all sources that the sink transitively depends on to advance their compaction/since
frontiers up to the sink's write frontier, if they so choose.

This function needs to be called periodically, otherwise sink's source dependencies will
never compact their timestamp bindings in memory or in the catalog. However, this doesn't
have to happen in lockstep with write frontier updates.
Allow all sources that the sink transitively depends on to advance their compaction / since frontiers up to the sink ' s write frontier if they so choose . This function needs to be called periodically otherwise sink ' s source dependencies will never compact their timestamp bindings in memory or in the catalog . However this doesn ' t have to happen in lockstep with write frontier updates .
pub fn advance_source_handles(&mut self) {
        let frontier: Vec<_> = self.frontier.frontier().to_owned().elements().to_vec();
        for handle in self.source_handles.iter_mut() {
            handle.maybe_advance(frontier.iter().cloned());
        }
    }
pub fn advance_source_handles ( & mut self ) { let frontier : Vec < _ > = self . frontier . frontier ( ) . to_owned ( ) . elements ( ) . to_vec ( ) ; for handle in self . source_handles . iter_mut ( ) { handle . maybe_advance ( frontier . iter ( ) . cloned ( ) ) ; } }
Allow all sources that the sink transitively depends on to advance their compaction/since
frontiers up to the sink's write frontier, if they so choose.
Allow all sources that the sink transitively depends on to advance their compaction / since frontiers up to the sink ' s write frontier if they so choose .
&mut self
&mut self