Struct ClickHouseDataSink 

pub struct ClickHouseDataSink { /* private fields */ }

datafusion::datasource::sink::DataSink for ClickHouse

Implementations

impl ClickHouseDataSink

pub fn new( writer: Arc<ClickHouseConnectionPool>, table: TableReference, schema: SchemaRef, ) -> Self

pub fn verify_input_schema(&self, input: &SchemaRef) -> Result<()>

Verify that a passed in schema aligns with the sink schema

Ordering and metadata don’t matter

Errors

• Returns an error if the field lengths don’t match
• Returns an error if data types don’t match
• Returns an error if names don’t match
• Returns an error if nullability doesn’t match

Trait Implementations

impl DataSink for ClickHouseDataSink

fn as_any(&self) -> &dyn Any

Returns the data sink as Any so that it can be downcast to a specific implementation.

fn schema(&self) -> &SchemaRef

Returns the sink schema

fn write_all<'life0, 'life1, 'async_trait>( &'life0 self, data: SendableRecordBatchStream, _context: &'life1 Arc<TaskContext>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Writes the data to the sink, returns the number of values written

fn metrics(&self) -> Option<MetricsSet>

Return a snapshot of the MetricsSet for this DataSink.

impl Debug for ClickHouseDataSink

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

Formats the value using the given formatter.

impl DisplayAs for ClickHouseDataSink

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

Format according to DisplayFormatType, used when verbose representation looks different from the default one