Struct ImportBuilder

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

A builder for an ETL IMPORT job.

Calling [build().await] will ouput a future that drives the IMPORT query execution and a Vec<ExaWriter> which must be concurrently used to ingest data into Exasol.

Implementations

impl<'a> ImportBuilder<'a>

pub fn new(dest_table: &'a str) -> Self

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

where 'c: 'a,

Builds the IMPORT job.

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

Errors

Returns an error if the job could not be built and submitted.

pub fn num_writers(&mut self, num_writers: usize) -> &mut Self

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 Self

pub fn compression(&mut self, enabled: bool) -> &mut Self

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

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

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

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

pub fn row_separator(&mut self, separator: RowSeparator) -> &mut Self

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

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

pub fn skip(&mut self, num: u64) -> &mut Self

pub fn trim(&mut self, trim: Trim) -> &mut Self

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

Formats the value using the given formatter.