#[non_exhaustive]
pub struct SnowflakeNodeDataBuilder { /* private fields */ }
Expand description

A builder for SnowflakeNodeData.

Implementations§

source§

impl SnowflakeNodeDataBuilder

source

pub fn source_type(self, input: impl Into<String>) -> Self

Specifies how retrieved data is specified. Valid values: "table", "query".

source

pub fn set_source_type(self, input: Option<String>) -> Self

Specifies how retrieved data is specified. Valid values: "table", "query".

source

pub fn get_source_type(&self) -> &Option<String>

Specifies how retrieved data is specified. Valid values: "table", "query".

source

pub fn connection(self, input: Option) -> Self

Specifies a Glue Data Catalog Connection to a Snowflake endpoint.

source

pub fn set_connection(self, input: Option<Option>) -> Self

Specifies a Glue Data Catalog Connection to a Snowflake endpoint.

source

pub fn get_connection(&self) -> &Option<Option>

Specifies a Glue Data Catalog Connection to a Snowflake endpoint.

source

pub fn schema(self, input: impl Into<String>) -> Self

Specifies a Snowflake database schema for your node to use.

source

pub fn set_schema(self, input: Option<String>) -> Self

Specifies a Snowflake database schema for your node to use.

source

pub fn get_schema(&self) -> &Option<String>

Specifies a Snowflake database schema for your node to use.

source

pub fn table(self, input: impl Into<String>) -> Self

Specifies a Snowflake table for your node to use.

source

pub fn set_table(self, input: Option<String>) -> Self

Specifies a Snowflake table for your node to use.

source

pub fn get_table(&self) -> &Option<String>

Specifies a Snowflake table for your node to use.

source

pub fn database(self, input: impl Into<String>) -> Self

Specifies a Snowflake database for your node to use.

source

pub fn set_database(self, input: Option<String>) -> Self

Specifies a Snowflake database for your node to use.

source

pub fn get_database(&self) -> &Option<String>

Specifies a Snowflake database for your node to use.

source

pub fn temp_dir(self, input: impl Into<String>) -> Self

Not currently used.

source

pub fn set_temp_dir(self, input: Option<String>) -> Self

Not currently used.

source

pub fn get_temp_dir(&self) -> &Option<String>

Not currently used.

source

pub fn iam_role(self, input: Option) -> Self

Not currently used.

source

pub fn set_iam_role(self, input: Option<Option>) -> Self

Not currently used.

source

pub fn get_iam_role(&self) -> &Option<Option>

Not currently used.

source

pub fn additional_options( self, k: impl Into<String>, v: impl Into<String>, ) -> Self

Adds a key-value pair to additional_options.

To override the contents of this collection use set_additional_options.

Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.

source

pub fn set_additional_options( self, input: Option<HashMap<String, String>>, ) -> Self

Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.

source

pub fn get_additional_options(&self) -> &Option<HashMap<String, String>>

Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.

source

pub fn sample_query(self, input: impl Into<String>) -> Self

A SQL string used to retrieve data with the query sourcetype.

source

pub fn set_sample_query(self, input: Option<String>) -> Self

A SQL string used to retrieve data with the query sourcetype.

source

pub fn get_sample_query(&self) -> &Option<String>

A SQL string used to retrieve data with the query sourcetype.

source

pub fn pre_action(self, input: impl Into<String>) -> Self

A SQL string run before the Snowflake connector performs its standard actions.

source

pub fn set_pre_action(self, input: Option<String>) -> Self

A SQL string run before the Snowflake connector performs its standard actions.

source

pub fn get_pre_action(&self) -> &Option<String>

A SQL string run before the Snowflake connector performs its standard actions.

source

pub fn post_action(self, input: impl Into<String>) -> Self

A SQL string run after the Snowflake connector performs its standard actions.

source

pub fn set_post_action(self, input: Option<String>) -> Self

A SQL string run after the Snowflake connector performs its standard actions.

source

pub fn get_post_action(&self) -> &Option<String>

A SQL string run after the Snowflake connector performs its standard actions.

source

pub fn action(self, input: impl Into<String>) -> Self

Specifies what action to take when writing to a table with preexisting data. Valid values: append, merge, truncate, drop.

source

pub fn set_action(self, input: Option<String>) -> Self

Specifies what action to take when writing to a table with preexisting data. Valid values: append, merge, truncate, drop.

source

pub fn get_action(&self) -> &Option<String>

Specifies what action to take when writing to a table with preexisting data. Valid values: append, merge, truncate, drop.

source

pub fn upsert(self, input: bool) -> Self

Used when Action is append. Specifies the resolution behavior when a row already exists. If true, preexisting rows will be updated. If false, those rows will be inserted.

source

pub fn set_upsert(self, input: Option<bool>) -> Self

Used when Action is append. Specifies the resolution behavior when a row already exists. If true, preexisting rows will be updated. If false, those rows will be inserted.

source

pub fn get_upsert(&self) -> &Option<bool>

Used when Action is append. Specifies the resolution behavior when a row already exists. If true, preexisting rows will be updated. If false, those rows will be inserted.

source

pub fn merge_action(self, input: impl Into<String>) -> Self

Specifies a merge action. Valid values: simple, custom. If simple, merge behavior is defined by MergeWhenMatched and MergeWhenNotMatched. If custom, defined by MergeClause.

source

pub fn set_merge_action(self, input: Option<String>) -> Self

Specifies a merge action. Valid values: simple, custom. If simple, merge behavior is defined by MergeWhenMatched and MergeWhenNotMatched. If custom, defined by MergeClause.

source

pub fn get_merge_action(&self) -> &Option<String>

Specifies a merge action. Valid values: simple, custom. If simple, merge behavior is defined by MergeWhenMatched and MergeWhenNotMatched. If custom, defined by MergeClause.

source

pub fn merge_when_matched(self, input: impl Into<String>) -> Self

Specifies how to resolve records that match preexisting data when merging. Valid values: update, delete.

source

pub fn set_merge_when_matched(self, input: Option<String>) -> Self

Specifies how to resolve records that match preexisting data when merging. Valid values: update, delete.

source

pub fn get_merge_when_matched(&self) -> &Option<String>

Specifies how to resolve records that match preexisting data when merging. Valid values: update, delete.

source

pub fn merge_when_not_matched(self, input: impl Into<String>) -> Self

Specifies how to process records that do not match preexisting data when merging. Valid values: insert, none.

source

pub fn set_merge_when_not_matched(self, input: Option<String>) -> Self

Specifies how to process records that do not match preexisting data when merging. Valid values: insert, none.

source

pub fn get_merge_when_not_matched(&self) -> &Option<String>

Specifies how to process records that do not match preexisting data when merging. Valid values: insert, none.

source

pub fn merge_clause(self, input: impl Into<String>) -> Self

A SQL statement that specifies a custom merge behavior.

source

pub fn set_merge_clause(self, input: Option<String>) -> Self

A SQL statement that specifies a custom merge behavior.

source

pub fn get_merge_clause(&self) -> &Option<String>

A SQL statement that specifies a custom merge behavior.

source

pub fn staging_table(self, input: impl Into<String>) -> Self

The name of a staging table used when performing merge or upsert append actions. Data is written to this table, then moved to table by a generated postaction.

source

pub fn set_staging_table(self, input: Option<String>) -> Self

The name of a staging table used when performing merge or upsert append actions. Data is written to this table, then moved to table by a generated postaction.

source

pub fn get_staging_table(&self) -> &Option<String>

The name of a staging table used when performing merge or upsert append actions. Data is written to this table, then moved to table by a generated postaction.

source

pub fn selected_columns(self, input: Option) -> Self

Appends an item to selected_columns.

To override the contents of this collection use set_selected_columns.

Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of structures with value, label and description keys. Each structure describes a column.

source

pub fn set_selected_columns(self, input: Option<Vec<Option>>) -> Self

Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of structures with value, label and description keys. Each structure describes a column.

source

pub fn get_selected_columns(&self) -> &Option<Vec<Option>>

Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of structures with value, label and description keys. Each structure describes a column.

source

pub fn auto_pushdown(self, input: bool) -> Self

Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.

source

pub fn set_auto_pushdown(self, input: Option<bool>) -> Self

Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.

source

pub fn get_auto_pushdown(&self) -> &Option<bool>

Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.

source

pub fn table_schema(self, input: Option) -> Self

Appends an item to table_schema.

To override the contents of this collection use set_table_schema.

Manually defines the target schema for the node. A list of structures with value , label and description keys. Each structure defines a column.

source

pub fn set_table_schema(self, input: Option<Vec<Option>>) -> Self

Manually defines the target schema for the node. A list of structures with value , label and description keys. Each structure defines a column.

source

pub fn get_table_schema(&self) -> &Option<Vec<Option>>

Manually defines the target schema for the node. A list of structures with value , label and description keys. Each structure defines a column.

source

pub fn build(self) -> SnowflakeNodeData

Consumes the builder and constructs a SnowflakeNodeData.

Trait Implementations§

source§

impl Clone for SnowflakeNodeDataBuilder

source§

fn clone(&self) -> SnowflakeNodeDataBuilder

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 SnowflakeNodeDataBuilder

source§

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

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

impl Default for SnowflakeNodeDataBuilder

source§

fn default() -> SnowflakeNodeDataBuilder

Returns the “default value” for a type. Read more
source§

impl PartialEq for SnowflakeNodeDataBuilder

source§

fn eq(&self, other: &SnowflakeNodeDataBuilder) -> 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 SnowflakeNodeDataBuilder

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