#[non_exhaustive]
pub struct JdbcConnectorOptions { pub filter_predicate: Option<String>, pub partition_column: Option<String>, pub lower_bound: Option<i64>, pub upper_bound: Option<i64>, pub num_partitions: Option<i64>, pub job_bookmark_keys: Option<Vec<String>>, pub job_bookmark_keys_sort_order: Option<String>, pub data_type_mapping: Option<HashMap<JdbcDataType, GlueRecordType>>, }
Expand description

Additional connection options for the connector.

Fields (Non-exhaustive)§

This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.
§filter_predicate: Option<String>

Extra condition clause to filter data from source. For example:

BillingCity='Mountain View'

When using a query instead of a table name, you should validate that the query works with the specified filterPredicate.

§partition_column: Option<String>

The name of an integer column that is used for partitioning. This option works only when it's included with lowerBound, upperBound, and numPartitions. This option works the same way as in the Spark SQL JDBC reader.

§lower_bound: Option<i64>

The minimum value of partitionColumn that is used to decide partition stride.

§upper_bound: Option<i64>

The maximum value of partitionColumn that is used to decide partition stride.

§num_partitions: Option<i64>

The number of partitions. This value, along with lowerBound (inclusive) and upperBound (exclusive), form partition strides for generated WHERE clause expressions that are used to split the partitionColumn.

§job_bookmark_keys: Option<Vec<String>>

The name of the job bookmark keys on which to sort.

§job_bookmark_keys_sort_order: Option<String>

Specifies an ascending or descending sort order.

§data_type_mapping: Option<HashMap<JdbcDataType, GlueRecordType>>

Custom data type mapping that builds a mapping from a JDBC data type to an Glue data type. For example, the option "dataTypeMapping":{"FLOAT":"STRING"} maps data fields of JDBC type FLOAT into the Java String type by calling the ResultSet.getString() method of the driver, and uses it to build the Glue record. The ResultSet object is implemented by each driver, so the behavior is specific to the driver you use. Refer to the documentation for your JDBC driver to understand how the driver performs the conversions.

Implementations§

source§

impl JdbcConnectorOptions

source

pub fn filter_predicate(&self) -> Option<&str>

Extra condition clause to filter data from source. For example:

BillingCity='Mountain View'

When using a query instead of a table name, you should validate that the query works with the specified filterPredicate.

source

pub fn partition_column(&self) -> Option<&str>

The name of an integer column that is used for partitioning. This option works only when it's included with lowerBound, upperBound, and numPartitions. This option works the same way as in the Spark SQL JDBC reader.

source

pub fn lower_bound(&self) -> Option<i64>

The minimum value of partitionColumn that is used to decide partition stride.

source

pub fn upper_bound(&self) -> Option<i64>

The maximum value of partitionColumn that is used to decide partition stride.

source

pub fn num_partitions(&self) -> Option<i64>

The number of partitions. This value, along with lowerBound (inclusive) and upperBound (exclusive), form partition strides for generated WHERE clause expressions that are used to split the partitionColumn.

source

pub fn job_bookmark_keys(&self) -> &[String]

The name of the job bookmark keys on which to sort.

If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .job_bookmark_keys.is_none().

source

pub fn job_bookmark_keys_sort_order(&self) -> Option<&str>

Specifies an ascending or descending sort order.

source

pub fn data_type_mapping( &self ) -> Option<&HashMap<JdbcDataType, GlueRecordType>>

Custom data type mapping that builds a mapping from a JDBC data type to an Glue data type. For example, the option "dataTypeMapping":{"FLOAT":"STRING"} maps data fields of JDBC type FLOAT into the Java String type by calling the ResultSet.getString() method of the driver, and uses it to build the Glue record. The ResultSet object is implemented by each driver, so the behavior is specific to the driver you use. Refer to the documentation for your JDBC driver to understand how the driver performs the conversions.

source§

impl JdbcConnectorOptions

source

pub fn builder() -> JdbcConnectorOptionsBuilder

Creates a new builder-style object to manufacture JdbcConnectorOptions.

Trait Implementations§

source§

impl Clone for JdbcConnectorOptions

source§

fn clone(&self) -> JdbcConnectorOptions

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for JdbcConnectorOptions

source§

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

Formats the value using the given formatter. Read more
source§

impl PartialEq for JdbcConnectorOptions

source§

fn eq(&self, other: &JdbcConnectorOptions) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl StructuralPartialEq for JdbcConnectorOptions

Auto Trait Implementations§

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<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

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

§

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>,

§

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<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