async fn persist(&mut self, partition_ids: &[PartitionId]) {
        for partition_id in partition_ids {
            self.ingester_data.persist(*partition_id).await;
        }
    }
/// Persists the given set of partitions.
Persists the given set of partitions.
Persists the given set of partitions .
async fn persist(&mut self, partition_ids: &[PartitionId]) {
        for partition_id in partition_ids {
            self.ingester_data.persist(*partition_id).await;
        }
    }
async fn persist ( & mut self , partition_ids : & [ PartitionId ] ) { for partition_id in partition_ids { self . ingester_data . persist ( * partition_id ) . await ; } }
Persists the given set of partitions.
Persists the given set of partitions .
&mut self
partition_ids
&[PartitionId]
&mut self
partition_ids
&[PartitionId]