pub fn new_with_flight_client(
        ingester_addresses: Vec<String>,
        flight_client: Arc<dyn FlightClient>,
        catalog_cache: Arc<CatalogCache>,
    ) -> Self {
        let ingester_addresses = ingester_addresses
            .into_iter()
            .map(|addr| Arc::from(addr.as_str()))
            .collect();

        Self {
            ingester_addresses,
            flight_client,
            catalog_cache,
        }
    }
/// Create new ingester connection with specific flight client implementation.
///
/// This is helpful for testing, i.e. when the flight client should not be backed by normal network communication.
Create new ingester connection with specific flight client implementation.
This is helpful for testing, i.e. when the flight client should not be backed by normal network communication.
Create new ingester connection with specific flight client implementation . This is helpful for testing i . e . when the flight client should not be backed by normal network communication .
pub fn new_with_flight_client(
        ingester_addresses: Vec<String>,
        flight_client: Arc<dyn FlightClient>,
        catalog_cache: Arc<CatalogCache>,
    ) -> Self {
        let ingester_addresses = ingester_addresses
            .into_iter()
            .map(|addr| Arc::from(addr.as_str()))
            .collect();
        Self {
            ingester_addresses,
            flight_client,
            catalog_cache,
        }
    }
pub fn new_with_flight_client ( ingester_addresses : Vec < String > , flight_client : Arc < dyn FlightClient > , catalog_cache : Arc < CatalogCache > , ) -> Self { let ingester_addresses = ingester_addresses . into_iter ( ) . map ( | addr | Arc :: from ( addr . as_str ( ) ) ) . collect ( ) ; Self { ingester_addresses , flight_client , catalog_cache , } }
Create new ingester connection with specific flight client implementation.
Create new ingester connection with specific flight client implementation .
ingester_addresses
Vec<String>
flight_client
Arc<dyn FlightClient>
catalog_cache
Arc<CatalogCache>
ingester_addresses
Vec<String>
flight_client
Arc<dyn FlightClient>
catalog_cache
Arc<CatalogCache>