ExportBuilder

Struct ExportBuilder 

Source
pub struct ExportBuilder<'a> { /* private fields */ }
Available on crate feature etl only.
Expand description

A builder for an ETL EXPORT job.

This builder allows configuring various options for the EXPORT job, such as the source, number of readers, and CSV formatting options.

Once configured, the ExportBuilder::build method will create the EXPORT query and return a tuple containing the EtlQuery future and a Vec<ExaReader> of workers. The future must be awaited to drive the job to completion, while the workers are used to read the exported data.

Implementations§

Source§

impl<'a> ExportBuilder<'a>

Source

pub fn new_from_query(query: &'a str) -> ExportBuilder<'a>

Source

pub fn new_from_table( name: &'a str, schema: Option<&'a str>, ) -> ExportBuilder<'a>

Source

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

Builds the EXPORT job.

The output will be a future to await the result of the EXPORT 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.

Source

pub fn num_readers(&mut self, num_readers: usize) -> &mut ExportBuilder<'a>

Sets the number of reader 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.

Source

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

Available on crate feature compression only.
Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

pub fn with_column_names(&mut self, flag: bool) -> &mut ExportBuilder<'a>

Trait Implementations§

Source§

impl<'a> Debug for ExportBuilder<'a>

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a> Freeze for ExportBuilder<'a>

§

impl<'a> RefUnwindSafe for ExportBuilder<'a>

§

impl<'a> Send for ExportBuilder<'a>

§

impl<'a> Sync for ExportBuilder<'a>

§

impl<'a> Unpin for ExportBuilder<'a>

§

impl<'a> UnwindSafe for ExportBuilder<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more