Struct ClickHouseSource 

pub struct ClickHouseSource { /* private fields */ }

A handle to a ClickHouse server queried over HTTP.

let ch = ClickHouseSource::new("http://localhost:8123")
    .database("analytics")
    .credentials("default", "");
let batches = ch.query_arrow("SELECT count() FROM events", &[]).await?;

Implementations

impl ClickHouseSource

pub fn new(url: impl Into<String>) -> Self

Point at a ClickHouse HTTP endpoint, e.g. http://localhost:8123.

pub fn database(self, database: impl Into<String>) -> Self

Set the default database for queries.

pub fn credentials( self, user: impl Into<String>, password: impl Into<String>, ) -> Self

Set HTTP basic-auth credentials.

Trait Implementations

impl RemoteSink for ClickHouseSource

fn write_arrow<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, batches: Vec<RecordBatch>, ) -> Pin<Box<dyn Future<Output = Result<(), DbkitError>> + Send + 'async_trait>>

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

Append Arrow batches to table in the remote store. The table is expected to already exist with a compatible schema. Empty input is a no-op.

impl RemoteSource for ClickHouseSource

fn query_arrow<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [DbValue], ) -> Pin<Box<dyn Future<Output = Result<Vec<RecordBatch>, DbkitError>> + Send + 'async_trait>>

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

Run an analytical query against the remote store, returning Arrow batches.