#[non_exhaustive]
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
pub struct CodeGenConfigurationNode {
pub athena_connector_source: ::std::option::Option<crate::types::AthenaConnectorSource>,
pub jdbc_connector_source: ::std::option::Option<crate::types::JdbcConnectorSource>,
pub spark_connector_source: ::std::option::Option<crate::types::SparkConnectorSource>,
pub catalog_source: ::std::option::Option<crate::types::CatalogSource>,
pub redshift_source: ::std::option::Option<crate::types::RedshiftSource>,
pub s3_catalog_source: ::std::option::Option<crate::types::S3CatalogSource>,
pub s3_csv_source: ::std::option::Option<crate::types::S3CsvSource>,
pub s3_json_source: ::std::option::Option<crate::types::S3JsonSource>,
pub s3_parquet_source: ::std::option::Option<crate::types::S3ParquetSource>,
pub relational_catalog_source: ::std::option::Option<crate::types::RelationalCatalogSource>,
pub dynamo_db_catalog_source: ::std::option::Option<crate::types::DynamoDbCatalogSource>,
pub jdbc_connector_target: ::std::option::Option<crate::types::JdbcConnectorTarget>,
pub spark_connector_target: ::std::option::Option<crate::types::SparkConnectorTarget>,
pub catalog_target: ::std::option::Option<crate::types::BasicCatalogTarget>,
pub redshift_target: ::std::option::Option<crate::types::RedshiftTarget>,
pub s3_catalog_target: ::std::option::Option<crate::types::S3CatalogTarget>,
pub s3_glue_parquet_target: ::std::option::Option<crate::types::S3GlueParquetTarget>,
pub s3_direct_target: ::std::option::Option<crate::types::S3DirectTarget>,
pub apply_mapping: ::std::option::Option<crate::types::ApplyMapping>,
pub select_fields: ::std::option::Option<crate::types::SelectFields>,
pub drop_fields: ::std::option::Option<crate::types::DropFields>,
pub rename_field: ::std::option::Option<crate::types::RenameField>,
pub spigot: ::std::option::Option<crate::types::Spigot>,
pub join: ::std::option::Option<crate::types::Join>,
pub split_fields: ::std::option::Option<crate::types::SplitFields>,
pub select_from_collection: ::std::option::Option<crate::types::SelectFromCollection>,
pub fill_missing_values: ::std::option::Option<crate::types::FillMissingValues>,
pub filter: ::std::option::Option<crate::types::Filter>,
pub custom_code: ::std::option::Option<crate::types::CustomCode>,
pub spark_sql: ::std::option::Option<crate::types::SparkSql>,
pub direct_kinesis_source: ::std::option::Option<crate::types::DirectKinesisSource>,
pub direct_kafka_source: ::std::option::Option<crate::types::DirectKafkaSource>,
pub catalog_kinesis_source: ::std::option::Option<crate::types::CatalogKinesisSource>,
pub catalog_kafka_source: ::std::option::Option<crate::types::CatalogKafkaSource>,
pub drop_null_fields: ::std::option::Option<crate::types::DropNullFields>,
pub merge: ::std::option::Option<crate::types::Merge>,
pub union: ::std::option::Option<crate::types::Union>,
pub pii_detection: ::std::option::Option<crate::types::PiiDetection>,
pub aggregate: ::std::option::Option<crate::types::Aggregate>,
pub drop_duplicates: ::std::option::Option<crate::types::DropDuplicates>,
pub governed_catalog_target: ::std::option::Option<crate::types::GovernedCatalogTarget>,
pub governed_catalog_source: ::std::option::Option<crate::types::GovernedCatalogSource>,
pub microsoft_sql_server_catalog_source: ::std::option::Option<crate::types::MicrosoftSqlServerCatalogSource>,
pub my_sql_catalog_source: ::std::option::Option<crate::types::MySqlCatalogSource>,
pub oracle_sql_catalog_source: ::std::option::Option<crate::types::OracleSqlCatalogSource>,
pub postgre_sql_catalog_source: ::std::option::Option<crate::types::PostgreSqlCatalogSource>,
pub microsoft_sql_server_catalog_target: ::std::option::Option<crate::types::MicrosoftSqlServerCatalogTarget>,
pub my_sql_catalog_target: ::std::option::Option<crate::types::MySqlCatalogTarget>,
pub oracle_sql_catalog_target: ::std::option::Option<crate::types::OracleSqlCatalogTarget>,
pub postgre_sql_catalog_target: ::std::option::Option<crate::types::PostgreSqlCatalogTarget>,
pub dynamic_transform: ::std::option::Option<crate::types::DynamicTransform>,
pub evaluate_data_quality: ::std::option::Option<crate::types::EvaluateDataQuality>,
pub s3_catalog_hudi_source: ::std::option::Option<crate::types::S3CatalogHudiSource>,
pub catalog_hudi_source: ::std::option::Option<crate::types::CatalogHudiSource>,
pub s3_hudi_source: ::std::option::Option<crate::types::S3HudiSource>,
pub s3_hudi_catalog_target: ::std::option::Option<crate::types::S3HudiCatalogTarget>,
pub s3_hudi_direct_target: ::std::option::Option<crate::types::S3HudiDirectTarget>,
pub direct_jdbc_source: ::std::option::Option<crate::types::DirectJdbcSource>,
pub s3_catalog_delta_source: ::std::option::Option<crate::types::S3CatalogDeltaSource>,
pub catalog_delta_source: ::std::option::Option<crate::types::CatalogDeltaSource>,
pub s3_delta_source: ::std::option::Option<crate::types::S3DeltaSource>,
pub s3_delta_catalog_target: ::std::option::Option<crate::types::S3DeltaCatalogTarget>,
pub s3_delta_direct_target: ::std::option::Option<crate::types::S3DeltaDirectTarget>,
pub amazon_redshift_source: ::std::option::Option<crate::types::AmazonRedshiftSource>,
pub amazon_redshift_target: ::std::option::Option<crate::types::AmazonRedshiftTarget>,
pub evaluate_data_quality_multi_frame: ::std::option::Option<crate::types::EvaluateDataQualityMultiFrame>,
pub recipe: ::std::option::Option<crate::types::Recipe>,
pub snowflake_source: ::std::option::Option<crate::types::SnowflakeSource>,
pub snowflake_target: ::std::option::Option<crate::types::SnowflakeTarget>,
pub connector_data_source: ::std::option::Option<crate::types::ConnectorDataSource>,
pub connector_data_target: ::std::option::Option<crate::types::ConnectorDataTarget>,
}
impl CodeGenConfigurationNode {
pub fn athena_connector_source(&self) -> ::std::option::Option<&crate::types::AthenaConnectorSource> {
self.athena_connector_source.as_ref()
}
pub fn jdbc_connector_source(&self) -> ::std::option::Option<&crate::types::JdbcConnectorSource> {
self.jdbc_connector_source.as_ref()
}
pub fn spark_connector_source(&self) -> ::std::option::Option<&crate::types::SparkConnectorSource> {
self.spark_connector_source.as_ref()
}
pub fn catalog_source(&self) -> ::std::option::Option<&crate::types::CatalogSource> {
self.catalog_source.as_ref()
}
pub fn redshift_source(&self) -> ::std::option::Option<&crate::types::RedshiftSource> {
self.redshift_source.as_ref()
}
pub fn s3_catalog_source(&self) -> ::std::option::Option<&crate::types::S3CatalogSource> {
self.s3_catalog_source.as_ref()
}
pub fn s3_csv_source(&self) -> ::std::option::Option<&crate::types::S3CsvSource> {
self.s3_csv_source.as_ref()
}
pub fn s3_json_source(&self) -> ::std::option::Option<&crate::types::S3JsonSource> {
self.s3_json_source.as_ref()
}
pub fn s3_parquet_source(&self) -> ::std::option::Option<&crate::types::S3ParquetSource> {
self.s3_parquet_source.as_ref()
}
pub fn relational_catalog_source(&self) -> ::std::option::Option<&crate::types::RelationalCatalogSource> {
self.relational_catalog_source.as_ref()
}
pub fn dynamo_db_catalog_source(&self) -> ::std::option::Option<&crate::types::DynamoDbCatalogSource> {
self.dynamo_db_catalog_source.as_ref()
}
pub fn jdbc_connector_target(&self) -> ::std::option::Option<&crate::types::JdbcConnectorTarget> {
self.jdbc_connector_target.as_ref()
}
pub fn spark_connector_target(&self) -> ::std::option::Option<&crate::types::SparkConnectorTarget> {
self.spark_connector_target.as_ref()
}
pub fn catalog_target(&self) -> ::std::option::Option<&crate::types::BasicCatalogTarget> {
self.catalog_target.as_ref()
}
pub fn redshift_target(&self) -> ::std::option::Option<&crate::types::RedshiftTarget> {
self.redshift_target.as_ref()
}
pub fn s3_catalog_target(&self) -> ::std::option::Option<&crate::types::S3CatalogTarget> {
self.s3_catalog_target.as_ref()
}
pub fn s3_glue_parquet_target(&self) -> ::std::option::Option<&crate::types::S3GlueParquetTarget> {
self.s3_glue_parquet_target.as_ref()
}
pub fn s3_direct_target(&self) -> ::std::option::Option<&crate::types::S3DirectTarget> {
self.s3_direct_target.as_ref()
}
pub fn apply_mapping(&self) -> ::std::option::Option<&crate::types::ApplyMapping> {
self.apply_mapping.as_ref()
}
pub fn select_fields(&self) -> ::std::option::Option<&crate::types::SelectFields> {
self.select_fields.as_ref()
}
pub fn drop_fields(&self) -> ::std::option::Option<&crate::types::DropFields> {
self.drop_fields.as_ref()
}
pub fn rename_field(&self) -> ::std::option::Option<&crate::types::RenameField> {
self.rename_field.as_ref()
}
pub fn spigot(&self) -> ::std::option::Option<&crate::types::Spigot> {
self.spigot.as_ref()
}
pub fn join(&self) -> ::std::option::Option<&crate::types::Join> {
self.join.as_ref()
}
pub fn split_fields(&self) -> ::std::option::Option<&crate::types::SplitFields> {
self.split_fields.as_ref()
}
pub fn select_from_collection(&self) -> ::std::option::Option<&crate::types::SelectFromCollection> {
self.select_from_collection.as_ref()
}
pub fn fill_missing_values(&self) -> ::std::option::Option<&crate::types::FillMissingValues> {
self.fill_missing_values.as_ref()
}
pub fn filter(&self) -> ::std::option::Option<&crate::types::Filter> {
self.filter.as_ref()
}
pub fn custom_code(&self) -> ::std::option::Option<&crate::types::CustomCode> {
self.custom_code.as_ref()
}
pub fn spark_sql(&self) -> ::std::option::Option<&crate::types::SparkSql> {
self.spark_sql.as_ref()
}
pub fn direct_kinesis_source(&self) -> ::std::option::Option<&crate::types::DirectKinesisSource> {
self.direct_kinesis_source.as_ref()
}
pub fn direct_kafka_source(&self) -> ::std::option::Option<&crate::types::DirectKafkaSource> {
self.direct_kafka_source.as_ref()
}
pub fn catalog_kinesis_source(&self) -> ::std::option::Option<&crate::types::CatalogKinesisSource> {
self.catalog_kinesis_source.as_ref()
}
pub fn catalog_kafka_source(&self) -> ::std::option::Option<&crate::types::CatalogKafkaSource> {
self.catalog_kafka_source.as_ref()
}
pub fn drop_null_fields(&self) -> ::std::option::Option<&crate::types::DropNullFields> {
self.drop_null_fields.as_ref()
}
pub fn merge(&self) -> ::std::option::Option<&crate::types::Merge> {
self.merge.as_ref()
}
pub fn union(&self) -> ::std::option::Option<&crate::types::Union> {
self.union.as_ref()
}
pub fn pii_detection(&self) -> ::std::option::Option<&crate::types::PiiDetection> {
self.pii_detection.as_ref()
}
pub fn aggregate(&self) -> ::std::option::Option<&crate::types::Aggregate> {
self.aggregate.as_ref()
}
pub fn drop_duplicates(&self) -> ::std::option::Option<&crate::types::DropDuplicates> {
self.drop_duplicates.as_ref()
}
pub fn governed_catalog_target(&self) -> ::std::option::Option<&crate::types::GovernedCatalogTarget> {
self.governed_catalog_target.as_ref()
}
pub fn governed_catalog_source(&self) -> ::std::option::Option<&crate::types::GovernedCatalogSource> {
self.governed_catalog_source.as_ref()
}
pub fn microsoft_sql_server_catalog_source(&self) -> ::std::option::Option<&crate::types::MicrosoftSqlServerCatalogSource> {
self.microsoft_sql_server_catalog_source.as_ref()
}
pub fn my_sql_catalog_source(&self) -> ::std::option::Option<&crate::types::MySqlCatalogSource> {
self.my_sql_catalog_source.as_ref()
}
pub fn oracle_sql_catalog_source(&self) -> ::std::option::Option<&crate::types::OracleSqlCatalogSource> {
self.oracle_sql_catalog_source.as_ref()
}
pub fn postgre_sql_catalog_source(&self) -> ::std::option::Option<&crate::types::PostgreSqlCatalogSource> {
self.postgre_sql_catalog_source.as_ref()
}
pub fn microsoft_sql_server_catalog_target(&self) -> ::std::option::Option<&crate::types::MicrosoftSqlServerCatalogTarget> {
self.microsoft_sql_server_catalog_target.as_ref()
}
pub fn my_sql_catalog_target(&self) -> ::std::option::Option<&crate::types::MySqlCatalogTarget> {
self.my_sql_catalog_target.as_ref()
}
pub fn oracle_sql_catalog_target(&self) -> ::std::option::Option<&crate::types::OracleSqlCatalogTarget> {
self.oracle_sql_catalog_target.as_ref()
}
pub fn postgre_sql_catalog_target(&self) -> ::std::option::Option<&crate::types::PostgreSqlCatalogTarget> {
self.postgre_sql_catalog_target.as_ref()
}
pub fn dynamic_transform(&self) -> ::std::option::Option<&crate::types::DynamicTransform> {
self.dynamic_transform.as_ref()
}
pub fn evaluate_data_quality(&self) -> ::std::option::Option<&crate::types::EvaluateDataQuality> {
self.evaluate_data_quality.as_ref()
}
pub fn s3_catalog_hudi_source(&self) -> ::std::option::Option<&crate::types::S3CatalogHudiSource> {
self.s3_catalog_hudi_source.as_ref()
}
pub fn catalog_hudi_source(&self) -> ::std::option::Option<&crate::types::CatalogHudiSource> {
self.catalog_hudi_source.as_ref()
}
pub fn s3_hudi_source(&self) -> ::std::option::Option<&crate::types::S3HudiSource> {
self.s3_hudi_source.as_ref()
}
pub fn s3_hudi_catalog_target(&self) -> ::std::option::Option<&crate::types::S3HudiCatalogTarget> {
self.s3_hudi_catalog_target.as_ref()
}
pub fn s3_hudi_direct_target(&self) -> ::std::option::Option<&crate::types::S3HudiDirectTarget> {
self.s3_hudi_direct_target.as_ref()
}
pub fn direct_jdbc_source(&self) -> ::std::option::Option<&crate::types::DirectJdbcSource> {
self.direct_jdbc_source.as_ref()
}
pub fn s3_catalog_delta_source(&self) -> ::std::option::Option<&crate::types::S3CatalogDeltaSource> {
self.s3_catalog_delta_source.as_ref()
}
pub fn catalog_delta_source(&self) -> ::std::option::Option<&crate::types::CatalogDeltaSource> {
self.catalog_delta_source.as_ref()
}
pub fn s3_delta_source(&self) -> ::std::option::Option<&crate::types::S3DeltaSource> {
self.s3_delta_source.as_ref()
}
pub fn s3_delta_catalog_target(&self) -> ::std::option::Option<&crate::types::S3DeltaCatalogTarget> {
self.s3_delta_catalog_target.as_ref()
}
pub fn s3_delta_direct_target(&self) -> ::std::option::Option<&crate::types::S3DeltaDirectTarget> {
self.s3_delta_direct_target.as_ref()
}
pub fn amazon_redshift_source(&self) -> ::std::option::Option<&crate::types::AmazonRedshiftSource> {
self.amazon_redshift_source.as_ref()
}
pub fn amazon_redshift_target(&self) -> ::std::option::Option<&crate::types::AmazonRedshiftTarget> {
self.amazon_redshift_target.as_ref()
}
pub fn evaluate_data_quality_multi_frame(&self) -> ::std::option::Option<&crate::types::EvaluateDataQualityMultiFrame> {
self.evaluate_data_quality_multi_frame.as_ref()
}
pub fn recipe(&self) -> ::std::option::Option<&crate::types::Recipe> {
self.recipe.as_ref()
}
pub fn snowflake_source(&self) -> ::std::option::Option<&crate::types::SnowflakeSource> {
self.snowflake_source.as_ref()
}
pub fn snowflake_target(&self) -> ::std::option::Option<&crate::types::SnowflakeTarget> {
self.snowflake_target.as_ref()
}
pub fn connector_data_source(&self) -> ::std::option::Option<&crate::types::ConnectorDataSource> {
self.connector_data_source.as_ref()
}
pub fn connector_data_target(&self) -> ::std::option::Option<&crate::types::ConnectorDataTarget> {
self.connector_data_target.as_ref()
}
}
impl CodeGenConfigurationNode {
pub fn builder() -> crate::types::builders::CodeGenConfigurationNodeBuilder {
crate::types::builders::CodeGenConfigurationNodeBuilder::default()
}
}
#[non_exhaustive]
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
pub struct CodeGenConfigurationNodeBuilder {
pub(crate) athena_connector_source: ::std::option::Option<crate::types::AthenaConnectorSource>,
pub(crate) jdbc_connector_source: ::std::option::Option<crate::types::JdbcConnectorSource>,
pub(crate) spark_connector_source: ::std::option::Option<crate::types::SparkConnectorSource>,
pub(crate) catalog_source: ::std::option::Option<crate::types::CatalogSource>,
pub(crate) redshift_source: ::std::option::Option<crate::types::RedshiftSource>,
pub(crate) s3_catalog_source: ::std::option::Option<crate::types::S3CatalogSource>,
pub(crate) s3_csv_source: ::std::option::Option<crate::types::S3CsvSource>,
pub(crate) s3_json_source: ::std::option::Option<crate::types::S3JsonSource>,
pub(crate) s3_parquet_source: ::std::option::Option<crate::types::S3ParquetSource>,
pub(crate) relational_catalog_source: ::std::option::Option<crate::types::RelationalCatalogSource>,
pub(crate) dynamo_db_catalog_source: ::std::option::Option<crate::types::DynamoDbCatalogSource>,
pub(crate) jdbc_connector_target: ::std::option::Option<crate::types::JdbcConnectorTarget>,
pub(crate) spark_connector_target: ::std::option::Option<crate::types::SparkConnectorTarget>,
pub(crate) catalog_target: ::std::option::Option<crate::types::BasicCatalogTarget>,
pub(crate) redshift_target: ::std::option::Option<crate::types::RedshiftTarget>,
pub(crate) s3_catalog_target: ::std::option::Option<crate::types::S3CatalogTarget>,
pub(crate) s3_glue_parquet_target: ::std::option::Option<crate::types::S3GlueParquetTarget>,
pub(crate) s3_direct_target: ::std::option::Option<crate::types::S3DirectTarget>,
pub(crate) apply_mapping: ::std::option::Option<crate::types::ApplyMapping>,
pub(crate) select_fields: ::std::option::Option<crate::types::SelectFields>,
pub(crate) drop_fields: ::std::option::Option<crate::types::DropFields>,
pub(crate) rename_field: ::std::option::Option<crate::types::RenameField>,
pub(crate) spigot: ::std::option::Option<crate::types::Spigot>,
pub(crate) join: ::std::option::Option<crate::types::Join>,
pub(crate) split_fields: ::std::option::Option<crate::types::SplitFields>,
pub(crate) select_from_collection: ::std::option::Option<crate::types::SelectFromCollection>,
pub(crate) fill_missing_values: ::std::option::Option<crate::types::FillMissingValues>,
pub(crate) filter: ::std::option::Option<crate::types::Filter>,
pub(crate) custom_code: ::std::option::Option<crate::types::CustomCode>,
pub(crate) spark_sql: ::std::option::Option<crate::types::SparkSql>,
pub(crate) direct_kinesis_source: ::std::option::Option<crate::types::DirectKinesisSource>,
pub(crate) direct_kafka_source: ::std::option::Option<crate::types::DirectKafkaSource>,
pub(crate) catalog_kinesis_source: ::std::option::Option<crate::types::CatalogKinesisSource>,
pub(crate) catalog_kafka_source: ::std::option::Option<crate::types::CatalogKafkaSource>,
pub(crate) drop_null_fields: ::std::option::Option<crate::types::DropNullFields>,
pub(crate) merge: ::std::option::Option<crate::types::Merge>,
pub(crate) union: ::std::option::Option<crate::types::Union>,
pub(crate) pii_detection: ::std::option::Option<crate::types::PiiDetection>,
pub(crate) aggregate: ::std::option::Option<crate::types::Aggregate>,
pub(crate) drop_duplicates: ::std::option::Option<crate::types::DropDuplicates>,
pub(crate) governed_catalog_target: ::std::option::Option<crate::types::GovernedCatalogTarget>,
pub(crate) governed_catalog_source: ::std::option::Option<crate::types::GovernedCatalogSource>,
pub(crate) microsoft_sql_server_catalog_source: ::std::option::Option<crate::types::MicrosoftSqlServerCatalogSource>,
pub(crate) my_sql_catalog_source: ::std::option::Option<crate::types::MySqlCatalogSource>,
pub(crate) oracle_sql_catalog_source: ::std::option::Option<crate::types::OracleSqlCatalogSource>,
pub(crate) postgre_sql_catalog_source: ::std::option::Option<crate::types::PostgreSqlCatalogSource>,
pub(crate) microsoft_sql_server_catalog_target: ::std::option::Option<crate::types::MicrosoftSqlServerCatalogTarget>,
pub(crate) my_sql_catalog_target: ::std::option::Option<crate::types::MySqlCatalogTarget>,
pub(crate) oracle_sql_catalog_target: ::std::option::Option<crate::types::OracleSqlCatalogTarget>,
pub(crate) postgre_sql_catalog_target: ::std::option::Option<crate::types::PostgreSqlCatalogTarget>,
pub(crate) dynamic_transform: ::std::option::Option<crate::types::DynamicTransform>,
pub(crate) evaluate_data_quality: ::std::option::Option<crate::types::EvaluateDataQuality>,
pub(crate) s3_catalog_hudi_source: ::std::option::Option<crate::types::S3CatalogHudiSource>,
pub(crate) catalog_hudi_source: ::std::option::Option<crate::types::CatalogHudiSource>,
pub(crate) s3_hudi_source: ::std::option::Option<crate::types::S3HudiSource>,
pub(crate) s3_hudi_catalog_target: ::std::option::Option<crate::types::S3HudiCatalogTarget>,
pub(crate) s3_hudi_direct_target: ::std::option::Option<crate::types::S3HudiDirectTarget>,
pub(crate) direct_jdbc_source: ::std::option::Option<crate::types::DirectJdbcSource>,
pub(crate) s3_catalog_delta_source: ::std::option::Option<crate::types::S3CatalogDeltaSource>,
pub(crate) catalog_delta_source: ::std::option::Option<crate::types::CatalogDeltaSource>,
pub(crate) s3_delta_source: ::std::option::Option<crate::types::S3DeltaSource>,
pub(crate) s3_delta_catalog_target: ::std::option::Option<crate::types::S3DeltaCatalogTarget>,
pub(crate) s3_delta_direct_target: ::std::option::Option<crate::types::S3DeltaDirectTarget>,
pub(crate) amazon_redshift_source: ::std::option::Option<crate::types::AmazonRedshiftSource>,
pub(crate) amazon_redshift_target: ::std::option::Option<crate::types::AmazonRedshiftTarget>,
pub(crate) evaluate_data_quality_multi_frame: ::std::option::Option<crate::types::EvaluateDataQualityMultiFrame>,
pub(crate) recipe: ::std::option::Option<crate::types::Recipe>,
pub(crate) snowflake_source: ::std::option::Option<crate::types::SnowflakeSource>,
pub(crate) snowflake_target: ::std::option::Option<crate::types::SnowflakeTarget>,
pub(crate) connector_data_source: ::std::option::Option<crate::types::ConnectorDataSource>,
pub(crate) connector_data_target: ::std::option::Option<crate::types::ConnectorDataTarget>,
}
impl CodeGenConfigurationNodeBuilder {
pub fn athena_connector_source(mut self, input: crate::types::AthenaConnectorSource) -> Self {
self.athena_connector_source = ::std::option::Option::Some(input);
self
}
pub fn set_athena_connector_source(mut self, input: ::std::option::Option<crate::types::AthenaConnectorSource>) -> Self {
self.athena_connector_source = input;
self
}
pub fn get_athena_connector_source(&self) -> &::std::option::Option<crate::types::AthenaConnectorSource> {
&self.athena_connector_source
}
pub fn jdbc_connector_source(mut self, input: crate::types::JdbcConnectorSource) -> Self {
self.jdbc_connector_source = ::std::option::Option::Some(input);
self
}
pub fn set_jdbc_connector_source(mut self, input: ::std::option::Option<crate::types::JdbcConnectorSource>) -> Self {
self.jdbc_connector_source = input;
self
}
pub fn get_jdbc_connector_source(&self) -> &::std::option::Option<crate::types::JdbcConnectorSource> {
&self.jdbc_connector_source
}
pub fn spark_connector_source(mut self, input: crate::types::SparkConnectorSource) -> Self {
self.spark_connector_source = ::std::option::Option::Some(input);
self
}
pub fn set_spark_connector_source(mut self, input: ::std::option::Option<crate::types::SparkConnectorSource>) -> Self {
self.spark_connector_source = input;
self
}
pub fn get_spark_connector_source(&self) -> &::std::option::Option<crate::types::SparkConnectorSource> {
&self.spark_connector_source
}
pub fn catalog_source(mut self, input: crate::types::CatalogSource) -> Self {
self.catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_catalog_source(mut self, input: ::std::option::Option<crate::types::CatalogSource>) -> Self {
self.catalog_source = input;
self
}
pub fn get_catalog_source(&self) -> &::std::option::Option<crate::types::CatalogSource> {
&self.catalog_source
}
pub fn redshift_source(mut self, input: crate::types::RedshiftSource) -> Self {
self.redshift_source = ::std::option::Option::Some(input);
self
}
pub fn set_redshift_source(mut self, input: ::std::option::Option<crate::types::RedshiftSource>) -> Self {
self.redshift_source = input;
self
}
pub fn get_redshift_source(&self) -> &::std::option::Option<crate::types::RedshiftSource> {
&self.redshift_source
}
pub fn s3_catalog_source(mut self, input: crate::types::S3CatalogSource) -> Self {
self.s3_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_catalog_source(mut self, input: ::std::option::Option<crate::types::S3CatalogSource>) -> Self {
self.s3_catalog_source = input;
self
}
pub fn get_s3_catalog_source(&self) -> &::std::option::Option<crate::types::S3CatalogSource> {
&self.s3_catalog_source
}
pub fn s3_csv_source(mut self, input: crate::types::S3CsvSource) -> Self {
self.s3_csv_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_csv_source(mut self, input: ::std::option::Option<crate::types::S3CsvSource>) -> Self {
self.s3_csv_source = input;
self
}
pub fn get_s3_csv_source(&self) -> &::std::option::Option<crate::types::S3CsvSource> {
&self.s3_csv_source
}
pub fn s3_json_source(mut self, input: crate::types::S3JsonSource) -> Self {
self.s3_json_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_json_source(mut self, input: ::std::option::Option<crate::types::S3JsonSource>) -> Self {
self.s3_json_source = input;
self
}
pub fn get_s3_json_source(&self) -> &::std::option::Option<crate::types::S3JsonSource> {
&self.s3_json_source
}
pub fn s3_parquet_source(mut self, input: crate::types::S3ParquetSource) -> Self {
self.s3_parquet_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_parquet_source(mut self, input: ::std::option::Option<crate::types::S3ParquetSource>) -> Self {
self.s3_parquet_source = input;
self
}
pub fn get_s3_parquet_source(&self) -> &::std::option::Option<crate::types::S3ParquetSource> {
&self.s3_parquet_source
}
pub fn relational_catalog_source(mut self, input: crate::types::RelationalCatalogSource) -> Self {
self.relational_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_relational_catalog_source(mut self, input: ::std::option::Option<crate::types::RelationalCatalogSource>) -> Self {
self.relational_catalog_source = input;
self
}
pub fn get_relational_catalog_source(&self) -> &::std::option::Option<crate::types::RelationalCatalogSource> {
&self.relational_catalog_source
}
pub fn dynamo_db_catalog_source(mut self, input: crate::types::DynamoDbCatalogSource) -> Self {
self.dynamo_db_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_dynamo_db_catalog_source(mut self, input: ::std::option::Option<crate::types::DynamoDbCatalogSource>) -> Self {
self.dynamo_db_catalog_source = input;
self
}
pub fn get_dynamo_db_catalog_source(&self) -> &::std::option::Option<crate::types::DynamoDbCatalogSource> {
&self.dynamo_db_catalog_source
}
pub fn jdbc_connector_target(mut self, input: crate::types::JdbcConnectorTarget) -> Self {
self.jdbc_connector_target = ::std::option::Option::Some(input);
self
}
pub fn set_jdbc_connector_target(mut self, input: ::std::option::Option<crate::types::JdbcConnectorTarget>) -> Self {
self.jdbc_connector_target = input;
self
}
pub fn get_jdbc_connector_target(&self) -> &::std::option::Option<crate::types::JdbcConnectorTarget> {
&self.jdbc_connector_target
}
pub fn spark_connector_target(mut self, input: crate::types::SparkConnectorTarget) -> Self {
self.spark_connector_target = ::std::option::Option::Some(input);
self
}
pub fn set_spark_connector_target(mut self, input: ::std::option::Option<crate::types::SparkConnectorTarget>) -> Self {
self.spark_connector_target = input;
self
}
pub fn get_spark_connector_target(&self) -> &::std::option::Option<crate::types::SparkConnectorTarget> {
&self.spark_connector_target
}
pub fn catalog_target(mut self, input: crate::types::BasicCatalogTarget) -> Self {
self.catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_catalog_target(mut self, input: ::std::option::Option<crate::types::BasicCatalogTarget>) -> Self {
self.catalog_target = input;
self
}
pub fn get_catalog_target(&self) -> &::std::option::Option<crate::types::BasicCatalogTarget> {
&self.catalog_target
}
pub fn redshift_target(mut self, input: crate::types::RedshiftTarget) -> Self {
self.redshift_target = ::std::option::Option::Some(input);
self
}
pub fn set_redshift_target(mut self, input: ::std::option::Option<crate::types::RedshiftTarget>) -> Self {
self.redshift_target = input;
self
}
pub fn get_redshift_target(&self) -> &::std::option::Option<crate::types::RedshiftTarget> {
&self.redshift_target
}
pub fn s3_catalog_target(mut self, input: crate::types::S3CatalogTarget) -> Self {
self.s3_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_s3_catalog_target(mut self, input: ::std::option::Option<crate::types::S3CatalogTarget>) -> Self {
self.s3_catalog_target = input;
self
}
pub fn get_s3_catalog_target(&self) -> &::std::option::Option<crate::types::S3CatalogTarget> {
&self.s3_catalog_target
}
pub fn s3_glue_parquet_target(mut self, input: crate::types::S3GlueParquetTarget) -> Self {
self.s3_glue_parquet_target = ::std::option::Option::Some(input);
self
}
pub fn set_s3_glue_parquet_target(mut self, input: ::std::option::Option<crate::types::S3GlueParquetTarget>) -> Self {
self.s3_glue_parquet_target = input;
self
}
pub fn get_s3_glue_parquet_target(&self) -> &::std::option::Option<crate::types::S3GlueParquetTarget> {
&self.s3_glue_parquet_target
}
pub fn s3_direct_target(mut self, input: crate::types::S3DirectTarget) -> Self {
self.s3_direct_target = ::std::option::Option::Some(input);
self
}
pub fn set_s3_direct_target(mut self, input: ::std::option::Option<crate::types::S3DirectTarget>) -> Self {
self.s3_direct_target = input;
self
}
pub fn get_s3_direct_target(&self) -> &::std::option::Option<crate::types::S3DirectTarget> {
&self.s3_direct_target
}
pub fn apply_mapping(mut self, input: crate::types::ApplyMapping) -> Self {
self.apply_mapping = ::std::option::Option::Some(input);
self
}
pub fn set_apply_mapping(mut self, input: ::std::option::Option<crate::types::ApplyMapping>) -> Self {
self.apply_mapping = input;
self
}
pub fn get_apply_mapping(&self) -> &::std::option::Option<crate::types::ApplyMapping> {
&self.apply_mapping
}
pub fn select_fields(mut self, input: crate::types::SelectFields) -> Self {
self.select_fields = ::std::option::Option::Some(input);
self
}
pub fn set_select_fields(mut self, input: ::std::option::Option<crate::types::SelectFields>) -> Self {
self.select_fields = input;
self
}
pub fn get_select_fields(&self) -> &::std::option::Option<crate::types::SelectFields> {
&self.select_fields
}
pub fn drop_fields(mut self, input: crate::types::DropFields) -> Self {
self.drop_fields = ::std::option::Option::Some(input);
self
}
pub fn set_drop_fields(mut self, input: ::std::option::Option<crate::types::DropFields>) -> Self {
self.drop_fields = input;
self
}
pub fn get_drop_fields(&self) -> &::std::option::Option<crate::types::DropFields> {
&self.drop_fields
}
pub fn rename_field(mut self, input: crate::types::RenameField) -> Self {
self.rename_field = ::std::option::Option::Some(input);
self
}
pub fn set_rename_field(mut self, input: ::std::option::Option<crate::types::RenameField>) -> Self {
self.rename_field = input;
self
}
pub fn get_rename_field(&self) -> &::std::option::Option<crate::types::RenameField> {
&self.rename_field
}
pub fn spigot(mut self, input: crate::types::Spigot) -> Self {
self.spigot = ::std::option::Option::Some(input);
self
}
pub fn set_spigot(mut self, input: ::std::option::Option<crate::types::Spigot>) -> Self {
self.spigot = input;
self
}
pub fn get_spigot(&self) -> &::std::option::Option<crate::types::Spigot> {
&self.spigot
}
pub fn join(mut self, input: crate::types::Join) -> Self {
self.join = ::std::option::Option::Some(input);
self
}
pub fn set_join(mut self, input: ::std::option::Option<crate::types::Join>) -> Self {
self.join = input;
self
}
pub fn get_join(&self) -> &::std::option::Option<crate::types::Join> {
&self.join
}
pub fn split_fields(mut self, input: crate::types::SplitFields) -> Self {
self.split_fields = ::std::option::Option::Some(input);
self
}
pub fn set_split_fields(mut self, input: ::std::option::Option<crate::types::SplitFields>) -> Self {
self.split_fields = input;
self
}
pub fn get_split_fields(&self) -> &::std::option::Option<crate::types::SplitFields> {
&self.split_fields
}
pub fn select_from_collection(mut self, input: crate::types::SelectFromCollection) -> Self {
self.select_from_collection = ::std::option::Option::Some(input);
self
}
pub fn set_select_from_collection(mut self, input: ::std::option::Option<crate::types::SelectFromCollection>) -> Self {
self.select_from_collection = input;
self
}
pub fn get_select_from_collection(&self) -> &::std::option::Option<crate::types::SelectFromCollection> {
&self.select_from_collection
}
pub fn fill_missing_values(mut self, input: crate::types::FillMissingValues) -> Self {
self.fill_missing_values = ::std::option::Option::Some(input);
self
}
pub fn set_fill_missing_values(mut self, input: ::std::option::Option<crate::types::FillMissingValues>) -> Self {
self.fill_missing_values = input;
self
}
pub fn get_fill_missing_values(&self) -> &::std::option::Option<crate::types::FillMissingValues> {
&self.fill_missing_values
}
pub fn filter(mut self, input: crate::types::Filter) -> Self {
self.filter = ::std::option::Option::Some(input);
self
}
pub fn set_filter(mut self, input: ::std::option::Option<crate::types::Filter>) -> Self {
self.filter = input;
self
}
pub fn get_filter(&self) -> &::std::option::Option<crate::types::Filter> {
&self.filter
}
pub fn custom_code(mut self, input: crate::types::CustomCode) -> Self {
self.custom_code = ::std::option::Option::Some(input);
self
}
pub fn set_custom_code(mut self, input: ::std::option::Option<crate::types::CustomCode>) -> Self {
self.custom_code = input;
self
}
pub fn get_custom_code(&self) -> &::std::option::Option<crate::types::CustomCode> {
&self.custom_code
}
pub fn spark_sql(mut self, input: crate::types::SparkSql) -> Self {
self.spark_sql = ::std::option::Option::Some(input);
self
}
pub fn set_spark_sql(mut self, input: ::std::option::Option<crate::types::SparkSql>) -> Self {
self.spark_sql = input;
self
}
pub fn get_spark_sql(&self) -> &::std::option::Option<crate::types::SparkSql> {
&self.spark_sql
}
pub fn direct_kinesis_source(mut self, input: crate::types::DirectKinesisSource) -> Self {
self.direct_kinesis_source = ::std::option::Option::Some(input);
self
}
pub fn set_direct_kinesis_source(mut self, input: ::std::option::Option<crate::types::DirectKinesisSource>) -> Self {
self.direct_kinesis_source = input;
self
}
pub fn get_direct_kinesis_source(&self) -> &::std::option::Option<crate::types::DirectKinesisSource> {
&self.direct_kinesis_source
}
pub fn direct_kafka_source(mut self, input: crate::types::DirectKafkaSource) -> Self {
self.direct_kafka_source = ::std::option::Option::Some(input);
self
}
pub fn set_direct_kafka_source(mut self, input: ::std::option::Option<crate::types::DirectKafkaSource>) -> Self {
self.direct_kafka_source = input;
self
}
pub fn get_direct_kafka_source(&self) -> &::std::option::Option<crate::types::DirectKafkaSource> {
&self.direct_kafka_source
}
pub fn catalog_kinesis_source(mut self, input: crate::types::CatalogKinesisSource) -> Self {
self.catalog_kinesis_source = ::std::option::Option::Some(input);
self
}
pub fn set_catalog_kinesis_source(mut self, input: ::std::option::Option<crate::types::CatalogKinesisSource>) -> Self {
self.catalog_kinesis_source = input;
self
}
pub fn get_catalog_kinesis_source(&self) -> &::std::option::Option<crate::types::CatalogKinesisSource> {
&self.catalog_kinesis_source
}
pub fn catalog_kafka_source(mut self, input: crate::types::CatalogKafkaSource) -> Self {
self.catalog_kafka_source = ::std::option::Option::Some(input);
self
}
pub fn set_catalog_kafka_source(mut self, input: ::std::option::Option<crate::types::CatalogKafkaSource>) -> Self {
self.catalog_kafka_source = input;
self
}
pub fn get_catalog_kafka_source(&self) -> &::std::option::Option<crate::types::CatalogKafkaSource> {
&self.catalog_kafka_source
}
pub fn drop_null_fields(mut self, input: crate::types::DropNullFields) -> Self {
self.drop_null_fields = ::std::option::Option::Some(input);
self
}
pub fn set_drop_null_fields(mut self, input: ::std::option::Option<crate::types::DropNullFields>) -> Self {
self.drop_null_fields = input;
self
}
pub fn get_drop_null_fields(&self) -> &::std::option::Option<crate::types::DropNullFields> {
&self.drop_null_fields
}
pub fn merge(mut self, input: crate::types::Merge) -> Self {
self.merge = ::std::option::Option::Some(input);
self
}
pub fn set_merge(mut self, input: ::std::option::Option<crate::types::Merge>) -> Self {
self.merge = input;
self
}
pub fn get_merge(&self) -> &::std::option::Option<crate::types::Merge> {
&self.merge
}
pub fn union(mut self, input: crate::types::Union) -> Self {
self.union = ::std::option::Option::Some(input);
self
}
pub fn set_union(mut self, input: ::std::option::Option<crate::types::Union>) -> Self {
self.union = input;
self
}
pub fn get_union(&self) -> &::std::option::Option<crate::types::Union> {
&self.union
}
pub fn pii_detection(mut self, input: crate::types::PiiDetection) -> Self {
self.pii_detection = ::std::option::Option::Some(input);
self
}
pub fn set_pii_detection(mut self, input: ::std::option::Option<crate::types::PiiDetection>) -> Self {
self.pii_detection = input;
self
}
pub fn get_pii_detection(&self) -> &::std::option::Option<crate::types::PiiDetection> {
&self.pii_detection
}
pub fn aggregate(mut self, input: crate::types::Aggregate) -> Self {
self.aggregate = ::std::option::Option::Some(input);
self
}
pub fn set_aggregate(mut self, input: ::std::option::Option<crate::types::Aggregate>) -> Self {
self.aggregate = input;
self
}
pub fn get_aggregate(&self) -> &::std::option::Option<crate::types::Aggregate> {
&self.aggregate
}
pub fn drop_duplicates(mut self, input: crate::types::DropDuplicates) -> Self {
self.drop_duplicates = ::std::option::Option::Some(input);
self
}
pub fn set_drop_duplicates(mut self, input: ::std::option::Option<crate::types::DropDuplicates>) -> Self {
self.drop_duplicates = input;
self
}
pub fn get_drop_duplicates(&self) -> &::std::option::Option<crate::types::DropDuplicates> {
&self.drop_duplicates
}
pub fn governed_catalog_target(mut self, input: crate::types::GovernedCatalogTarget) -> Self {
self.governed_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_governed_catalog_target(mut self, input: ::std::option::Option<crate::types::GovernedCatalogTarget>) -> Self {
self.governed_catalog_target = input;
self
}
pub fn get_governed_catalog_target(&self) -> &::std::option::Option<crate::types::GovernedCatalogTarget> {
&self.governed_catalog_target
}
pub fn governed_catalog_source(mut self, input: crate::types::GovernedCatalogSource) -> Self {
self.governed_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_governed_catalog_source(mut self, input: ::std::option::Option<crate::types::GovernedCatalogSource>) -> Self {
self.governed_catalog_source = input;
self
}
pub fn get_governed_catalog_source(&self) -> &::std::option::Option<crate::types::GovernedCatalogSource> {
&self.governed_catalog_source
}
pub fn microsoft_sql_server_catalog_source(mut self, input: crate::types::MicrosoftSqlServerCatalogSource) -> Self {
self.microsoft_sql_server_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_microsoft_sql_server_catalog_source(mut self, input: ::std::option::Option<crate::types::MicrosoftSqlServerCatalogSource>) -> Self {
self.microsoft_sql_server_catalog_source = input;
self
}
pub fn get_microsoft_sql_server_catalog_source(&self) -> &::std::option::Option<crate::types::MicrosoftSqlServerCatalogSource> {
&self.microsoft_sql_server_catalog_source
}
pub fn my_sql_catalog_source(mut self, input: crate::types::MySqlCatalogSource) -> Self {
self.my_sql_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_my_sql_catalog_source(mut self, input: ::std::option::Option<crate::types::MySqlCatalogSource>) -> Self {
self.my_sql_catalog_source = input;
self
}
pub fn get_my_sql_catalog_source(&self) -> &::std::option::Option<crate::types::MySqlCatalogSource> {
&self.my_sql_catalog_source
}
pub fn oracle_sql_catalog_source(mut self, input: crate::types::OracleSqlCatalogSource) -> Self {
self.oracle_sql_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_oracle_sql_catalog_source(mut self, input: ::std::option::Option<crate::types::OracleSqlCatalogSource>) -> Self {
self.oracle_sql_catalog_source = input;
self
}
pub fn get_oracle_sql_catalog_source(&self) -> &::std::option::Option<crate::types::OracleSqlCatalogSource> {
&self.oracle_sql_catalog_source
}
pub fn postgre_sql_catalog_source(mut self, input: crate::types::PostgreSqlCatalogSource) -> Self {
self.postgre_sql_catalog_source = ::std::option::Option::Some(input);
self
}
pub fn set_postgre_sql_catalog_source(mut self, input: ::std::option::Option<crate::types::PostgreSqlCatalogSource>) -> Self {
self.postgre_sql_catalog_source = input;
self
}
pub fn get_postgre_sql_catalog_source(&self) -> &::std::option::Option<crate::types::PostgreSqlCatalogSource> {
&self.postgre_sql_catalog_source
}
pub fn microsoft_sql_server_catalog_target(mut self, input: crate::types::MicrosoftSqlServerCatalogTarget) -> Self {
self.microsoft_sql_server_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_microsoft_sql_server_catalog_target(mut self, input: ::std::option::Option<crate::types::MicrosoftSqlServerCatalogTarget>) -> Self {
self.microsoft_sql_server_catalog_target = input;
self
}
pub fn get_microsoft_sql_server_catalog_target(&self) -> &::std::option::Option<crate::types::MicrosoftSqlServerCatalogTarget> {
&self.microsoft_sql_server_catalog_target
}
pub fn my_sql_catalog_target(mut self, input: crate::types::MySqlCatalogTarget) -> Self {
self.my_sql_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_my_sql_catalog_target(mut self, input: ::std::option::Option<crate::types::MySqlCatalogTarget>) -> Self {
self.my_sql_catalog_target = input;
self
}
pub fn get_my_sql_catalog_target(&self) -> &::std::option::Option<crate::types::MySqlCatalogTarget> {
&self.my_sql_catalog_target
}
pub fn oracle_sql_catalog_target(mut self, input: crate::types::OracleSqlCatalogTarget) -> Self {
self.oracle_sql_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_oracle_sql_catalog_target(mut self, input: ::std::option::Option<crate::types::OracleSqlCatalogTarget>) -> Self {
self.oracle_sql_catalog_target = input;
self
}
pub fn get_oracle_sql_catalog_target(&self) -> &::std::option::Option<crate::types::OracleSqlCatalogTarget> {
&self.oracle_sql_catalog_target
}
pub fn postgre_sql_catalog_target(mut self, input: crate::types::PostgreSqlCatalogTarget) -> Self {
self.postgre_sql_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_postgre_sql_catalog_target(mut self, input: ::std::option::Option<crate::types::PostgreSqlCatalogTarget>) -> Self {
self.postgre_sql_catalog_target = input;
self
}
pub fn get_postgre_sql_catalog_target(&self) -> &::std::option::Option<crate::types::PostgreSqlCatalogTarget> {
&self.postgre_sql_catalog_target
}
pub fn dynamic_transform(mut self, input: crate::types::DynamicTransform) -> Self {
self.dynamic_transform = ::std::option::Option::Some(input);
self
}
pub fn set_dynamic_transform(mut self, input: ::std::option::Option<crate::types::DynamicTransform>) -> Self {
self.dynamic_transform = input;
self
}
pub fn get_dynamic_transform(&self) -> &::std::option::Option<crate::types::DynamicTransform> {
&self.dynamic_transform
}
pub fn evaluate_data_quality(mut self, input: crate::types::EvaluateDataQuality) -> Self {
self.evaluate_data_quality = ::std::option::Option::Some(input);
self
}
pub fn set_evaluate_data_quality(mut self, input: ::std::option::Option<crate::types::EvaluateDataQuality>) -> Self {
self.evaluate_data_quality = input;
self
}
pub fn get_evaluate_data_quality(&self) -> &::std::option::Option<crate::types::EvaluateDataQuality> {
&self.evaluate_data_quality
}
pub fn s3_catalog_hudi_source(mut self, input: crate::types::S3CatalogHudiSource) -> Self {
self.s3_catalog_hudi_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_catalog_hudi_source(mut self, input: ::std::option::Option<crate::types::S3CatalogHudiSource>) -> Self {
self.s3_catalog_hudi_source = input;
self
}
pub fn get_s3_catalog_hudi_source(&self) -> &::std::option::Option<crate::types::S3CatalogHudiSource> {
&self.s3_catalog_hudi_source
}
pub fn catalog_hudi_source(mut self, input: crate::types::CatalogHudiSource) -> Self {
self.catalog_hudi_source = ::std::option::Option::Some(input);
self
}
pub fn set_catalog_hudi_source(mut self, input: ::std::option::Option<crate::types::CatalogHudiSource>) -> Self {
self.catalog_hudi_source = input;
self
}
pub fn get_catalog_hudi_source(&self) -> &::std::option::Option<crate::types::CatalogHudiSource> {
&self.catalog_hudi_source
}
pub fn s3_hudi_source(mut self, input: crate::types::S3HudiSource) -> Self {
self.s3_hudi_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_hudi_source(mut self, input: ::std::option::Option<crate::types::S3HudiSource>) -> Self {
self.s3_hudi_source = input;
self
}
pub fn get_s3_hudi_source(&self) -> &::std::option::Option<crate::types::S3HudiSource> {
&self.s3_hudi_source
}
pub fn s3_hudi_catalog_target(mut self, input: crate::types::S3HudiCatalogTarget) -> Self {
self.s3_hudi_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_s3_hudi_catalog_target(mut self, input: ::std::option::Option<crate::types::S3HudiCatalogTarget>) -> Self {
self.s3_hudi_catalog_target = input;
self
}
pub fn get_s3_hudi_catalog_target(&self) -> &::std::option::Option<crate::types::S3HudiCatalogTarget> {
&self.s3_hudi_catalog_target
}
pub fn s3_hudi_direct_target(mut self, input: crate::types::S3HudiDirectTarget) -> Self {
self.s3_hudi_direct_target = ::std::option::Option::Some(input);
self
}
pub fn set_s3_hudi_direct_target(mut self, input: ::std::option::Option<crate::types::S3HudiDirectTarget>) -> Self {
self.s3_hudi_direct_target = input;
self
}
pub fn get_s3_hudi_direct_target(&self) -> &::std::option::Option<crate::types::S3HudiDirectTarget> {
&self.s3_hudi_direct_target
}
pub fn direct_jdbc_source(mut self, input: crate::types::DirectJdbcSource) -> Self {
self.direct_jdbc_source = ::std::option::Option::Some(input);
self
}
pub fn set_direct_jdbc_source(mut self, input: ::std::option::Option<crate::types::DirectJdbcSource>) -> Self {
self.direct_jdbc_source = input;
self
}
pub fn get_direct_jdbc_source(&self) -> &::std::option::Option<crate::types::DirectJdbcSource> {
&self.direct_jdbc_source
}
pub fn s3_catalog_delta_source(mut self, input: crate::types::S3CatalogDeltaSource) -> Self {
self.s3_catalog_delta_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_catalog_delta_source(mut self, input: ::std::option::Option<crate::types::S3CatalogDeltaSource>) -> Self {
self.s3_catalog_delta_source = input;
self
}
pub fn get_s3_catalog_delta_source(&self) -> &::std::option::Option<crate::types::S3CatalogDeltaSource> {
&self.s3_catalog_delta_source
}
pub fn catalog_delta_source(mut self, input: crate::types::CatalogDeltaSource) -> Self {
self.catalog_delta_source = ::std::option::Option::Some(input);
self
}
pub fn set_catalog_delta_source(mut self, input: ::std::option::Option<crate::types::CatalogDeltaSource>) -> Self {
self.catalog_delta_source = input;
self
}
pub fn get_catalog_delta_source(&self) -> &::std::option::Option<crate::types::CatalogDeltaSource> {
&self.catalog_delta_source
}
pub fn s3_delta_source(mut self, input: crate::types::S3DeltaSource) -> Self {
self.s3_delta_source = ::std::option::Option::Some(input);
self
}
pub fn set_s3_delta_source(mut self, input: ::std::option::Option<crate::types::S3DeltaSource>) -> Self {
self.s3_delta_source = input;
self
}
pub fn get_s3_delta_source(&self) -> &::std::option::Option<crate::types::S3DeltaSource> {
&self.s3_delta_source
}
pub fn s3_delta_catalog_target(mut self, input: crate::types::S3DeltaCatalogTarget) -> Self {
self.s3_delta_catalog_target = ::std::option::Option::Some(input);
self
}
pub fn set_s3_delta_catalog_target(mut self, input: ::std::option::Option<crate::types::S3DeltaCatalogTarget>) -> Self {
self.s3_delta_catalog_target = input;
self
}
pub fn get_s3_delta_catalog_target(&self) -> &::std::option::Option<crate::types::S3DeltaCatalogTarget> {
&self.s3_delta_catalog_target
}
pub fn s3_delta_direct_target(mut self, input: crate::types::S3DeltaDirectTarget) -> Self {
self.s3_delta_direct_target = ::std::option::Option::Some(input);
self
}
pub fn set_s3_delta_direct_target(mut self, input: ::std::option::Option<crate::types::S3DeltaDirectTarget>) -> Self {
self.s3_delta_direct_target = input;
self
}
pub fn get_s3_delta_direct_target(&self) -> &::std::option::Option<crate::types::S3DeltaDirectTarget> {
&self.s3_delta_direct_target
}
pub fn amazon_redshift_source(mut self, input: crate::types::AmazonRedshiftSource) -> Self {
self.amazon_redshift_source = ::std::option::Option::Some(input);
self
}
pub fn set_amazon_redshift_source(mut self, input: ::std::option::Option<crate::types::AmazonRedshiftSource>) -> Self {
self.amazon_redshift_source = input;
self
}
pub fn get_amazon_redshift_source(&self) -> &::std::option::Option<crate::types::AmazonRedshiftSource> {
&self.amazon_redshift_source
}
pub fn amazon_redshift_target(mut self, input: crate::types::AmazonRedshiftTarget) -> Self {
self.amazon_redshift_target = ::std::option::Option::Some(input);
self
}
pub fn set_amazon_redshift_target(mut self, input: ::std::option::Option<crate::types::AmazonRedshiftTarget>) -> Self {
self.amazon_redshift_target = input;
self
}
pub fn get_amazon_redshift_target(&self) -> &::std::option::Option<crate::types::AmazonRedshiftTarget> {
&self.amazon_redshift_target
}
pub fn evaluate_data_quality_multi_frame(mut self, input: crate::types::EvaluateDataQualityMultiFrame) -> Self {
self.evaluate_data_quality_multi_frame = ::std::option::Option::Some(input);
self
}
pub fn set_evaluate_data_quality_multi_frame(mut self, input: ::std::option::Option<crate::types::EvaluateDataQualityMultiFrame>) -> Self {
self.evaluate_data_quality_multi_frame = input;
self
}
pub fn get_evaluate_data_quality_multi_frame(&self) -> &::std::option::Option<crate::types::EvaluateDataQualityMultiFrame> {
&self.evaluate_data_quality_multi_frame
}
pub fn recipe(mut self, input: crate::types::Recipe) -> Self {
self.recipe = ::std::option::Option::Some(input);
self
}
pub fn set_recipe(mut self, input: ::std::option::Option<crate::types::Recipe>) -> Self {
self.recipe = input;
self
}
pub fn get_recipe(&self) -> &::std::option::Option<crate::types::Recipe> {
&self.recipe
}
pub fn snowflake_source(mut self, input: crate::types::SnowflakeSource) -> Self {
self.snowflake_source = ::std::option::Option::Some(input);
self
}
pub fn set_snowflake_source(mut self, input: ::std::option::Option<crate::types::SnowflakeSource>) -> Self {
self.snowflake_source = input;
self
}
pub fn get_snowflake_source(&self) -> &::std::option::Option<crate::types::SnowflakeSource> {
&self.snowflake_source
}
pub fn snowflake_target(mut self, input: crate::types::SnowflakeTarget) -> Self {
self.snowflake_target = ::std::option::Option::Some(input);
self
}
pub fn set_snowflake_target(mut self, input: ::std::option::Option<crate::types::SnowflakeTarget>) -> Self {
self.snowflake_target = input;
self
}
pub fn get_snowflake_target(&self) -> &::std::option::Option<crate::types::SnowflakeTarget> {
&self.snowflake_target
}
pub fn connector_data_source(mut self, input: crate::types::ConnectorDataSource) -> Self {
self.connector_data_source = ::std::option::Option::Some(input);
self
}
pub fn set_connector_data_source(mut self, input: ::std::option::Option<crate::types::ConnectorDataSource>) -> Self {
self.connector_data_source = input;
self
}
pub fn get_connector_data_source(&self) -> &::std::option::Option<crate::types::ConnectorDataSource> {
&self.connector_data_source
}
pub fn connector_data_target(mut self, input: crate::types::ConnectorDataTarget) -> Self {
self.connector_data_target = ::std::option::Option::Some(input);
self
}
pub fn set_connector_data_target(mut self, input: ::std::option::Option<crate::types::ConnectorDataTarget>) -> Self {
self.connector_data_target = input;
self
}
pub fn get_connector_data_target(&self) -> &::std::option::Option<crate::types::ConnectorDataTarget> {
&self.connector_data_target
}
pub fn build(self) -> crate::types::CodeGenConfigurationNode {
crate::types::CodeGenConfigurationNode {
athena_connector_source: self.athena_connector_source,
jdbc_connector_source: self.jdbc_connector_source,
spark_connector_source: self.spark_connector_source,
catalog_source: self.catalog_source,
redshift_source: self.redshift_source,
s3_catalog_source: self.s3_catalog_source,
s3_csv_source: self.s3_csv_source,
s3_json_source: self.s3_json_source,
s3_parquet_source: self.s3_parquet_source,
relational_catalog_source: self.relational_catalog_source,
dynamo_db_catalog_source: self.dynamo_db_catalog_source,
jdbc_connector_target: self.jdbc_connector_target,
spark_connector_target: self.spark_connector_target,
catalog_target: self.catalog_target,
redshift_target: self.redshift_target,
s3_catalog_target: self.s3_catalog_target,
s3_glue_parquet_target: self.s3_glue_parquet_target,
s3_direct_target: self.s3_direct_target,
apply_mapping: self.apply_mapping,
select_fields: self.select_fields,
drop_fields: self.drop_fields,
rename_field: self.rename_field,
spigot: self.spigot,
join: self.join,
split_fields: self.split_fields,
select_from_collection: self.select_from_collection,
fill_missing_values: self.fill_missing_values,
filter: self.filter,
custom_code: self.custom_code,
spark_sql: self.spark_sql,
direct_kinesis_source: self.direct_kinesis_source,
direct_kafka_source: self.direct_kafka_source,
catalog_kinesis_source: self.catalog_kinesis_source,
catalog_kafka_source: self.catalog_kafka_source,
drop_null_fields: self.drop_null_fields,
merge: self.merge,
union: self.union,
pii_detection: self.pii_detection,
aggregate: self.aggregate,
drop_duplicates: self.drop_duplicates,
governed_catalog_target: self.governed_catalog_target,
governed_catalog_source: self.governed_catalog_source,
microsoft_sql_server_catalog_source: self.microsoft_sql_server_catalog_source,
my_sql_catalog_source: self.my_sql_catalog_source,
oracle_sql_catalog_source: self.oracle_sql_catalog_source,
postgre_sql_catalog_source: self.postgre_sql_catalog_source,
microsoft_sql_server_catalog_target: self.microsoft_sql_server_catalog_target,
my_sql_catalog_target: self.my_sql_catalog_target,
oracle_sql_catalog_target: self.oracle_sql_catalog_target,
postgre_sql_catalog_target: self.postgre_sql_catalog_target,
dynamic_transform: self.dynamic_transform,
evaluate_data_quality: self.evaluate_data_quality,
s3_catalog_hudi_source: self.s3_catalog_hudi_source,
catalog_hudi_source: self.catalog_hudi_source,
s3_hudi_source: self.s3_hudi_source,
s3_hudi_catalog_target: self.s3_hudi_catalog_target,
s3_hudi_direct_target: self.s3_hudi_direct_target,
direct_jdbc_source: self.direct_jdbc_source,
s3_catalog_delta_source: self.s3_catalog_delta_source,
catalog_delta_source: self.catalog_delta_source,
s3_delta_source: self.s3_delta_source,
s3_delta_catalog_target: self.s3_delta_catalog_target,
s3_delta_direct_target: self.s3_delta_direct_target,
amazon_redshift_source: self.amazon_redshift_source,
amazon_redshift_target: self.amazon_redshift_target,
evaluate_data_quality_multi_frame: self.evaluate_data_quality_multi_frame,
recipe: self.recipe,
snowflake_source: self.snowflake_source,
snowflake_target: self.snowflake_target,
connector_data_source: self.connector_data_source,
connector_data_target: self.connector_data_target,
}
}
}