/// Finalizes the ingester and creates a querier namespace that can be used for query tests.
///
/// The querier namespace will hold a simulated connection to the ingester to be able to query
/// unpersisted data.
Finalizes the ingester and creates a querier namespace that can be used for query tests.
The querier namespace will hold a simulated connection to the ingester to be able to query
unpersisted data.
Finalizes the ingester and creates a querier namespace that can be used for query tests . The querier namespace will hold a simulated connection to the ingester to be able to query unpersisted data .
async fn into_query_namespace(self) -> Arc<QuerierNamespace> {
        let mut repos = self.catalog.catalog.repositories().await;
        let schema = Arc::new(
            get_schema_by_name(&self.ns.namespace.name, repos.as_mut())
                .await
                .unwrap(),
        );
        let catalog = Arc::clone(&self.catalog);
        let ns = Arc::clone(&self.ns);
        let catalog_cache = Arc::new(QuerierCatalogCache::new(
            self.catalog.catalog(),
            self.catalog.time_provider(),
            self.catalog.metric_registry(),
            usize::MAX,
        ));
        let ingester_connection = IngesterConnectionImpl::new_with_flight_client(
            vec![String::from("some_address")],
            Arc::new(self),
            Arc::clone(&catalog_cache),
        );
        let ingester_connection = Arc::new(ingester_connection);
        Arc::new(QuerierNamespace::new_testing(
            catalog_cache,
            ParquetStorage::new(catalog.object_store()),
            catalog.metric_registry(),
            ns.namespace.name.clone().into(),
            schema,
            catalog.exec(),
            ingester_connection,
        ))
    }
async fn into_query_namespace ( self ) -> Arc < QuerierNamespace > { let mut repos = self . catalog . catalog . repositories ( ) . await ; let schema = Arc :: new ( get_schema_by_name ( & self . ns . namespace . name , repos . as_mut ( ) ) . await . unwrap ( ) , ) ; let catalog = Arc :: clone ( & self . catalog ) ; let ns = Arc :: clone ( & self . ns ) ; let catalog_cache = Arc :: new ( QuerierCatalogCache :: new ( self . catalog . catalog ( ) , self . catalog . time_provider ( ) , self . catalog . metric_registry ( ) , usize :: MAX , ) ) ; let ingester_connection = IngesterConnectionImpl :: new_with_flight_client ( vec ! [ String from ( " " ) ] , Arc :: new ( self ) , Arc :: clone ( & catalog_cache ) , ) ; let ingester_connection = Arc :: new ( ingester_connection ) ; Arc :: new ( QuerierNamespace :: new_testing ( catalog_cache , ParquetStorage :: new ( catalog . object_store ( ) ) , catalog . metric_registry ( ) , ns . namespace . name . clone ( ) . into ( ) , schema , catalog . exec ( ) , ingester_connection , ) ) }
Finalizes the ingester and creates a querier namespace that can be used for query tests.
Finalizes the ingester and creates a querier namespace that can be used for query tests .
self