fn restore(
        &self,
    ) -> Result<
        (
            HashMap<PartitionId, Option<MzOffset>>,
            Vec<(SourceTimestamp, AssignedTimestamp)>,
        ),
        persist::error::Error,
    > {
        let (offsets, bindings) = self.internal_restore(
            self.config.read_handle.clone(),
            self.config.upper_bindings_seal_ts,
            self.config.upper_data_seal_ts,
        )?;

        log::trace!(
            "In {}, initial (restored) source offsets: {:?}",
            self.source_name,
            offsets,
        );

        log::trace!(
            "In {}, initial (restored) timestamp bindings: {:?}",
            self.source_name,
            bindings,
        );

        Ok((offsets, bindings))
    }
/// Restores the known source partitions (along with their latest read offset, if the binding
/// is not beyond the `upper_data_seal_ts`) and the known timestamp bindings.
Restores the known source partitions (along with their latest read offset, if the binding
is not beyond the `upper_data_seal_ts`) and the known timestamp bindings.
Restores the known source partitions ( along with their latest read offset if the binding is not beyond the ` upper_data_seal_ts ` ) and the known timestamp bindings .
fn restore(
        &self,
    ) -> Result<
        (
            HashMap<PartitionId, Option<MzOffset>>,
            Vec<(SourceTimestamp, AssignedTimestamp)>,
        ),
        persist::error::Error,
    > {
        let (offsets, bindings) = self.internal_restore(
            self.config.read_handle.clone(),
            self.config.upper_bindings_seal_ts,
            self.config.upper_data_seal_ts,
        )?;
        log::trace!(
            "In {}, initial (restored) source offsets: {:?}",
            self.source_name,
            offsets,
        );
        log::trace!(
            "In {}, initial (restored) timestamp bindings: {:?}",
            self.source_name,
            bindings,
        );
        Ok((offsets, bindings))
    }
fn restore ( & self , ) -> Result < ( HashMap < PartitionId , Option < MzOffset > > , Vec < ( SourceTimestamp , AssignedTimestamp ) > , ) , persist :: error :: Error , > { let ( offsets , bindings ) = self . internal_restore ( self . config . read_handle . clone ( ) , self . config . upper_bindings_seal_ts , self . config . upper_data_seal_ts , ) ? ; log :: trace ! ( " " self source_name offsets ) ; log :: trace ! ( " " self source_name bindings ) ; Ok ( ( offsets , bindings ) ) }
Restores the known source partitions (along with their latest read offset, if the binding
is not beyond the `upper_data_seal_ts`) and the known timestamp bindings.
Restores the known source partitions ( along with their latest read offset if the binding is not beyond the ` upper_data_seal_ts ` ) and the known timestamp bindings .
&self
&self