fn validate_caches(&self, partitions: &[IngesterPartition]) {
        // figure out if the ingester has created new parquet files or
        // tombstones the querier doens't yet know about
        let catalog_cache = self.chunk_adapter.catalog_cache();

        let max_parquet_sequence_number = partitions
            .iter()
            .flat_map(|p| p.parquet_max_sequence_number())
            .max();

        let parquet_cache_outdated = catalog_cache
            .parquet_file()
            .expire_on_newly_persisted_files(self.id, max_parquet_sequence_number);

        let max_tombstone_sequence_number = partitions
            .iter()
            .flat_map(|p| p.tombstone_max_sequence_number())
            .max();

        let tombstone_cache_outdated = catalog_cache
            .tombstone()
            .expire_on_newly_persisted_files(self.id, max_tombstone_sequence_number);

        debug!(
            namespace=%self.namespace_name,
            table_name=%self.table_name(),
            parquet_cache_outdated,
            tombstone_cache_outdated,
            ?max_parquet_sequence_number,
            ?max_tombstone_sequence_number,
            "Ingester partitions fetched"
        );
    }
/// Handles invalidating parquet and tombstone caches if the
/// responses from the ingesters refer to newer parquet data or
/// tombstone data than is in the cache.
Handles invalidating parquet and tombstone caches if the
responses from the ingesters refer to newer parquet data or
tombstone data than is in the cache.
Handles invalidating parquet and tombstone caches if the responses from the ingesters refer to newer parquet data or tombstone data than is in the cache .
fn validate_caches(&self, partitions: &[IngesterPartition]) {
        // figure out if the ingester has created new parquet files or
        // tombstones the querier doens't yet know about
        let catalog_cache = self.chunk_adapter.catalog_cache();
        let max_parquet_sequence_number = partitions
            .iter()
            .flat_map(|p| p.parquet_max_sequence_number())
            .max();
        let parquet_cache_outdated = catalog_cache
            .parquet_file()
            .expire_on_newly_persisted_files(self.id, max_parquet_sequence_number);
        let max_tombstone_sequence_number = partitions
            .iter()
            .flat_map(|p| p.tombstone_max_sequence_number())
            .max();
        let tombstone_cache_outdated = catalog_cache
            .tombstone()
            .expire_on_newly_persisted_files(self.id, max_tombstone_sequence_number);
        debug!(
            namespace=%self.namespace_name,
            table_name=%self.table_name(),
            parquet_cache_outdated,
            tombstone_cache_outdated,
            ?max_parquet_sequence_number,
            ?max_tombstone_sequence_number,
            "Ingester partitions fetched"
        );
    }
fn validate_caches ( & self , partitions : & [ IngesterPartition ] ) { // figure out if the ingester has created new parquet files or // tombstones the querier doens't yet know about let catalog_cache = self . chunk_adapter . catalog_cache ( ) ; let max_parquet_sequence_number = partitions . iter ( ) . flat_map ( | p | p . parquet_max_sequence_number ( ) ) . max ( ) ; let parquet_cache_outdated = catalog_cache . parquet_file ( ) . expire_on_newly_persisted_files ( self . id , max_parquet_sequence_number ) ; let max_tombstone_sequence_number = partitions . iter ( ) . flat_map ( | p | p . tombstone_max_sequence_number ( ) ) . max ( ) ; let tombstone_cache_outdated = catalog_cache . tombstone ( ) . expire_on_newly_persisted_files ( self . id , max_tombstone_sequence_number ) ; debug ! ( namespace self namespace_name table_name self table_name ( ) parquet_cache_outdated tombstone_cache_outdated max_parquet_sequence_number max_tombstone_sequence_number " " ) ; }
Handles invalidating parquet and tombstone caches if the
responses from the ingesters refer to newer parquet data or
tombstone data than is in the cache.
Handles invalidating parquet and tombstone caches if the responses from the ingesters refer to newer parquet data or tombstone data than is in the cache .
&self
partitions
&[IngesterPartition]
&self
partitions
&[IngesterPartition]