Struct ClickHouseTableProviderFactory 

pub struct ClickHouseTableProviderFactory { /* private fields */ }

A DataFusion TableProviderFactory for creating ClickHouse tables.

Implementations

impl ClickHouseTableProviderFactory

pub fn new() -> Self

pub fn with_coercion(self, coerce: bool) -> Self

Set whether ClickHouseTableProviders should attempt to coerce RecordBatch schemas to the schema of the LogicalPlan being executed.

pub fn coerce_schemas(&self) -> bool

impl ClickHouseTableProviderFactory

pub async fn new_with_builder( endpoint: impl Into<Destination>, builder: ArrowConnectionPoolBuilder, ) -> Result<Self>

Errors

• Returns an error if creating the ClickHouseConnectionPool fails.

pub async fn attach_pool_builder( &self, endpoint: impl Into<Destination>, builder: ArrowConnectionPoolBuilder, ) -> Result<ClickHouseConnectionPool>

Attach an existing ClickHouseConnectionPool to the factory by providing ArrowConnectionPoolBuilder which will be built into a ClickHouseConnectionPool

Errors

• Returns an error if creating the ClickHouseConnectionPool fails.

Trait Implementations

impl Clone for ClickHouseTableProviderFactory

fn clone(&self) -> ClickHouseTableProviderFactory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClickHouseTableProviderFactory

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

Formats the value using the given formatter.

impl Default for ClickHouseTableProviderFactory

fn default() -> Self

Returns the “default value” for a type.

impl TableProviderFactory for ClickHouseTableProviderFactory

fn create<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _state: &'life1 dyn Session, cmd: &'life2 CreateExternalTable, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn TableProvider>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Create a TableProvider with the given url