Struct ClickHouseConnectionPool 

pub struct ClickHouseConnectionPool { /* private fields */ }

A wrapper around a clickhouse_arrow::ConnectionPool<ArrowFormat>

Implementations

impl ClickHouseConnectionPool

pub fn new(identifier: impl Into<String>, pool: ArrowPool) -> Self

Create a new ClickHouse connection pool for use in DataFusion. The identifier is used in the case of federation to determine if queries can be pushed down across two pools

pub fn with_write_concurrency(self, concurrency: usize) -> Self

Set the write concurrency level for INSERT operations.

This controls how many record batches can be written to ClickHouse concurrently. Higher values may improve throughput but increase memory and connection usage.

Default: 4 (matching clickhouse-arrow’s current connection pool limit)

pub fn write_concurrency(&self) -> usize

Get the configured write concurrency level

pub async fn from_pool_builder( builder: ArrowConnectionPoolBuilder, ) -> Result<Self>

Create a new ClickHouse connection pool from a builder.

Errors

• Returns an error if the connection pool cannot be created.

pub fn pool(&self) -> &ArrowPool

Access the underlying connection pool

pub fn join_push_down(&self) -> JoinPushDown

impl ClickHouseConnectionPool

pub async fn connect(&self) -> Result<ClickHouseConnection<'_>>

Get a managed ArrowPoolConnection wrapped in a ClickHouseConnection

Errors

• Returns an error if the connection cannot be established.

pub async fn connect_static(&self) -> Result<ClickHouseConnection<'static>>

Get a managed static ArrowPoolConnection wrapped in a ClickHouseConnection

Errors

• Returns an error if the connection cannot be established.

Trait Implementations

impl Clone for ClickHouseConnectionPool

fn clone(&self) -> ClickHouseConnectionPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClickHouseConnectionPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.