Struct ImportBuilder 

pub struct ImportBuilder<'a> { /* private fields */ }

Available on crate feature etl only.

A builder for an ETL IMPORT job.

This builder allows configuring various options for the IMPORT job, such as the destination table, number of writers, and CSV formatting options.

Once configured, the ImportBuilder::build method will create the IMPORT query and return a tuple containing the EtlQuery future and a Vec<ExaWriter> of workers. The future must be awaited to drive the job to completion, while the workers are used to write the data to be imported.

Implementations

impl<'a> ImportBuilder<'a>

pub fn new( dest_table: &'a str, dest_schema: Option<&'a str>, ) -> ImportBuilder<'a>

pub async fn build<'c>( &'a self, con: &'c mut ExaConnection, ) -> Result<(EtlQuery<'c>, Vec<ExaImport>), Error>

where 'c: 'a,

Builds the IMPORT job.

The output will be a future to await the result of the IMPORT query and the workers that can be used for ETL IO.

Errors

Returns an error if getting the nodes IPs from Exasol fails or if the worker sockets could not be connected.

pub fn num_writers(&mut self, num_writers: usize) -> &mut ImportBuilder<'a>

Sets the number of writer jobs that will be started.

If set to 0, then as many as possible will be used (one per node). Providing a number bigger than the number of nodes is the same as providing 0.

pub fn buffer_size(&mut self, buffer_size: usize) -> &mut ImportBuilder<'a>

pub fn compression(&mut self, enabled: bool) -> &mut ImportBuilder<'a>

Available on crate feature compression only.

pub fn columns( &mut self, columns: Option<&'a [&'a str]>, ) -> &mut ImportBuilder<'a>

pub fn comment(&mut self, comment: &'a str) -> &mut ImportBuilder<'a>

pub fn encoding(&mut self, encoding: &'a str) -> &mut ImportBuilder<'a>

pub fn null(&mut self, null: &'a str) -> &mut ImportBuilder<'a>

pub fn row_separator( &mut self, separator: RowSeparator, ) -> &mut ImportBuilder<'a>

pub fn column_separator(&mut self, separator: &'a str) -> &mut ImportBuilder<'a>

pub fn column_delimiter(&mut self, delimiter: &'a str) -> &mut ImportBuilder<'a>

pub fn skip(&mut self, num: u64) -> &mut ImportBuilder<'a>

pub fn trim(&mut self, trim: Trim) -> &mut ImportBuilder<'a>

Trait Implementations

impl<'a> Clone for ImportBuilder<'a>

fn clone(&self) -> ImportBuilder<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for ImportBuilder<'a>

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

Formats the value using the given formatter.