Struct aws_sdk_glue::Client

source · [−]

pub struct Client { /* private fields */ }

Expand description

Client for AWS Glue

Client for invoking operations on AWS Glue. Each operation on AWS Glue is a method on this this struct. .send() MUST be invoked on the generated operations to dispatch the request to the service.

Examples

Constructing a client and invoking an operation

    // create a shared configuration. This can be used & shared between multiple service clients.
    let shared_config = aws_config::load_from_env().await;
    let client = aws_sdk_glue::Client::new(&shared_config);
    // invoke an operation
    /* let rsp = client
        .<operation_name>().
        .<param>("some value")
        .send().await; */

Constructing a client with custom configuration

use aws_config::RetryConfig;
let shared_config = aws_config::load_from_env().await;
let config = aws_sdk_glue::config::Builder::from(&shared_config)
  .retry_config(RetryConfig::disabled())
  .build();
let client = aws_sdk_glue::Client::from_conf(config);

Implementations

source

impl Client

source

pub fn with_config(
client: Client<DynConnector, DynMiddleware<DynConnector>>,
conf: Config
) -> Self

Creates a client with the given service configuration.

source

pub fn conf(&self) -> &Config

Returns the client’s configuration.

source

impl Client

source

pub fn batch_create_partition(&self) -> BatchCreatePartition

Constructs a fluent builder for the BatchCreatePartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the catalog in which the partition is to be created. Currently, this should be the Amazon Web Services account ID.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the metadata database in which the partition is to be created.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the metadata table in which the partition is to be created.
- partition_input_list(Vec<PartitionInput>) / set_partition_input_list(Option<Vec<PartitionInput>>):
  A list of PartitionInput structures that define the partitions to be created.
On success, responds with BatchCreatePartitionOutput with field(s):
- errors(Option<Vec<PartitionError>>):
  The errors encountered when trying to create the requested partitions.
On failure, responds with SdkError<BatchCreatePartitionError>

source

pub fn batch_delete_connection(&self) -> BatchDeleteConnection

Constructs a fluent builder for the BatchDeleteConnection operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the connections reside. If none is provided, the Amazon Web Services account ID is used by default.
- connection_name_list(Vec<String>) / set_connection_name_list(Option<Vec<String>>):
  A list of names of the connections to delete.
On success, responds with BatchDeleteConnectionOutput with field(s):
- succeeded(Option<Vec<String>>):
  A list of names of the connection definitions that were successfully deleted.
- errors(Option<HashMap<String, ErrorDetail>>):
  A map of the names of connections that were not successfully deleted to error details.
On failure, responds with SdkError<BatchDeleteConnectionError>

source

pub fn batch_delete_partition(&self) -> BatchDeletePartition

Constructs a fluent builder for the BatchDeletePartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partition to be deleted resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database in which the table in question resides.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the table that contains the partitions to be deleted.
- partitions_to_delete(Vec<PartitionValueList>) / set_partitions_to_delete(Option<Vec<PartitionValueList>>):
  A list of PartitionInput structures that define the partitions to be deleted.
On success, responds with BatchDeletePartitionOutput with field(s):
- errors(Option<Vec<PartitionError>>):
  The errors encountered when trying to delete the requested partitions.
On failure, responds with SdkError<BatchDeletePartitionError>

source

pub fn batch_delete_table(&self) -> BatchDeleteTable

Constructs a fluent builder for the BatchDeleteTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the table resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database in which the tables to delete reside. For Hive compatibility, this name is entirely lowercase.
- tables_to_delete(Vec<String>) / set_tables_to_delete(Option<Vec<String>>):
  A list of the table to delete.
- transaction_id(impl Into<String>) / set_transaction_id(Option<String>):
  The transaction ID at which to delete the table contents.
On success, responds with BatchDeleteTableOutput with field(s):
- errors(Option<Vec<TableError>>):
  A list of errors encountered in attempting to delete the specified tables.
On failure, responds with SdkError<BatchDeleteTableError>

source

pub fn batch_delete_table_version(&self) -> BatchDeleteTableVersion

Constructs a fluent builder for the BatchDeleteTableVersion operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the tables reside. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the table. For Hive compatibility, this name is entirely lowercase.
- version_ids(Vec<String>) / set_version_ids(Option<Vec<String>>):
  A list of the IDs of versions to be deleted. A VersionId is a string representation of an integer. Each version is incremented by 1.
On success, responds with BatchDeleteTableVersionOutput with field(s):
- errors(Option<Vec<TableVersionError>>):
  A list of errors encountered while trying to delete the specified table versions.
On failure, responds with SdkError<BatchDeleteTableVersionError>

source

pub fn batch_get_blueprints(&self) -> BatchGetBlueprints

Constructs a fluent builder for the BatchGetBlueprints operation.

The fluent builder is configurable:
- names(Vec<String>) / set_names(Option<Vec<String>>):
  A list of blueprint names.
- include_blueprint(bool) / set_include_blueprint(Option<bool>):
  Specifies whether or not to include the blueprint in the response.
- include_parameter_spec(bool) / set_include_parameter_spec(Option<bool>):
  Specifies whether or not to include the parameters, as a JSON string, for the blueprint in the response.
On success, responds with BatchGetBlueprintsOutput with field(s):
- blueprints(Option<Vec<Blueprint>>):
  Returns a list of blueprint as a Blueprints object.
- missing_blueprints(Option<Vec<String>>):
  Returns a list of BlueprintNames that were not found.
On failure, responds with SdkError<BatchGetBlueprintsError>

source

pub fn batch_get_crawlers(&self) -> BatchGetCrawlers

Constructs a fluent builder for the BatchGetCrawlers operation.

The fluent builder is configurable:
- crawler_names(Vec<String>) / set_crawler_names(Option<Vec<String>>):
  A list of crawler names, which might be the names returned from the ListCrawlers operation.
On success, responds with BatchGetCrawlersOutput with field(s):
- crawlers(Option<Vec<Crawler>>):
  A list of crawler definitions.
- crawlers_not_found(Option<Vec<String>>):
  A list of names of crawlers that were not found.
On failure, responds with SdkError<BatchGetCrawlersError>

source

pub fn batch_get_custom_entity_types(&self) -> BatchGetCustomEntityTypes

Constructs a fluent builder for the BatchGetCustomEntityTypes operation.

The fluent builder is configurable:
- names(Vec<String>) / set_names(Option<Vec<String>>):
  A list of names of the custom patterns that you want to retrieve.
On success, responds with BatchGetCustomEntityTypesOutput with field(s):
- custom_entity_types(Option<Vec<CustomEntityType>>):
  A list of CustomEntityType objects representing the custom patterns that have been created.
- custom_entity_types_not_found(Option<Vec<String>>):
  A list of the names of custom patterns that were not found.
On failure, responds with SdkError<BatchGetCustomEntityTypesError>

source

pub fn batch_get_dev_endpoints(&self) -> BatchGetDevEndpoints

Constructs a fluent builder for the BatchGetDevEndpoints operation.

The fluent builder is configurable:
- dev_endpoint_names(Vec<String>) / set_dev_endpoint_names(Option<Vec<String>>):
  The list of DevEndpoint names, which might be the names returned from the ListDevEndpoint operation.
On success, responds with BatchGetDevEndpointsOutput with field(s):
- dev_endpoints(Option<Vec<DevEndpoint>>):
  A list of DevEndpoint definitions.
- dev_endpoints_not_found(Option<Vec<String>>):
  A list of DevEndpoints not found.
On failure, responds with SdkError<BatchGetDevEndpointsError>

source

pub fn batch_get_jobs(&self) -> BatchGetJobs

Constructs a fluent builder for the BatchGetJobs operation.

The fluent builder is configurable:
- job_names(Vec<String>) / set_job_names(Option<Vec<String>>):
  A list of job names, which might be the names returned from the ListJobs operation.
On success, responds with BatchGetJobsOutput with field(s):
- jobs(Option<Vec<Job>>):
  A list of job definitions.
- jobs_not_found(Option<Vec<String>>):
  A list of names of jobs not found.
On failure, responds with SdkError<BatchGetJobsError>

source

pub fn batch_get_partition(&self) -> BatchGetPartition

Constructs a fluent builder for the BatchGetPartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- partitions_to_get(Vec<PartitionValueList>) / set_partitions_to_get(Option<Vec<PartitionValueList>>):
  A list of partition values identifying the partitions to retrieve.
On success, responds with BatchGetPartitionOutput with field(s):
- partitions(Option<Vec<Partition>>):
  A list of the requested partitions.
- unprocessed_keys(Option<Vec<PartitionValueList>>):
  A list of the partition values in the request for which partitions were not returned.
On failure, responds with SdkError<BatchGetPartitionError>

source

pub fn batch_get_triggers(&self) -> BatchGetTriggers

Constructs a fluent builder for the BatchGetTriggers operation.

The fluent builder is configurable:
- trigger_names(Vec<String>) / set_trigger_names(Option<Vec<String>>):
  A list of trigger names, which may be the names returned from the ListTriggers operation.
On success, responds with BatchGetTriggersOutput with field(s):
- triggers(Option<Vec<Trigger>>):
  A list of trigger definitions.
- triggers_not_found(Option<Vec<String>>):
  A list of names of triggers not found.
On failure, responds with SdkError<BatchGetTriggersError>

source

pub fn batch_get_workflows(&self) -> BatchGetWorkflows

Constructs a fluent builder for the BatchGetWorkflows operation.

The fluent builder is configurable:
- names(Vec<String>) / set_names(Option<Vec<String>>):
  A list of workflow names, which may be the names returned from the ListWorkflows operation.
- include_graph(bool) / set_include_graph(Option<bool>):
  Specifies whether to include a graph when returning the workflow resource metadata.
On success, responds with BatchGetWorkflowsOutput with field(s):
- workflows(Option<Vec<Workflow>>):
  A list of workflow resource metadata.
- missing_workflows(Option<Vec<String>>):
  A list of names of workflows not found.
On failure, responds with SdkError<BatchGetWorkflowsError>

source

pub fn batch_stop_job_run(&self) -> BatchStopJobRun

Constructs a fluent builder for the BatchStopJobRun operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job definition for which to stop job runs.
- job_run_ids(Vec<String>) / set_job_run_ids(Option<Vec<String>>):
  A list of the JobRunIds that should be stopped for that job definition.
On success, responds with BatchStopJobRunOutput with field(s):
- successful_submissions(Option<Vec<BatchStopJobRunSuccessfulSubmission>>):
  A list of the JobRuns that were successfully submitted for stopping.
- errors(Option<Vec<BatchStopJobRunError>>):
  A list of the errors that were encountered in trying to stop JobRuns, including the JobRunId for which each error was encountered and details about the error.
On failure, responds with SdkError<BatchStopJobRunError>

source

pub fn batch_update_partition(&self) -> BatchUpdatePartition

Constructs a fluent builder for the BatchUpdatePartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the catalog in which the partition is to be updated. Currently, this should be the Amazon Web Services account ID.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the metadata database in which the partition is to be updated.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the metadata table in which the partition is to be updated.
- entries(Vec<BatchUpdatePartitionRequestEntry>) / set_entries(Option<Vec<BatchUpdatePartitionRequestEntry>>):
  A list of up to 100 BatchUpdatePartitionRequestEntry objects to update.
On success, responds with BatchUpdatePartitionOutput with field(s):
- errors(Option<Vec<BatchUpdatePartitionFailureEntry>>):
  The errors encountered when trying to update the requested partitions. A list of BatchUpdatePartitionFailureEntry objects.
On failure, responds with SdkError<BatchUpdatePartitionError>

source

pub fn cancel_ml_task_run(&self) -> CancelMLTaskRun

Constructs a fluent builder for the CancelMLTaskRun operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the machine learning transform.
- task_run_id(impl Into<String>) / set_task_run_id(Option<String>):
  A unique identifier for the task run.
On success, responds with CancelMlTaskRunOutput with field(s):
- transform_id(Option<String>):
  The unique identifier of the machine learning transform.
- task_run_id(Option<String>):
  The unique identifier for the task run.
- status(Option<TaskStatusType>):
  The status for this run.
On failure, responds with SdkError<CancelMLTaskRunError>

source

pub fn cancel_statement(&self) -> CancelStatement

Constructs a fluent builder for the CancelStatement operation.

The fluent builder is configurable:
- session_id(impl Into<String>) / set_session_id(Option<String>):
  The Session ID of the statement to be cancelled.
- id(i32) / set_id(i32):
  The ID of the statement to be cancelled.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request to cancel the statement.
On success, responds with CancelStatementOutput
On failure, responds with SdkError<CancelStatementError>

source

pub fn check_schema_version_validity(&self) -> CheckSchemaVersionValidity

Constructs a fluent builder for the CheckSchemaVersionValidity operation.

The fluent builder is configurable:
- data_format(DataFormat) / set_data_format(Option<DataFormat>):
  The data format of the schema definition. Currently AVRO, JSON and PROTOBUF are supported.
- schema_definition(impl Into<String>) / set_schema_definition(Option<String>):
  The definition of the schema that has to be validated.
On success, responds with CheckSchemaVersionValidityOutput with field(s):
- valid(bool):
  Return true, if the schema is valid and false otherwise.
- error(Option<String>):
  A validation failure error message.
On failure, responds with SdkError<CheckSchemaVersionValidityError>

source

pub fn create_blueprint(&self) -> CreateBlueprint

Constructs a fluent builder for the CreateBlueprint operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the blueprint.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the blueprint.
- blueprint_location(impl Into<String>) / set_blueprint_location(Option<String>):
  Specifies a path in Amazon S3 where the blueprint is published.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags to be applied to this blueprint.
On success, responds with CreateBlueprintOutput with field(s):
- name(Option<String>):
  Returns the name of the blueprint that was registered.
On failure, responds with SdkError<CreateBlueprintError>

source

pub fn create_classifier(&self) -> CreateClassifier

Constructs a fluent builder for the CreateClassifier operation.

The fluent builder is configurable:
- grok_classifier(CreateGrokClassifierRequest) / set_grok_classifier(Option<CreateGrokClassifierRequest>):
  A GrokClassifier object specifying the classifier to create.
- xml_classifier(CreateXmlClassifierRequest) / set_xml_classifier(Option<CreateXmlClassifierRequest>):
  An XMLClassifier object specifying the classifier to create.
- json_classifier(CreateJsonClassifierRequest) / set_json_classifier(Option<CreateJsonClassifierRequest>):
  A JsonClassifier object specifying the classifier to create.
- csv_classifier(CreateCsvClassifierRequest) / set_csv_classifier(Option<CreateCsvClassifierRequest>):
  A CsvClassifier object specifying the classifier to create.
On success, responds with CreateClassifierOutput
On failure, responds with SdkError<CreateClassifierError>

source

pub fn create_connection(&self) -> CreateConnection

Constructs a fluent builder for the CreateConnection operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which to create the connection. If none is provided, the Amazon Web Services account ID is used by default.
- connection_input(ConnectionInput) / set_connection_input(Option<ConnectionInput>):
  A ConnectionInput object defining the connection to create.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags you assign to the connection.
On success, responds with CreateConnectionOutput
On failure, responds with SdkError<CreateConnectionError>

source

pub fn create_crawler(&self) -> CreateCrawler

Constructs a fluent builder for the CreateCrawler operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the new crawler.
- role(impl Into<String>) / set_role(Option<String>):
  The IAM role or Amazon Resource Name (ARN) of an IAM role used by the new crawler to access customer resources.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The Glue database where results are written, such as: arn:aws:daylight:us-east-1::database/sometable/*.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the new crawler.
- targets(CrawlerTargets) / set_targets(Option<CrawlerTargets>):
  A list of collection of targets to crawl.
- schedule(impl Into<String>) / set_schedule(Option<String>):
  A cron expression used to specify the schedule (see Time-Based Schedules for Jobs and Crawlers. For example, to run something every day at 12:15 UTC, you would specify: cron(15 12 * * ? *).
- classifiers(Vec<String>) / set_classifiers(Option<Vec<String>>):
  A list of custom classifiers that the user has registered. By default, all built-in classifiers are included in a crawl, but these custom classifiers always override the default classifiers for a given classification.
- table_prefix(impl Into<String>) / set_table_prefix(Option<String>):
  The table prefix used for catalog tables that are created.
- schema_change_policy(SchemaChangePolicy) / set_schema_change_policy(Option<SchemaChangePolicy>):
  The policy for the crawler’s update and deletion behavior.
- recrawl_policy(RecrawlPolicy) / set_recrawl_policy(Option<RecrawlPolicy>):
  A policy that specifies whether to crawl the entire dataset again, or to crawl only folders that were added since the last crawler run.
- lineage_configuration(LineageConfiguration) / set_lineage_configuration(Option<LineageConfiguration>):
  Specifies data lineage configuration settings for the crawler.
- lake_formation_configuration(LakeFormationConfiguration) / set_lake_formation_configuration(Option<LakeFormationConfiguration>):
  Specifies AWS Lake Formation configuration settings for the crawler.
- configuration(impl Into<String>) / set_configuration(Option<String>):
  Crawler configuration information. This versioned JSON string allows users to specify aspects of a crawler’s behavior. For more information, see Configuring a Crawler.
- crawler_security_configuration(impl Into<String>) / set_crawler_security_configuration(Option<String>):
  The name of the SecurityConfiguration structure to be used by this crawler.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags to use with this crawler request. You may use tags to limit access to the crawler. For more information about tags in Glue, see Amazon Web Services Tags in Glue in the developer guide.
On success, responds with CreateCrawlerOutput
On failure, responds with SdkError<CreateCrawlerError>

source

pub fn create_custom_entity_type(&self) -> CreateCustomEntityType

Constructs a fluent builder for the CreateCustomEntityType operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  A name for the custom pattern that allows it to be retrieved or deleted later. This name must be unique per Amazon Web Services account.
- regex_string(impl Into<String>) / set_regex_string(Option<String>):
  A regular expression string that is used for detecting sensitive data in a custom pattern.
- context_words(Vec<String>) / set_context_words(Option<Vec<String>>):
  A list of context words. If none of these context words are found within the vicinity of the regular expression the data will not be detected as sensitive data.
  
  If no context words are passed only a regular expression is checked.
On success, responds with CreateCustomEntityTypeOutput with field(s):
- name(Option<String>):
  The name of the custom pattern you created.
On failure, responds with SdkError<CreateCustomEntityTypeError>

source

pub fn create_database(&self) -> CreateDatabase

Constructs a fluent builder for the CreateDatabase operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which to create the database. If none is provided, the Amazon Web Services account ID is used by default.
- database_input(DatabaseInput) / set_database_input(Option<DatabaseInput>):
  The metadata for the database.
On success, responds with CreateDatabaseOutput
On failure, responds with SdkError<CreateDatabaseError>

source

pub fn create_dev_endpoint(&self) -> CreateDevEndpoint

Constructs a fluent builder for the CreateDevEndpoint operation.

The fluent builder is configurable:
- endpoint_name(impl Into<String>) / set_endpoint_name(Option<String>):
  The name to be assigned to the new DevEndpoint.
- role_arn(impl Into<String>) / set_role_arn(Option<String>):
  The IAM role for the DevEndpoint.
- security_group_ids(Vec<String>) / set_security_group_ids(Option<Vec<String>>):
  Security group IDs for the security groups to be used by the new DevEndpoint.
- subnet_id(impl Into<String>) / set_subnet_id(Option<String>):
  The subnet ID for the new DevEndpoint to use.
- public_key(impl Into<String>) / set_public_key(Option<String>):
  The public key to be used by this DevEndpoint for authentication. This attribute is provided for backward compatibility because the recommended attribute to use is public keys.
- public_keys(Vec<String>) / set_public_keys(Option<Vec<String>>):
  A list of public keys to be used by the development endpoints for authentication. The use of this attribute is preferred over a single public key because the public keys allow you to have a different private key per client.
  
  If you previously created an endpoint with a public key, you must remove that key to be able to set a list of public keys. Call the UpdateDevEndpoint API with the public key content in the deletePublicKeys attribute, and the list of new keys in the addPublicKeys attribute.
- number_of_nodes(i32) / set_number_of_nodes(i32):
  The number of Glue Data Processing Units (DPUs) to allocate to this DevEndpoint.
- worker_type(WorkerType) / set_worker_type(Option<WorkerType>):
  The type of predefined worker that is allocated to the development endpoint. Accepts a value of Standard, G.1X, or G.2X.
  - For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.
  - For the G.1X worker type, each worker maps to 1 DPU (4 vCPU, 16 GB of memory, 64 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.
  - For the G.2X worker type, each worker maps to 2 DPU (8 vCPU, 32 GB of memory, 128 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.
  Known issue: when a development endpoint is created with the G.2X WorkerType configuration, the Spark drivers for the development endpoint will run on 4 vCPU, 16 GB of memory, and a 64 GB disk.
- glue_version(impl Into<String>) / set_glue_version(Option<String>):
  Glue version determines the versions of Apache Spark and Python that Glue supports. The Python version indicates the version supported for running your ETL scripts on development endpoints.
  
  For more information about the available Glue versions and corresponding Spark and Python versions, see Glue version in the developer guide.
  
  Development endpoints that are created without specifying a Glue version default to Glue 0.9.
  
  You can specify a version of Python support for development endpoints by using the Arguments parameter in the CreateDevEndpoint or UpdateDevEndpoint APIs. If no arguments are provided, the version defaults to Python 2.
- number_of_workers(i32) / set_number_of_workers(Option<i32>):
  The number of workers of a defined workerType that are allocated to the development endpoint.
  
  The maximum number of workers you can define are 299 for G.1X, and 149 for G.2X.
- extra_python_libs_s3_path(impl Into<String>) / set_extra_python_libs_s3_path(Option<String>):
  The paths to one or more Python libraries in an Amazon S3 bucket that should be loaded in your DevEndpoint. Multiple values must be complete paths separated by a comma.
  
  You can only use pure Python libraries with a DevEndpoint. Libraries that rely on C extensions, such as the pandas Python data analysis library, are not yet supported.
- extra_jars_s3_path(impl Into<String>) / set_extra_jars_s3_path(Option<String>):
  The path to one or more Java .jar files in an S3 bucket that should be loaded in your DevEndpoint.
- security_configuration(impl Into<String>) / set_security_configuration(Option<String>):
  The name of the SecurityConfiguration structure to be used with this DevEndpoint.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags to use with this DevEndpoint. You may use tags to limit access to the DevEndpoint. For more information about tags in Glue, see Amazon Web Services Tags in Glue in the developer guide.
- arguments(HashMap<String, String>) / set_arguments(Option<HashMap<String, String>>):
  A map of arguments used to configure the DevEndpoint.
On success, responds with CreateDevEndpointOutput with field(s):
- endpoint_name(Option<String>):
  The name assigned to the new DevEndpoint.
- status(Option<String>):
  The current status of the new DevEndpoint.
- security_group_ids(Option<Vec<String>>):
  The security groups assigned to the new DevEndpoint.
- subnet_id(Option<String>):
  The subnet ID assigned to the new DevEndpoint.
- role_arn(Option<String>):
  The Amazon Resource Name (ARN) of the role assigned to the new DevEndpoint.
- yarn_endpoint_address(Option<String>):
  The address of the YARN endpoint used by this DevEndpoint.
- zeppelin_remote_spark_interpreter_port(i32):
  The Apache Zeppelin port for the remote Apache Spark interpreter.
- number_of_nodes(i32):
  The number of Glue Data Processing Units (DPUs) allocated to this DevEndpoint.
- worker_type(Option<WorkerType>):
  The type of predefined worker that is allocated to the development endpoint. May be a value of Standard, G.1X, or G.2X.
- glue_version(Option<String>):
  Glue version determines the versions of Apache Spark and Python that Glue supports. The Python version indicates the version supported for running your ETL scripts on development endpoints.
  
  For more information about the available Glue versions and corresponding Spark and Python versions, see Glue version in the developer guide.
- number_of_workers(Option<i32>):
  The number of workers of a defined workerType that are allocated to the development endpoint.
- availability_zone(Option<String>):
  The AWS Availability Zone where this DevEndpoint is located.
- vpc_id(Option<String>):
  The ID of the virtual private cloud (VPC) used by this DevEndpoint.
- extra_python_libs_s3_path(Option<String>):
  The paths to one or more Python libraries in an S3 bucket that will be loaded in your DevEndpoint.
- extra_jars_s3_path(Option<String>):
  Path to one or more Java .jar files in an S3 bucket that will be loaded in your DevEndpoint.
- failure_reason(Option<String>):
  The reason for a current failure in this DevEndpoint.
- security_configuration(Option<String>):
  The name of the SecurityConfiguration structure being used with this DevEndpoint.
- created_timestamp(Option<DateTime>):
  The point in time at which this DevEndpoint was created.
- arguments(Option<HashMap<String, String>>):
  The map of arguments used to configure this DevEndpoint.
  
  Valid arguments are:
  - “–enable-glue-datacatalog”: “”
  You can specify a version of Python support for development endpoints by using the Arguments parameter in the CreateDevEndpoint or UpdateDevEndpoint APIs. If no arguments are provided, the version defaults to Python 2.
On failure, responds with SdkError<CreateDevEndpointError>

source

pub fn create_job(&self) -> CreateJob

Constructs a fluent builder for the CreateJob operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name you assign to this job definition. It must be unique in your account.
- description(impl Into<String>) / set_description(Option<String>):
  Description of the job being defined.
- log_uri(impl Into<String>) / set_log_uri(Option<String>):
  This field is reserved for future use.
- role(impl Into<String>) / set_role(Option<String>):
  The name or Amazon Resource Name (ARN) of the IAM role associated with this job.
- execution_property(ExecutionProperty) / set_execution_property(Option<ExecutionProperty>):
  An ExecutionProperty specifying the maximum number of concurrent runs allowed for this job.
- command(JobCommand) / set_command(Option<JobCommand>):
  The JobCommand that runs this job.
- default_arguments(HashMap<String, String>) / set_default_arguments(Option<HashMap<String, String>>):
  The default arguments for this job.
  
  You can specify arguments here that your own job-execution script consumes, as well as arguments that Glue itself consumes.
  
  For information about how to specify and consume your own Job arguments, see the Calling Glue APIs in Python topic in the developer guide.
  
  For information about the key-value pairs that Glue consumes to set up your job, see the Special Parameters Used by Glue topic in the developer guide.
- non_overridable_arguments(HashMap<String, String>) / set_non_overridable_arguments(Option<HashMap<String, String>>):
  Non-overridable arguments for this job, specified as name-value pairs.
- connections(ConnectionsList) / set_connections(Option<ConnectionsList>):
  The connections used for this job.
- max_retries(i32) / set_max_retries(i32):
  The maximum number of times to retry this job if it fails.
- allocated_capacity(i32) / set_allocated_capacity(i32):
  This parameter is deprecated. Use MaxCapacity instead.
  
  The number of Glue data processing units (DPUs) to allocate to this Job. You can allocate from 2 to 100 DPUs; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory. For more information, see the Glue pricing page.
- timeout(i32) / set_timeout(Option<i32>):
  The job timeout in minutes. This is the maximum time that a job run can consume resources before it is terminated and enters TIMEOUT status. The default is 2,880 minutes (48 hours).
- max_capacity(f64) / set_max_capacity(Option<f64>):
  For Glue version 1.0 or earlier jobs, using the standard worker type, the number of Glue data processing units (DPUs) that can be allocated when this job runs. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory. For more information, see the Glue pricing page.
  
  Do not set Max Capacity if using WorkerType and NumberOfWorkers.
  
  The value that can be allocated for MaxCapacity depends on whether you are running a Python shell job or an Apache Spark ETL job:
  - When you specify a Python shell job (JobCommand.Name=“pythonshell”), you can allocate either 0.0625 or 1 DPU. The default is 0.0625 DPU.
  - When you specify an Apache Spark ETL job (JobCommand.Name=“glueetl”) or Apache Spark streaming ETL job (JobCommand.Name=“gluestreaming”), you can allocate from 2 to 100 DPUs. The default is 10 DPUs. This job type cannot have a fractional DPU allocation.
  For Glue version 2.0 jobs, you cannot instead specify a Maximum capacity. Instead, you should specify a Worker type and the Number of workers.
- security_configuration(impl Into<String>) / set_security_configuration(Option<String>):
  The name of the SecurityConfiguration structure to be used with this job.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags to use with this job. You may use tags to limit access to the job. For more information about tags in Glue, see Amazon Web Services Tags in Glue in the developer guide.
- notification_property(NotificationProperty) / set_notification_property(Option<NotificationProperty>):
  Specifies configuration properties of a job notification.
- glue_version(impl Into<String>) / set_glue_version(Option<String>):
  Glue version determines the versions of Apache Spark and Python that Glue supports. The Python version indicates the version supported for jobs of type Spark.
  
  For more information about the available Glue versions and corresponding Spark and Python versions, see Glue version in the developer guide.
  
  Jobs that are created without specifying a Glue version default to Glue 0.9.
- number_of_workers(i32) / set_number_of_workers(Option<i32>):
  The number of workers of a defined workerType that are allocated when a job runs.
  
  The maximum number of workers you can define are 299 for G.1X, and 149 for G.2X.
- worker_type(WorkerType) / set_worker_type(Option<WorkerType>):
  The type of predefined worker that is allocated when a job runs. Accepts a value of Standard, G.1X, or G.2X.
  - For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.
  - For the G.1X worker type, each worker maps to 1 DPU (4 vCPU, 16 GB of memory, 64 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.
  - For the G.2X worker type, each worker maps to 2 DPU (8 vCPU, 32 GB of memory, 128 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.
- code_gen_configuration_nodes(HashMap<String, CodeGenConfigurationNode>) / set_code_gen_configuration_nodes(Option<HashMap<String, CodeGenConfigurationNode>>):
  The representation of a directed acyclic graph on which both the Glue Studio visual component and Glue Studio code generation is based.
On success, responds with CreateJobOutput with field(s):
- name(Option<String>):
  The unique name that was provided for this job definition.
On failure, responds with SdkError<CreateJobError>

source

pub fn create_ml_transform(&self) -> CreateMLTransform

Constructs a fluent builder for the CreateMLTransform operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The unique name that you give the transform when you create it.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the machine learning transform that is being defined. The default is an empty string.
- input_record_tables(Vec<GlueTable>) / set_input_record_tables(Option<Vec<GlueTable>>):
  A list of Glue table definitions used by the transform.
- parameters(TransformParameters) / set_parameters(Option<TransformParameters>):
  The algorithmic parameters that are specific to the transform type used. Conditionally dependent on the transform type.
- role(impl Into<String>) / set_role(Option<String>):
  The name or Amazon Resource Name (ARN) of the IAM role with the required permissions. The required permissions include both Glue service role permissions to Glue resources, and Amazon S3 permissions required by the transform.
  - This role needs Glue service role permissions to allow access to resources in Glue. See Attach a Policy to IAM Users That Access Glue.
  - This role needs permission to your Amazon Simple Storage Service (Amazon S3) sources, targets, temporary directory, scripts, and any libraries used by the task run for this transform.
- glue_version(impl Into<String>) / set_glue_version(Option<String>):
  This value determines which version of Glue this machine learning transform is compatible with. Glue 1.0 is recommended for most customers. If the value is not set, the Glue compatibility defaults to Glue 0.9. For more information, see Glue Versions in the developer guide.
- max_capacity(f64) / set_max_capacity(Option<f64>):
  The number of Glue data processing units (DPUs) that are allocated to task runs for this transform. You can allocate from 2 to 100 DPUs; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory. For more information, see the Glue pricing page.
  
  MaxCapacity is a mutually exclusive option with NumberOfWorkers and WorkerType.
  - If either NumberOfWorkers or WorkerType is set, then MaxCapacity cannot be set.
  - If MaxCapacity is set then neither NumberOfWorkers or WorkerType can be set.
  - If WorkerType is set, then NumberOfWorkers is required (and vice versa).
  - MaxCapacity and NumberOfWorkers must both be at least 1.
  When the WorkerType field is set to a value other than Standard, the MaxCapacity field is set automatically and becomes read-only.
  
  When the WorkerType field is set to a value other than Standard, the MaxCapacity field is set automatically and becomes read-only.
- worker_type(WorkerType) / set_worker_type(Option<WorkerType>):
  The type of predefined worker that is allocated when this task runs. Accepts a value of Standard, G.1X, or G.2X.
  - For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.
  - For the G.1X worker type, each worker provides 4 vCPU, 16 GB of memory and a 64GB disk, and 1 executor per worker.
  - For the G.2X worker type, each worker provides 8 vCPU, 32 GB of memory and a 128GB disk, and 1 executor per worker.
  MaxCapacity is a mutually exclusive option with NumberOfWorkers and WorkerType.
  - If either NumberOfWorkers or WorkerType is set, then MaxCapacity cannot be set.
  - If MaxCapacity is set then neither NumberOfWorkers or WorkerType can be set.
  - If WorkerType is set, then NumberOfWorkers is required (and vice versa).
  - MaxCapacity and NumberOfWorkers must both be at least 1.
- number_of_workers(i32) / set_number_of_workers(Option<i32>):
  The number of workers of a defined workerType that are allocated when this task runs.
  
  If WorkerType is set, then NumberOfWorkers is required (and vice versa).
- timeout(i32) / set_timeout(Option<i32>):
  The timeout of the task run for this transform in minutes. This is the maximum time that a task run for this transform can consume resources before it is terminated and enters TIMEOUT status. The default is 2,880 minutes (48 hours).
- max_retries(i32) / set_max_retries(Option<i32>):
  The maximum number of times to retry a task for this transform after a task run fails.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags to use with this machine learning transform. You may use tags to limit access to the machine learning transform. For more information about tags in Glue, see Amazon Web Services Tags in Glue in the developer guide.
- transform_encryption(TransformEncryption) / set_transform_encryption(Option<TransformEncryption>):
  The encryption-at-rest settings of the transform that apply to accessing user data. Machine learning transforms can access user data encrypted in Amazon S3 using KMS.
On success, responds with CreateMlTransformOutput with field(s):
- transform_id(Option<String>):
  A unique identifier that is generated for the transform.
On failure, responds with SdkError<CreateMLTransformError>

source

pub fn create_partition(&self) -> CreatePartition

Constructs a fluent builder for the CreatePartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The Amazon Web Services account ID of the catalog in which the partition is to be created.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the metadata database in which the partition is to be created.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the metadata table in which the partition is to be created.
- partition_input(PartitionInput) / set_partition_input(Option<PartitionInput>):
  A PartitionInput structure defining the partition to be created.
On success, responds with CreatePartitionOutput
On failure, responds with SdkError<CreatePartitionError>

source

pub fn create_partition_index(&self) -> CreatePartitionIndex

Constructs a fluent builder for the CreatePartitionIndex operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The catalog ID where the table resides.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  Specifies the name of a database in which you want to create a partition index.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  Specifies the name of a table in which you want to create a partition index.
- partition_index(PartitionIndex) / set_partition_index(Option<PartitionIndex>):
  Specifies a PartitionIndex structure to create a partition index in an existing table.
On success, responds with CreatePartitionIndexOutput
On failure, responds with SdkError<CreatePartitionIndexError>

source

pub fn create_registry(&self) -> CreateRegistry

Constructs a fluent builder for the CreateRegistry operation.

The fluent builder is configurable:
- registry_name(impl Into<String>) / set_registry_name(Option<String>):
  Name of the registry to be created of max length of 255, and may only contain letters, numbers, hyphen, underscore, dollar sign, or hash mark. No whitespace.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the registry. If description is not provided, there will not be any default value for this.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Amazon Web Services tags that contain a key value pair and may be searched by console, command line, or API.
On success, responds with CreateRegistryOutput with field(s):
- registry_arn(Option<String>):
  The Amazon Resource Name (ARN) of the newly created registry.
- registry_name(Option<String>):
  The name of the registry.
- description(Option<String>):
  A description of the registry.
- tags(Option<HashMap<String, String>>):
  The tags for the registry.
On failure, responds with SdkError<CreateRegistryError>

source

pub fn create_schema(&self) -> CreateSchema

Constructs a fluent builder for the CreateSchema operation.

The fluent builder is configurable:
- registry_id(RegistryId) / set_registry_id(Option<RegistryId>):
  This is a wrapper shape to contain the registry identity fields. If this is not provided, the default registry will be used. The ARN format for the same will be: arn:aws:glue:us-east-2: :registry/default-registry:random-5-letter-id .
- schema_name(impl Into<String>) / set_schema_name(Option<String>):
  Name of the schema to be created of max length of 255, and may only contain letters, numbers, hyphen, underscore, dollar sign, or hash mark. No whitespace.
- data_format(DataFormat) / set_data_format(Option<DataFormat>):
  The data format of the schema definition. Currently AVRO, JSON and PROTOBUF are supported.
- compatibility(Compatibility) / set_compatibility(Option<Compatibility>):
  The compatibility mode of the schema. The possible values are:
  - NONE: No compatibility mode applies. You can use this choice in development scenarios or if you do not know the compatibility mode that you want to apply to schemas. Any new version added will be accepted without undergoing a compatibility check.
  - DISABLED: This compatibility choice prevents versioning for a particular schema. You can use this choice to prevent future versioning of a schema.
  - BACKWARD: This compatibility choice is recommended as it allows data receivers to read both the current and one previous schema version. This means that for instance, a new schema version cannot drop data fields or change the type of these fields, so they can’t be read by readers using the previous version.
  - BACKWARD_ALL: This compatibility choice allows data receivers to read both the current and all previous schema versions. You can use this choice when you need to delete fields or add optional fields, and check compatibility against all previous schema versions.
  - FORWARD: This compatibility choice allows data receivers to read both the current and one next schema version, but not necessarily later versions. You can use this choice when you need to add fields or delete optional fields, but only check compatibility against the last schema version.
  - FORWARD_ALL: This compatibility choice allows data receivers to read written by producers of any new registered schema. You can use this choice when you need to add fields or delete optional fields, and check compatibility against all previous schema versions.
  - FULL: This compatibility choice allows data receivers to read data written by producers using the previous or next version of the schema, but not necessarily earlier or later versions. You can use this choice when you need to add or remove optional fields, but only check compatibility against the last schema version.
  - FULL_ALL: This compatibility choice allows data receivers to read data written by producers using all previous schema versions. You can use this choice when you need to add or remove optional fields, and check compatibility against all previous schema versions.
- description(impl Into<String>) / set_description(Option<String>):
  An optional description of the schema. If description is not provided, there will not be any automatic default value for this.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Amazon Web Services tags that contain a key value pair and may be searched by console, command line, or API. If specified, follows the Amazon Web Services tags-on-create pattern.
- schema_definition(impl Into<String>) / set_schema_definition(Option<String>):
  The schema definition using the DataFormat setting for SchemaName.
On success, responds with CreateSchemaOutput with field(s):
- registry_name(Option<String>):
  The name of the registry.
- registry_arn(Option<String>):
  The Amazon Resource Name (ARN) of the registry.
- schema_name(Option<String>):
  The name of the schema.
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) of the schema.
- description(Option<String>):
  A description of the schema if specified when created.
- data_format(Option<DataFormat>):
  The data format of the schema definition. Currently AVRO, JSON and PROTOBUF are supported.
- compatibility(Option<Compatibility>):
  The schema compatibility mode.
- schema_checkpoint(i64):
  The version number of the checkpoint (the last time the compatibility mode was changed).
- latest_schema_version(i64):
  The latest version of the schema associated with the returned schema definition.
- next_schema_version(i64):
  The next version of the schema associated with the returned schema definition.
- schema_status(Option<SchemaStatus>):
  The status of the schema.
- tags(Option<HashMap<String, String>>):
  The tags for the schema.
- schema_version_id(Option<String>):
  The unique identifier of the first schema version.
- schema_version_status(Option<SchemaVersionStatus>):
  The status of the first schema version created.
On failure, responds with SdkError<CreateSchemaError>

source

pub fn create_script(&self) -> CreateScript

Constructs a fluent builder for the CreateScript operation.

The fluent builder is configurable:
- dag_nodes(Vec<CodeGenNode>) / set_dag_nodes(Option<Vec<CodeGenNode>>):
  A list of the nodes in the DAG.
- dag_edges(Vec<CodeGenEdge>) / set_dag_edges(Option<Vec<CodeGenEdge>>):
  A list of the edges in the DAG.
- language(Language) / set_language(Option<Language>):
  The programming language of the resulting code from the DAG.
On success, responds with CreateScriptOutput with field(s):
- python_script(Option<String>):
  The Python script generated from the DAG.
- scala_code(Option<String>):
  The Scala code generated from the DAG.
On failure, responds with SdkError<CreateScriptError>

source

pub fn create_security_configuration(&self) -> CreateSecurityConfiguration

Constructs a fluent builder for the CreateSecurityConfiguration operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name for the new security configuration.
- encryption_configuration(EncryptionConfiguration) / set_encryption_configuration(Option<EncryptionConfiguration>):
  The encryption configuration for the new security configuration.
On success, responds with CreateSecurityConfigurationOutput with field(s):
- name(Option<String>):
  The name assigned to the new security configuration.
- created_timestamp(Option<DateTime>):
  The time at which the new security configuration was created.
On failure, responds with SdkError<CreateSecurityConfigurationError>

source

pub fn create_session(&self) -> CreateSession

Constructs a fluent builder for the CreateSession operation.

The fluent builder is configurable:
- id(impl Into<String>) / set_id(Option<String>):
  The ID of the session request.
- description(impl Into<String>) / set_description(Option<String>):
  The description of the session.
- role(impl Into<String>) / set_role(Option<String>):
  The IAM Role ARN
- command(SessionCommand) / set_command(Option<SessionCommand>):
  The SessionCommand that runs the job.
- timeout(i32) / set_timeout(Option<i32>):
  The number of seconds before request times out.
- idle_timeout(i32) / set_idle_timeout(Option<i32>):
  The number of seconds when idle before request times out.
- default_arguments(HashMap<String, String>) / set_default_arguments(Option<HashMap<String, String>>):
  A map array of key-value pairs. Max is 75 pairs.
- connections(ConnectionsList) / set_connections(Option<ConnectionsList>):
  The number of connections to use for the session.
- max_capacity(f64) / set_max_capacity(Option<f64>):
  The number of AWS Glue data processing units (DPUs) that can be allocated when the job runs. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB memory.
- number_of_workers(i32) / set_number_of_workers(Option<i32>):
  The number of workers to use for the session.
- worker_type(WorkerType) / set_worker_type(Option<WorkerType>):
  The Worker Type. Can be one of G.1X, G.2X, Standard
- security_configuration(impl Into<String>) / set_security_configuration(Option<String>):
  The name of the SecurityConfiguration structure to be used with the session
- glue_version(impl Into<String>) / set_glue_version(Option<String>):
  The Glue version determines the versions of Apache Spark and Python that AWS Glue supports. The GlueVersion must be greater than 2.0.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The map of key value pairs (tags) belonging to the session.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request.
On success, responds with CreateSessionOutput with field(s):
- session(Option<Session>):
  Returns the session object in the response.
On failure, responds with SdkError<CreateSessionError>

source

pub fn create_table(&self) -> CreateTable

Constructs a fluent builder for the CreateTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which to create the Table. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The catalog database in which to create the new table. For Hive compatibility, this name is entirely lowercase.
- table_input(TableInput) / set_table_input(Option<TableInput>):
  The TableInput object that defines the metadata table to create in the catalog.
- partition_indexes(Vec<PartitionIndex>) / set_partition_indexes(Option<Vec<PartitionIndex>>):
  A list of partition indexes, PartitionIndex structures, to create in the table.
- transaction_id(impl Into<String>) / set_transaction_id(Option<String>):
  The ID of the transaction.
On success, responds with CreateTableOutput
On failure, responds with SdkError<CreateTableError>

source

pub fn create_trigger(&self) -> CreateTrigger

Constructs a fluent builder for the CreateTrigger operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the trigger.
- workflow_name(impl Into<String>) / set_workflow_name(Option<String>):
  The name of the workflow associated with the trigger.
- r#type(TriggerType) / set_type(Option<TriggerType>):
  The type of the new trigger.
- schedule(impl Into<String>) / set_schedule(Option<String>):
  A cron expression used to specify the schedule (see Time-Based Schedules for Jobs and Crawlers. For example, to run something every day at 12:15 UTC, you would specify: cron(15 12 * * ? *).
  
  This field is required when the trigger type is SCHEDULED.
- predicate(Predicate) / set_predicate(Option<Predicate>):
  A predicate to specify when the new trigger should fire.
  
  This field is required when the trigger type is CONDITIONAL.
- actions(Vec<Action>) / set_actions(Option<Vec<Action>>):
  The actions initiated by this trigger when it fires.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the new trigger.
- start_on_creation(bool) / set_start_on_creation(bool):
  Set to true to start SCHEDULED and CONDITIONAL triggers when created. True is not supported for ON_DEMAND triggers.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags to use with this trigger. You may use tags to limit access to the trigger. For more information about tags in Glue, see Amazon Web Services Tags in Glue in the developer guide.
- event_batching_condition(EventBatchingCondition) / set_event_batching_condition(Option<EventBatchingCondition>):
  Batch condition that must be met (specified number of events received or batch time window expired) before EventBridge event trigger fires.
On success, responds with CreateTriggerOutput with field(s):
- name(Option<String>):
  The name of the trigger.
On failure, responds with SdkError<CreateTriggerError>

source

pub fn create_user_defined_function(&self) -> CreateUserDefinedFunction

Constructs a fluent builder for the CreateUserDefinedFunction operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which to create the function. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database in which to create the function.
- function_input(UserDefinedFunctionInput) / set_function_input(Option<UserDefinedFunctionInput>):
  A FunctionInput object that defines the function to create in the Data Catalog.
On success, responds with CreateUserDefinedFunctionOutput
On failure, responds with SdkError<CreateUserDefinedFunctionError>

source

pub fn create_workflow(&self) -> CreateWorkflow

Constructs a fluent builder for the CreateWorkflow operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name to be assigned to the workflow. It should be unique within your account.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the workflow.
- default_run_properties(HashMap<String, String>) / set_default_run_properties(Option<HashMap<String, String>>):
  A collection of properties to be used as part of each execution of the workflow.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  The tags to be used with this workflow.
- max_concurrent_runs(i32) / set_max_concurrent_runs(Option<i32>):
  You can use this parameter to prevent unwanted multiple updates to data, to control costs, or in some cases, to prevent exceeding the maximum number of concurrent runs of any of the component jobs. If you leave this parameter blank, there is no limit to the number of concurrent workflow runs.
On success, responds with CreateWorkflowOutput with field(s):
- name(Option<String>):
  The name of the workflow which was provided as part of the request.
On failure, responds with SdkError<CreateWorkflowError>

source

pub fn delete_blueprint(&self) -> DeleteBlueprint

Constructs a fluent builder for the DeleteBlueprint operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the blueprint to delete.
On success, responds with DeleteBlueprintOutput with field(s):
- name(Option<String>):
  Returns the name of the blueprint that was deleted.
On failure, responds with SdkError<DeleteBlueprintError>

source

pub fn delete_classifier(&self) -> DeleteClassifier

Constructs a fluent builder for the DeleteClassifier operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the classifier to remove.
On success, responds with DeleteClassifierOutput
On failure, responds with SdkError<DeleteClassifierError>

source

pub fn delete_column_statistics_for_partition(
&self
) -> DeleteColumnStatisticsForPartition

Constructs a fluent builder for the DeleteColumnStatisticsForPartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- partition_values(Vec<String>) / set_partition_values(Option<Vec<String>>):
  A list of partition values identifying the partition.
- column_name(impl Into<String>) / set_column_name(Option<String>):
  Name of the column.
On success, responds with DeleteColumnStatisticsForPartitionOutput
On failure, responds with SdkError<DeleteColumnStatisticsForPartitionError>

source

pub fn delete_column_statistics_for_table(
&self
) -> DeleteColumnStatisticsForTable

Constructs a fluent builder for the DeleteColumnStatisticsForTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- column_name(impl Into<String>) / set_column_name(Option<String>):
  The name of the column.
On success, responds with DeleteColumnStatisticsForTableOutput
On failure, responds with SdkError<DeleteColumnStatisticsForTableError>

source

pub fn delete_connection(&self) -> DeleteConnection

Constructs a fluent builder for the DeleteConnection operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the connection resides. If none is provided, the Amazon Web Services account ID is used by default.
- connection_name(impl Into<String>) / set_connection_name(Option<String>):
  The name of the connection to delete.
On success, responds with DeleteConnectionOutput
On failure, responds with SdkError<DeleteConnectionError>

source

pub fn delete_crawler(&self) -> DeleteCrawler

Constructs a fluent builder for the DeleteCrawler operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the crawler to remove.
On success, responds with DeleteCrawlerOutput
On failure, responds with SdkError<DeleteCrawlerError>

source

pub fn delete_custom_entity_type(&self) -> DeleteCustomEntityType

Constructs a fluent builder for the DeleteCustomEntityType operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the custom pattern that you want to delete.
On success, responds with DeleteCustomEntityTypeOutput with field(s):
- name(Option<String>):
  The name of the custom pattern you deleted.
On failure, responds with SdkError<DeleteCustomEntityTypeError>

source

pub fn delete_database(&self) -> DeleteDatabase

Constructs a fluent builder for the DeleteDatabase operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the database resides. If none is provided, the Amazon Web Services account ID is used by default.
- name(impl Into<String>) / set_name(Option<String>):
  The name of the database to delete. For Hive compatibility, this must be all lowercase.
On success, responds with DeleteDatabaseOutput
On failure, responds with SdkError<DeleteDatabaseError>

source

pub fn delete_dev_endpoint(&self) -> DeleteDevEndpoint

Constructs a fluent builder for the DeleteDevEndpoint operation.

The fluent builder is configurable:
- endpoint_name(impl Into<String>) / set_endpoint_name(Option<String>):
  The name of the DevEndpoint.
On success, responds with DeleteDevEndpointOutput
On failure, responds with SdkError<DeleteDevEndpointError>

source

pub fn delete_job(&self) -> DeleteJob

Constructs a fluent builder for the DeleteJob operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job definition to delete.
On success, responds with DeleteJobOutput with field(s):
- job_name(Option<String>):
  The name of the job definition that was deleted.
On failure, responds with SdkError<DeleteJobError>

source

pub fn delete_ml_transform(&self) -> DeleteMLTransform

Constructs a fluent builder for the DeleteMLTransform operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the transform to delete.
On success, responds with DeleteMlTransformOutput with field(s):
- transform_id(Option<String>):
  The unique identifier of the transform that was deleted.
On failure, responds with SdkError<DeleteMLTransformError>

source

pub fn delete_partition(&self) -> DeletePartition

Constructs a fluent builder for the DeletePartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partition to be deleted resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database in which the table in question resides.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the table that contains the partition to be deleted.
- partition_values(Vec<String>) / set_partition_values(Option<Vec<String>>):
  The values that define the partition.
On success, responds with DeletePartitionOutput
On failure, responds with SdkError<DeletePartitionError>

source

pub fn delete_partition_index(&self) -> DeletePartitionIndex

Constructs a fluent builder for the DeletePartitionIndex operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The catalog ID where the table resides.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  Specifies the name of a database from which you want to delete a partition index.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  Specifies the name of a table from which you want to delete a partition index.
- index_name(impl Into<String>) / set_index_name(Option<String>):
  The name of the partition index to be deleted.
On success, responds with DeletePartitionIndexOutput
On failure, responds with SdkError<DeletePartitionIndexError>

source

pub fn delete_registry(&self) -> DeleteRegistry

Constructs a fluent builder for the DeleteRegistry operation.

The fluent builder is configurable:
- registry_id(RegistryId) / set_registry_id(Option<RegistryId>):
  This is a wrapper structure that may contain the registry name and Amazon Resource Name (ARN).
On success, responds with DeleteRegistryOutput with field(s):
- registry_name(Option<String>):
  The name of the registry being deleted.
- registry_arn(Option<String>):
  The Amazon Resource Name (ARN) of the registry being deleted.
- status(Option<RegistryStatus>):
  The status of the registry. A successful operation will return the Deleting status.
On failure, responds with SdkError<DeleteRegistryError>

source

pub fn delete_resource_policy(&self) -> DeleteResourcePolicy

Constructs a fluent builder for the DeleteResourcePolicy operation.

The fluent builder is configurable:
- policy_hash_condition(impl Into<String>) / set_policy_hash_condition(Option<String>):
  The hash value returned when this policy was set.
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
  The ARN of the Glue resource for the resource policy to be deleted.
On success, responds with DeleteResourcePolicyOutput
On failure, responds with SdkError<DeleteResourcePolicyError>

source

pub fn delete_schema(&self) -> DeleteSchema

Constructs a fluent builder for the DeleteSchema operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure that may contain the schema name and Amazon Resource Name (ARN).
On success, responds with DeleteSchemaOutput with field(s):
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) of the schema being deleted.
- schema_name(Option<String>):
  The name of the schema being deleted.
- status(Option<SchemaStatus>):
  The status of the schema.
On failure, responds with SdkError<DeleteSchemaError>

source

pub fn delete_schema_versions(&self) -> DeleteSchemaVersions

Constructs a fluent builder for the DeleteSchemaVersions operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure that may contain the schema name and Amazon Resource Name (ARN).
- versions(impl Into<String>) / set_versions(Option<String>):
  A version range may be supplied which may be of the format:
  - a single version number, 5
  - a range, 5-8 : deletes versions 5, 6, 7, 8
On success, responds with DeleteSchemaVersionsOutput with field(s):
- schema_version_errors(Option<Vec<SchemaVersionErrorItem>>):
  A list of SchemaVersionErrorItem objects, each containing an error and schema version.
On failure, responds with SdkError<DeleteSchemaVersionsError>

source

pub fn delete_security_configuration(&self) -> DeleteSecurityConfiguration

Constructs a fluent builder for the DeleteSecurityConfiguration operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the security configuration to delete.
On success, responds with DeleteSecurityConfigurationOutput
On failure, responds with SdkError<DeleteSecurityConfigurationError>

source

pub fn delete_session(&self) -> DeleteSession

Constructs a fluent builder for the DeleteSession operation.

The fluent builder is configurable:
- id(impl Into<String>) / set_id(Option<String>):
  The ID of the session to be deleted.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The name of the origin of the delete session request.
On success, responds with DeleteSessionOutput with field(s):
- id(Option<String>):
  Returns the ID of the deleted session.
On failure, responds with SdkError<DeleteSessionError>

source

pub fn delete_table(&self) -> DeleteTable

Constructs a fluent builder for the DeleteTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the table resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database in which the table resides. For Hive compatibility, this name is entirely lowercase.
- name(impl Into<String>) / set_name(Option<String>):
  The name of the table to be deleted. For Hive compatibility, this name is entirely lowercase.
- transaction_id(impl Into<String>) / set_transaction_id(Option<String>):
  The transaction ID at which to delete the table contents.
On success, responds with DeleteTableOutput
On failure, responds with SdkError<DeleteTableError>

source

pub fn delete_table_version(&self) -> DeleteTableVersion

Constructs a fluent builder for the DeleteTableVersion operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the tables reside. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the table. For Hive compatibility, this name is entirely lowercase.
- version_id(impl Into<String>) / set_version_id(Option<String>):
  The ID of the table version to be deleted. A VersionID is a string representation of an integer. Each version is incremented by 1.
On success, responds with DeleteTableVersionOutput
On failure, responds with SdkError<DeleteTableVersionError>

source

pub fn delete_trigger(&self) -> DeleteTrigger

Constructs a fluent builder for the DeleteTrigger operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the trigger to delete.
On success, responds with DeleteTriggerOutput with field(s):
- name(Option<String>):
  The name of the trigger that was deleted.
On failure, responds with SdkError<DeleteTriggerError>

source

pub fn delete_user_defined_function(&self) -> DeleteUserDefinedFunction

Constructs a fluent builder for the DeleteUserDefinedFunction operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the function to be deleted is located. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the function is located.
- function_name(impl Into<String>) / set_function_name(Option<String>):
  The name of the function definition to be deleted.
On success, responds with DeleteUserDefinedFunctionOutput
On failure, responds with SdkError<DeleteUserDefinedFunctionError>

source

pub fn delete_workflow(&self) -> DeleteWorkflow

Constructs a fluent builder for the DeleteWorkflow operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the workflow to be deleted.
On success, responds with DeleteWorkflowOutput with field(s):
- name(Option<String>):
  Name of the workflow specified in input.
On failure, responds with SdkError<DeleteWorkflowError>

source

pub fn get_blueprint(&self) -> GetBlueprint

Constructs a fluent builder for the GetBlueprint operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the blueprint.
- include_blueprint(bool) / set_include_blueprint(Option<bool>):
  Specifies whether or not to include the blueprint in the response.
- include_parameter_spec(bool) / set_include_parameter_spec(Option<bool>):
  Specifies whether or not to include the parameter specification.
On success, responds with GetBlueprintOutput with field(s):
- blueprint(Option<Blueprint>):
  Returns a Blueprint object.
On failure, responds with SdkError<GetBlueprintError>

source

pub fn get_blueprint_run(&self) -> GetBlueprintRun

Constructs a fluent builder for the GetBlueprintRun operation.

The fluent builder is configurable:
- blueprint_name(impl Into<String>) / set_blueprint_name(Option<String>):
  The name of the blueprint.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The run ID for the blueprint run you want to retrieve.
On success, responds with GetBlueprintRunOutput with field(s):
- blueprint_run(Option<BlueprintRun>):
  Returns a BlueprintRun object.
On failure, responds with SdkError<GetBlueprintRunError>

source

pub fn get_blueprint_runs(&self) -> GetBlueprintRuns

Constructs a fluent builder for the GetBlueprintRuns operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- blueprint_name(impl Into<String>) / set_blueprint_name(Option<String>):
  The name of the blueprint.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
On success, responds with GetBlueprintRunsOutput with field(s):
- blueprint_runs(Option<Vec<BlueprintRun>>):
  Returns a list of BlueprintRun objects.
- next_token(Option<String>):
  A continuation token, if not all blueprint runs have been returned.
On failure, responds with SdkError<GetBlueprintRunsError>

source

pub fn get_catalog_import_status(&self) -> GetCatalogImportStatus

Constructs a fluent builder for the GetCatalogImportStatus operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the catalog to migrate. Currently, this should be the Amazon Web Services account ID.
On success, responds with GetCatalogImportStatusOutput with field(s):
- import_status(Option<CatalogImportStatus>):
  The status of the specified catalog migration.
On failure, responds with SdkError<GetCatalogImportStatusError>

source

pub fn get_classifier(&self) -> GetClassifier

Constructs a fluent builder for the GetClassifier operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the classifier to retrieve.
On success, responds with GetClassifierOutput with field(s):
- classifier(Option<Classifier>):
  The requested classifier.
On failure, responds with SdkError<GetClassifierError>

source

pub fn get_classifiers(&self) -> GetClassifiers

Constructs a fluent builder for the GetClassifiers operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- max_results(i32) / set_max_results(Option<i32>):
  The size of the list to return (optional).
- next_token(impl Into<String>) / set_next_token(Option<String>):
  An optional continuation token.
On success, responds with GetClassifiersOutput with field(s):
- classifiers(Option<Vec<Classifier>>):
  The requested list of classifier objects.
- next_token(Option<String>):
  A continuation token.
On failure, responds with SdkError<GetClassifiersError>

source

pub fn get_column_statistics_for_partition(
&self
) -> GetColumnStatisticsForPartition

Constructs a fluent builder for the GetColumnStatisticsForPartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- partition_values(Vec<String>) / set_partition_values(Option<Vec<String>>):
  A list of partition values identifying the partition.
- column_names(Vec<String>) / set_column_names(Option<Vec<String>>):
  A list of the column names.
On success, responds with GetColumnStatisticsForPartitionOutput with field(s):
- column_statistics_list(Option<Vec<ColumnStatistics>>):
  List of ColumnStatistics that failed to be retrieved.
- errors(Option<Vec<ColumnError>>):
  Error occurred during retrieving column statistics data.
On failure, responds with SdkError<GetColumnStatisticsForPartitionError>

source

pub fn get_column_statistics_for_table(&self) -> GetColumnStatisticsForTable

Constructs a fluent builder for the GetColumnStatisticsForTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- column_names(Vec<String>) / set_column_names(Option<Vec<String>>):
  A list of the column names.
On success, responds with GetColumnStatisticsForTableOutput with field(s):
- column_statistics_list(Option<Vec<ColumnStatistics>>):
  List of ColumnStatistics that failed to be retrieved.
- errors(Option<Vec<ColumnError>>):
  List of ColumnStatistics that failed to be retrieved.
On failure, responds with SdkError<GetColumnStatisticsForTableError>

source

pub fn get_connection(&self) -> GetConnection

Constructs a fluent builder for the GetConnection operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the connection resides. If none is provided, the Amazon Web Services account ID is used by default.
- name(impl Into<String>) / set_name(Option<String>):
  The name of the connection definition to retrieve.
- hide_password(bool) / set_hide_password(bool):
  Allows you to retrieve the connection metadata without returning the password. For instance, the AWS Glue console uses this flag to retrieve the connection, and does not display the password. Set this parameter when the caller might not have permission to use the KMS key to decrypt the password, but it does have permission to access the rest of the connection properties.
On success, responds with GetConnectionOutput with field(s):
- connection(Option<Connection>):
  The requested connection definition.
On failure, responds with SdkError<GetConnectionError>

source

pub fn get_connections(&self) -> GetConnections

Constructs a fluent builder for the GetConnections operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the connections reside. If none is provided, the Amazon Web Services account ID is used by default.
- filter(GetConnectionsFilter) / set_filter(Option<GetConnectionsFilter>):
  A filter that controls which connections are returned.
- hide_password(bool) / set_hide_password(bool):
  Allows you to retrieve the connection metadata without returning the password. For instance, the AWS Glue console uses this flag to retrieve the connection, and does not display the password. Set this parameter when the caller might not have permission to use the KMS key to decrypt the password, but it does have permission to access the rest of the connection properties.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of connections to return in one response.
On success, responds with GetConnectionsOutput with field(s):
- connection_list(Option<Vec<Connection>>):
  A list of requested connection definitions.
- next_token(Option<String>):
  A continuation token, if the list of connections returned does not include the last of the filtered connections.
On failure, responds with SdkError<GetConnectionsError>

source

pub fn get_crawler(&self) -> GetCrawler

Constructs a fluent builder for the GetCrawler operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the crawler to retrieve metadata for.
On success, responds with GetCrawlerOutput with field(s):
- crawler(Option<Crawler>):
  The metadata for the specified crawler.
On failure, responds with SdkError<GetCrawlerError>

source

pub fn get_crawler_metrics(&self) -> GetCrawlerMetrics

Constructs a fluent builder for the GetCrawlerMetrics operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- crawler_name_list(Vec<String>) / set_crawler_name_list(Option<Vec<String>>):
  A list of the names of crawlers about which to retrieve metrics.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
On success, responds with GetCrawlerMetricsOutput with field(s):
- crawler_metrics_list(Option<Vec<CrawlerMetrics>>):
  A list of metrics for the specified crawler.
- next_token(Option<String>):
  A continuation token, if the returned list does not contain the last metric available.
On failure, responds with SdkError<GetCrawlerMetricsError>

source

pub fn get_crawlers(&self) -> GetCrawlers

Constructs a fluent builder for the GetCrawlers operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- max_results(i32) / set_max_results(Option<i32>):
  The number of crawlers to return on each call.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
On success, responds with GetCrawlersOutput with field(s):
- crawlers(Option<Vec<Crawler>>):
  A list of crawler metadata.
- next_token(Option<String>):
  A continuation token, if the returned list has not reached the end of those defined in this customer account.
On failure, responds with SdkError<GetCrawlersError>

source

pub fn get_custom_entity_type(&self) -> GetCustomEntityType

Constructs a fluent builder for the GetCustomEntityType operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the custom pattern that you want to retrieve.
On success, responds with GetCustomEntityTypeOutput with field(s):
- name(Option<String>):
  The name of the custom pattern that you retrieved.
- regex_string(Option<String>):
  A regular expression string that is used for detecting sensitive data in a custom pattern.
- context_words(Option<Vec<String>>):
  A list of context words if specified when you created the custom pattern. If none of these context words are found within the vicinity of the regular expression the data will not be detected as sensitive data.
On failure, responds with SdkError<GetCustomEntityTypeError>

source

pub fn get_database(&self) -> GetDatabase

Constructs a fluent builder for the GetDatabase operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the database resides. If none is provided, the Amazon Web Services account ID is used by default.
- name(impl Into<String>) / set_name(Option<String>):
  The name of the database to retrieve. For Hive compatibility, this should be all lowercase.
On success, responds with GetDatabaseOutput with field(s):
- database(Option<Database>):
  The definition of the specified database in the Data Catalog.
On failure, responds with SdkError<GetDatabaseError>

source

pub fn get_databases(&self) -> GetDatabases

Constructs a fluent builder for the GetDatabases operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog from which to retrieve Databases. If none is provided, the Amazon Web Services account ID is used by default.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of databases to return in one response.
- resource_share_type(ResourceShareType) / set_resource_share_type(Option<ResourceShareType>):
  Allows you to specify that you want to list the databases shared with your account. The allowable values are FOREIGN or ALL.
  - If set to FOREIGN, will list the databases shared with your account.
  - If set to ALL, will list the databases shared with your account, as well as the databases in yor local account.
On success, responds with GetDatabasesOutput with field(s):
- database_list(Option<Vec<Database>>):
  A list of Database objects from the specified catalog.
- next_token(Option<String>):
  A continuation token for paginating the returned list of tokens, returned if the current segment of the list is not the last.
On failure, responds with SdkError<GetDatabasesError>

source

pub fn get_data_catalog_encryption_settings(
&self
) -> GetDataCatalogEncryptionSettings

Constructs a fluent builder for the GetDataCatalogEncryptionSettings operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog to retrieve the security configuration for. If none is provided, the Amazon Web Services account ID is used by default.
On success, responds with GetDataCatalogEncryptionSettingsOutput with field(s):
- data_catalog_encryption_settings(Option<DataCatalogEncryptionSettings>):
  The requested security configuration.
On failure, responds with SdkError<GetDataCatalogEncryptionSettingsError>

source

pub fn get_dataflow_graph(&self) -> GetDataflowGraph

Constructs a fluent builder for the GetDataflowGraph operation.

The fluent builder is configurable:
- python_script(impl Into<String>) / set_python_script(Option<String>):
  The Python script to transform.
On success, responds with GetDataflowGraphOutput with field(s):
- dag_nodes(Option<Vec<CodeGenNode>>):
  A list of the nodes in the resulting DAG.
- dag_edges(Option<Vec<CodeGenEdge>>):
  A list of the edges in the resulting DAG.
On failure, responds with SdkError<GetDataflowGraphError>

source

pub fn get_dev_endpoint(&self) -> GetDevEndpoint

Constructs a fluent builder for the GetDevEndpoint operation.

The fluent builder is configurable:
- endpoint_name(impl Into<String>) / set_endpoint_name(Option<String>):
  Name of the DevEndpoint to retrieve information for.
On success, responds with GetDevEndpointOutput with field(s):
- dev_endpoint(Option<DevEndpoint>):
  A DevEndpoint definition.
On failure, responds with SdkError<GetDevEndpointError>

source

pub fn get_dev_endpoints(&self) -> GetDevEndpoints

Constructs a fluent builder for the GetDevEndpoints operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of information to return.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
On success, responds with GetDevEndpointsOutput with field(s):
- dev_endpoints(Option<Vec<DevEndpoint>>):
  A list of DevEndpoint definitions.
- next_token(Option<String>):
  A continuation token, if not all DevEndpoint definitions have yet been returned.
On failure, responds with SdkError<GetDevEndpointsError>

source

pub fn get_job(&self) -> GetJob

Constructs a fluent builder for the GetJob operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job definition to retrieve.
On success, responds with GetJobOutput with field(s):
- job(Option<Job>):
  The requested job definition.
On failure, responds with SdkError<GetJobError>

source

pub fn get_job_bookmark(&self) -> GetJobBookmark

Constructs a fluent builder for the GetJobBookmark operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job in question.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The unique run identifier associated with this job run.
On success, responds with GetJobBookmarkOutput with field(s):
- job_bookmark_entry(Option<JobBookmarkEntry>):
  A structure that defines a point that a job can resume processing.
On failure, responds with SdkError<GetJobBookmarkError>

source

pub fn get_job_run(&self) -> GetJobRun

Constructs a fluent builder for the GetJobRun operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  Name of the job definition being run.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The ID of the job run.
- predecessors_included(bool) / set_predecessors_included(bool):
  True if a list of predecessor runs should be returned.
On success, responds with GetJobRunOutput with field(s):
- job_run(Option<JobRun>):
  The requested job-run metadata.
On failure, responds with SdkError<GetJobRunError>

source

pub fn get_job_runs(&self) -> GetJobRuns

Constructs a fluent builder for the GetJobRuns operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job definition for which to retrieve all job runs.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of the response.
On success, responds with GetJobRunsOutput with field(s):
- job_runs(Option<Vec<JobRun>>):
  A list of job-run metadata objects.
- next_token(Option<String>):
  A continuation token, if not all requested job runs have been returned.
On failure, responds with SdkError<GetJobRunsError>

source

pub fn get_jobs(&self) -> GetJobs

Constructs a fluent builder for the GetJobs operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of the response.
On success, responds with GetJobsOutput with field(s):
- jobs(Option<Vec<Job>>):
  A list of job definitions.
- next_token(Option<String>):
  A continuation token, if not all job definitions have yet been returned.
On failure, responds with SdkError<GetJobsError>

source

pub fn get_mapping(&self) -> GetMapping

Constructs a fluent builder for the GetMapping operation.

The fluent builder is configurable:
- source(CatalogEntry) / set_source(Option<CatalogEntry>):
  Specifies the source table.
- sinks(Vec<CatalogEntry>) / set_sinks(Option<Vec<CatalogEntry>>):
  A list of target tables.
- location(Location) / set_location(Option<Location>):
  Parameters for the mapping.
On success, responds with GetMappingOutput with field(s):
- mapping(Option<Vec<MappingEntry>>):
  A list of mappings to the specified targets.
On failure, responds with SdkError<GetMappingError>

source

pub fn get_ml_task_run(&self) -> GetMLTaskRun

Constructs a fluent builder for the GetMLTaskRun operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the machine learning transform.
- task_run_id(impl Into<String>) / set_task_run_id(Option<String>):
  The unique identifier of the task run.
On success, responds with GetMlTaskRunOutput with field(s):
- transform_id(Option<String>):
  The unique identifier of the task run.
- task_run_id(Option<String>):
  The unique run identifier associated with this run.
- status(Option<TaskStatusType>):
  The status for this task run.
- log_group_name(Option<String>):
  The names of the log groups that are associated with the task run.
- properties(Option<TaskRunProperties>):
  The list of properties that are associated with the task run.
- error_string(Option<String>):
  The error strings that are associated with the task run.
- started_on(Option<DateTime>):
  The date and time when this task run started.
- last_modified_on(Option<DateTime>):
  The date and time when this task run was last modified.
- completed_on(Option<DateTime>):
  The date and time when this task run was completed.
- execution_time(i32):
  The amount of time (in seconds) that the task run consumed resources.
On failure, responds with SdkError<GetMLTaskRunError>

source

pub fn get_ml_task_runs(&self) -> GetMLTaskRuns

Constructs a fluent builder for the GetMLTaskRuns operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the machine learning transform.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A token for pagination of the results. The default is empty.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of results to return.
- filter(TaskRunFilterCriteria) / set_filter(Option<TaskRunFilterCriteria>):
  The filter criteria, in the TaskRunFilterCriteria structure, for the task run.
- sort(TaskRunSortCriteria) / set_sort(Option<TaskRunSortCriteria>):
  The sorting criteria, in the TaskRunSortCriteria structure, for the task run.
On success, responds with GetMlTaskRunsOutput with field(s):
- task_runs(Option<Vec<TaskRun>>):
  A list of task runs that are associated with the transform.
- next_token(Option<String>):
  A pagination token, if more results are available.
On failure, responds with SdkError<GetMLTaskRunsError>

source

pub fn get_ml_transform(&self) -> GetMLTransform

Constructs a fluent builder for the GetMLTransform operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the transform, generated at the time that the transform was created.
On success, responds with GetMlTransformOutput with field(s):
- transform_id(Option<String>):
  The unique identifier of the transform, generated at the time that the transform was created.
- name(Option<String>):
  The unique name given to the transform when it was created.
- description(Option<String>):
  A description of the transform.
- status(Option<TransformStatusType>):
  The last known status of the transform (to indicate whether it can be used or not). One of “NOT_READY”, “READY”, or “DELETING”.
- created_on(Option<DateTime>):
  The date and time when the transform was created.
- last_modified_on(Option<DateTime>):
  The date and time when the transform was last modified.
- input_record_tables(Option<Vec<GlueTable>>):
  A list of Glue table definitions used by the transform.
- parameters(Option<TransformParameters>):
  The configuration parameters that are specific to the algorithm used.
- evaluation_metrics(Option<EvaluationMetrics>):
  The latest evaluation metrics.
- label_count(i32):
  The number of labels available for this transform.
- schema(Option<Vec<SchemaColumn>>):
  The Map <column, type></column,> object that represents the schema that this transform accepts. Has an upper bound of 100 columns.
- role(Option<String>):
  The name or Amazon Resource Name (ARN) of the IAM role with the required permissions.
- glue_version(Option<String>):
  This value determines which version of Glue this machine learning transform is compatible with. Glue 1.0 is recommended for most customers. If the value is not set, the Glue compatibility defaults to Glue 0.9. For more information, see Glue Versions in the developer guide.
- max_capacity(Option<f64>):
  The number of Glue data processing units (DPUs) that are allocated to task runs for this transform. You can allocate from 2 to 100 DPUs; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory. For more information, see the Glue pricing page.
  
  When the WorkerType field is set to a value other than Standard, the MaxCapacity field is set automatically and becomes read-only.
- worker_type(Option<WorkerType>):
  The type of predefined worker that is allocated when this task runs. Accepts a value of Standard, G.1X, or G.2X.
  - For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.
  - For the G.1X worker type, each worker provides 4 vCPU, 16 GB of memory and a 64GB disk, and 1 executor per worker.
  - For the G.2X worker type, each worker provides 8 vCPU, 32 GB of memory and a 128GB disk, and 1 executor per worker.
- number_of_workers(Option<i32>):
  The number of workers of a defined workerType that are allocated when this task runs.
- timeout(Option<i32>):
  The timeout for a task run for this transform in minutes. This is the maximum time that a task run for this transform can consume resources before it is terminated and enters TIMEOUT status. The default is 2,880 minutes (48 hours).
- max_retries(Option<i32>):
  The maximum number of times to retry a task for this transform after a task run fails.
- transform_encryption(Option<TransformEncryption>):
  The encryption-at-rest settings of the transform that apply to accessing user data. Machine learning transforms can access user data encrypted in Amazon S3 using KMS.
On failure, responds with SdkError<GetMLTransformError>

source

pub fn get_ml_transforms(&self) -> GetMLTransforms

Constructs a fluent builder for the GetMLTransforms operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A paginated token to offset the results.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of results to return.
- filter(TransformFilterCriteria) / set_filter(Option<TransformFilterCriteria>):
  The filter transformation criteria.
- sort(TransformSortCriteria) / set_sort(Option<TransformSortCriteria>):
  The sorting criteria.
On success, responds with GetMlTransformsOutput with field(s):
- transforms(Option<Vec<MlTransform>>):
  A list of machine learning transforms.
- next_token(Option<String>):
  A pagination token, if more results are available.
On failure, responds with SdkError<GetMLTransformsError>

source

pub fn get_partition(&self) -> GetPartition

Constructs a fluent builder for the GetPartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partition in question resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partition resides.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partition’s table.
- partition_values(Vec<String>) / set_partition_values(Option<Vec<String>>):
  The values that define the partition.
On success, responds with GetPartitionOutput with field(s):
- partition(Option<Partition>):
  The requested information, in the form of a Partition object.
On failure, responds with SdkError<GetPartitionError>

source

pub fn get_partition_indexes(&self) -> GetPartitionIndexes

Constructs a fluent builder for the GetPartitionIndexes operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The catalog ID where the table resides.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  Specifies the name of a database from which you want to retrieve partition indexes.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  Specifies the name of a table for which you want to retrieve the partition indexes.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, included if this is a continuation call.
On success, responds with GetPartitionIndexesOutput with field(s):
- partition_index_descriptor_list(Option<Vec<PartitionIndexDescriptor>>):
  A list of index descriptors.
- next_token(Option<String>):
  A continuation token, present if the current list segment is not the last.
On failure, responds with SdkError<GetPartitionIndexesError>

source

pub fn get_partitions(&self) -> GetPartitions

Constructs a fluent builder for the GetPartitions operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- expression(impl Into<String>) / set_expression(Option<String>):
  An expression that filters the partitions to be returned.
  
  The expression uses SQL syntax similar to the SQL WHERE filter clause. The SQL statement parser JSQLParser parses the expression.
  
  Operators: The following are the operators that you can use in the Expression API call:
  
  =
  
  Checks whether the values of the two operands are equal; if yes, then the condition becomes true.
  
  Example: Assume ‘variable a’ holds 10 and ‘variable b’ holds 20.
  
  (a = b) is not true.
  
  < >
  
  Checks whether the values of two operands are equal; if the values are not equal, then the condition becomes true.
  
  Example: (a < > b) is true.
  
  >
  
  Checks whether the value of the left operand is greater than the value of the right operand; if yes, then the condition becomes true.
  
  Example: (a > b) is not true.
  
  <
  
  Checks whether the value of the left operand is less than the value of the right operand; if yes, then the condition becomes true.
  
  Example: (a < b) is true.
  
  >=
  
  Checks whether the value of the left operand is greater than or equal to the value of the right operand; if yes, then the condition becomes true.
  
  Example: (a >= b) is not true.
  
  <=
  
  Checks whether the value of the left operand is less than or equal to the value of the right operand; if yes, then the condition becomes true.
  
  Example: (a <= b) is true.
  
  AND, OR, IN, BETWEEN, LIKE, NOT, IS NULL
  
  Logical operators.
  
  Supported Partition Key Types: The following are the supported partition keys.
  - string
  - date
  - timestamp
  - int
  - bigint
  - long
  - tinyint
  - smallint
  - decimal
  If an type is encountered that is not valid, an exception is thrown.
  
  The following list shows the valid operators on each type. When you define a crawler, the partitionKey type is created as a STRING, to be compatible with the catalog partitions.
  
  Sample API Call:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is not the first call to retrieve these partitions.
- segment(Segment) / set_segment(Option<Segment>):
  The segment of the table’s partitions to scan in this request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of partitions to return in a single response.
- exclude_column_schema(bool) / set_exclude_column_schema(Option<bool>):
  When true, specifies not returning the partition column schema. Useful when you are interested only in other partition attributes such as partition values or location. This approach avoids the problem of a large response by not returning duplicate data.
- transaction_id(impl Into<String>) / set_transaction_id(Option<String>):
  The transaction ID at which to read the partition contents.
- query_as_of_time(DateTime) / set_query_as_of_time(Option<DateTime>):
  The time as of when to read the partition contents. If not set, the most recent transaction commit time will be used. Cannot be specified along with TransactionId.
On success, responds with GetPartitionsOutput with field(s):
- partitions(Option<Vec<Partition>>):
  A list of requested partitions.
- next_token(Option<String>):
  A continuation token, if the returned list of partitions does not include the last one.
On failure, responds with SdkError<GetPartitionsError>

source

pub fn get_plan(&self) -> GetPlan

Constructs a fluent builder for the GetPlan operation.

The fluent builder is configurable:
- mapping(Vec<MappingEntry>) / set_mapping(Option<Vec<MappingEntry>>):
  The list of mappings from a source table to target tables.
- source(CatalogEntry) / set_source(Option<CatalogEntry>):
  The source table.
- sinks(Vec<CatalogEntry>) / set_sinks(Option<Vec<CatalogEntry>>):
  The target tables.
- location(Location) / set_location(Option<Location>):
  The parameters for the mapping.
- language(Language) / set_language(Option<Language>):
  The programming language of the code to perform the mapping.
- additional_plan_options_map(HashMap<String, String>) / set_additional_plan_options_map(Option<HashMap<String, String>>):
  A map to hold additional optional key-value parameters.
  
  Currently, these key-value pairs are supported:
  - inferSchema — Specifies whether to set inferSchema to true or false for the default script generated by an Glue job. For example, to set inferSchema to true, pass the following key value pair:
    
    –additional-plan-options-map ‘{“inferSchema”:“true”}’
On success, responds with GetPlanOutput with field(s):
- python_script(Option<String>):
  A Python script to perform the mapping.
- scala_code(Option<String>):
  The Scala code to perform the mapping.
On failure, responds with SdkError<GetPlanError>

source

pub fn get_registry(&self) -> GetRegistry

Constructs a fluent builder for the GetRegistry operation.

The fluent builder is configurable:
- registry_id(RegistryId) / set_registry_id(Option<RegistryId>):
  This is a wrapper structure that may contain the registry name and Amazon Resource Name (ARN).
On success, responds with GetRegistryOutput with field(s):
- registry_name(Option<String>):
  The name of the registry.
- registry_arn(Option<String>):
  The Amazon Resource Name (ARN) of the registry.
- description(Option<String>):
  A description of the registry.
- status(Option<RegistryStatus>):
  The status of the registry.
- created_time(Option<String>):
  The date and time the registry was created.
- updated_time(Option<String>):
  The date and time the registry was updated.
On failure, responds with SdkError<GetRegistryError>

source

pub fn get_resource_policies(&self) -> GetResourcePolicies

Constructs a fluent builder for the GetResourcePolicies operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
On success, responds with GetResourcePoliciesOutput with field(s):
- get_resource_policies_response_list(Option<Vec<GluePolicy>>):
  A list of the individual resource policies and the account-level resource policy.
- next_token(Option<String>):
  A continuation token, if the returned list does not contain the last resource policy available.
On failure, responds with SdkError<GetResourcePoliciesError>

source

pub fn get_resource_policy(&self) -> GetResourcePolicy

Constructs a fluent builder for the GetResourcePolicy operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
  The ARN of the Glue resource for which to retrieve the resource policy. If not supplied, the Data Catalog resource policy is returned. Use GetResourcePolicies to view all existing resource policies. For more information see Specifying Glue Resource ARNs.
On success, responds with GetResourcePolicyOutput with field(s):
- policy_in_json(Option<String>):
  Contains the requested policy document, in JSON format.
- policy_hash(Option<String>):
  Contains the hash value associated with this policy.
- create_time(Option<DateTime>):
  The date and time at which the policy was created.
- update_time(Option<DateTime>):
  The date and time at which the policy was last updated.
On failure, responds with SdkError<GetResourcePolicyError>

source

pub fn get_schema(&self) -> GetSchema

Constructs a fluent builder for the GetSchema operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure to contain schema identity fields. The structure contains:
  - SchemaId$SchemaArn: The Amazon Resource Name (ARN) of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
  - SchemaId$SchemaName: The name of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
On success, responds with GetSchemaOutput with field(s):
- registry_name(Option<String>):
  The name of the registry.
- registry_arn(Option<String>):
  The Amazon Resource Name (ARN) of the registry.
- schema_name(Option<String>):
  The name of the schema.
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) of the schema.
- description(Option<String>):
  A description of schema if specified when created
- data_format(Option<DataFormat>):
  The data format of the schema definition. Currently AVRO, JSON and PROTOBUF are supported.
- compatibility(Option<Compatibility>):
  The compatibility mode of the schema.
- schema_checkpoint(i64):
  The version number of the checkpoint (the last time the compatibility mode was changed).
- latest_schema_version(i64):
  The latest version of the schema associated with the returned schema definition.
- next_schema_version(i64):
  The next version of the schema associated with the returned schema definition.
- schema_status(Option<SchemaStatus>):
  The status of the schema.
- created_time(Option<String>):
  The date and time the schema was created.
- updated_time(Option<String>):
  The date and time the schema was updated.
On failure, responds with SdkError<GetSchemaError>

source

pub fn get_schema_by_definition(&self) -> GetSchemaByDefinition

Constructs a fluent builder for the GetSchemaByDefinition operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure to contain schema identity fields. The structure contains:
  - SchemaId$SchemaArn: The Amazon Resource Name (ARN) of the schema. One of SchemaArn or SchemaName has to be provided.
  - SchemaId$SchemaName: The name of the schema. One of SchemaArn or SchemaName has to be provided.
- schema_definition(impl Into<String>) / set_schema_definition(Option<String>):
  The definition of the schema for which schema details are required.
On success, responds with GetSchemaByDefinitionOutput with field(s):
- schema_version_id(Option<String>):
  The schema ID of the schema version.
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) of the schema.
- data_format(Option<DataFormat>):
  The data format of the schema definition. Currently AVRO, JSON and PROTOBUF are supported.
- status(Option<SchemaVersionStatus>):
  The status of the schema version.
- created_time(Option<String>):
  The date and time the schema was created.
On failure, responds with SdkError<GetSchemaByDefinitionError>

source

pub fn get_schema_version(&self) -> GetSchemaVersion

Constructs a fluent builder for the GetSchemaVersion operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure to contain schema identity fields. The structure contains:
  - SchemaId$SchemaArn: The Amazon Resource Name (ARN) of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
  - SchemaId$SchemaName: The name of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
- schema_version_id(impl Into<String>) / set_schema_version_id(Option<String>):
  The SchemaVersionId of the schema version. This field is required for fetching by schema ID. Either this or the SchemaId wrapper has to be provided.
- schema_version_number(SchemaVersionNumber) / set_schema_version_number(Option<SchemaVersionNumber>):
  The version number of the schema.
On success, responds with GetSchemaVersionOutput with field(s):
- schema_version_id(Option<String>):
  The SchemaVersionId of the schema version.
- schema_definition(Option<String>):
  The schema definition for the schema ID.
- data_format(Option<DataFormat>):
  The data format of the schema definition. Currently AVRO, JSON and PROTOBUF are supported.
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) of the schema.
- version_number(i64):
  The version number of the schema.
- status(Option<SchemaVersionStatus>):
  The status of the schema version.
- created_time(Option<String>):
  The date and time the schema version was created.
On failure, responds with SdkError<GetSchemaVersionError>

source

pub fn get_schema_versions_diff(&self) -> GetSchemaVersionsDiff

Constructs a fluent builder for the GetSchemaVersionsDiff operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure to contain schema identity fields. The structure contains:
  - SchemaId$SchemaArn: The Amazon Resource Name (ARN) of the schema. One of SchemaArn or SchemaName has to be provided.
  - SchemaId$SchemaName: The name of the schema. One of SchemaArn or SchemaName has to be provided.
- first_schema_version_number(SchemaVersionNumber) / set_first_schema_version_number(Option<SchemaVersionNumber>):
  The first of the two schema versions to be compared.
- second_schema_version_number(SchemaVersionNumber) / set_second_schema_version_number(Option<SchemaVersionNumber>):
  The second of the two schema versions to be compared.
- schema_diff_type(SchemaDiffType) / set_schema_diff_type(Option<SchemaDiffType>):
  Refers to SYNTAX_DIFF, which is the currently supported diff type.
On success, responds with GetSchemaVersionsDiffOutput with field(s):
- diff(Option<String>):
  The difference between schemas as a string in JsonPatch format.
On failure, responds with SdkError<GetSchemaVersionsDiffError>

source

pub fn get_security_configuration(&self) -> GetSecurityConfiguration

Constructs a fluent builder for the GetSecurityConfiguration operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the security configuration to retrieve.
On success, responds with GetSecurityConfigurationOutput with field(s):
- security_configuration(Option<SecurityConfiguration>):
  The requested security configuration.
On failure, responds with SdkError<GetSecurityConfigurationError>

source

pub fn get_security_configurations(&self) -> GetSecurityConfigurations

Constructs a fluent builder for the GetSecurityConfigurations operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of results to return.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
On success, responds with GetSecurityConfigurationsOutput with field(s):
- security_configurations(Option<Vec<SecurityConfiguration>>):
  A list of security configurations.
- next_token(Option<String>):
  A continuation token, if there are more security configurations to return.
On failure, responds with SdkError<GetSecurityConfigurationsError>

source

pub fn get_session(&self) -> GetSession

Constructs a fluent builder for the GetSession operation.

The fluent builder is configurable:
- id(impl Into<String>) / set_id(Option<String>):
  The ID of the session.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request.
On success, responds with GetSessionOutput with field(s):
- session(Option<Session>):
  The session object is returned in the response.
On failure, responds with SdkError<GetSessionError>

source

pub fn get_statement(&self) -> GetStatement

Constructs a fluent builder for the GetStatement operation.

The fluent builder is configurable:
- session_id(impl Into<String>) / set_session_id(Option<String>):
  The Session ID of the statement.
- id(i32) / set_id(i32):
  The Id of the statement.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request.
On success, responds with GetStatementOutput with field(s):
- statement(Option<Statement>):
  Returns the statement.
On failure, responds with SdkError<GetStatementError>

source

pub fn get_table(&self) -> GetTable

Constructs a fluent builder for the GetTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the table resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.
- name(impl Into<String>) / set_name(Option<String>):
  The name of the table for which to retrieve the definition. For Hive compatibility, this name is entirely lowercase.
- transaction_id(impl Into<String>) / set_transaction_id(Option<String>):
  The transaction ID at which to read the table contents.
- query_as_of_time(DateTime) / set_query_as_of_time(Option<DateTime>):
  The time as of when to read the table contents. If not set, the most recent transaction commit time will be used. Cannot be specified along with TransactionId.
On success, responds with GetTableOutput with field(s):
- table(Option<Table>):
  The Table object that defines the specified table.
On failure, responds with SdkError<GetTableError>

source

pub fn get_tables(&self) -> GetTables

Constructs a fluent builder for the GetTables operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the tables reside. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The database in the catalog whose tables to list. For Hive compatibility, this name is entirely lowercase.
- expression(impl Into<String>) / set_expression(Option<String>):
  A regular expression pattern. If present, only those tables whose names match the pattern are returned.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, included if this is a continuation call.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of tables to return in a single response.
- transaction_id(impl Into<String>) / set_transaction_id(Option<String>):
  The transaction ID at which to read the table contents.
- query_as_of_time(DateTime) / set_query_as_of_time(Option<DateTime>):
  The time as of when to read the table contents. If not set, the most recent transaction commit time will be used. Cannot be specified along with TransactionId.
On success, responds with GetTablesOutput with field(s):
- table_list(Option<Vec<Table>>):
  A list of the requested Table objects.
- next_token(Option<String>):
  A continuation token, present if the current list segment is not the last.
On failure, responds with SdkError<GetTablesError>

source

pub fn get_table_version(&self) -> GetTableVersion

Constructs a fluent builder for the GetTableVersion operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the tables reside. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the table. For Hive compatibility, this name is entirely lowercase.
- version_id(impl Into<String>) / set_version_id(Option<String>):
  The ID value of the table version to be retrieved. A VersionID is a string representation of an integer. Each version is incremented by 1.
On success, responds with GetTableVersionOutput with field(s):
- table_version(Option<TableVersion>):
  The requested table version.
On failure, responds with SdkError<GetTableVersionError>

source

pub fn get_table_versions(&self) -> GetTableVersions

Constructs a fluent builder for the GetTableVersions operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the tables reside. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the table. For Hive compatibility, this name is entirely lowercase.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is not the first call.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of table versions to return in one response.
On success, responds with GetTableVersionsOutput with field(s):
- table_versions(Option<Vec<TableVersion>>):
  A list of strings identifying available versions of the specified table.
- next_token(Option<String>):
  A continuation token, if the list of available versions does not include the last one.
On failure, responds with SdkError<GetTableVersionsError>

source

pub fn get_tags(&self) -> GetTags

Constructs a fluent builder for the GetTags operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
  The Amazon Resource Name (ARN) of the resource for which to retrieve tags.
On success, responds with GetTagsOutput with field(s):
- tags(Option<HashMap<String, String>>):
  The requested tags.
On failure, responds with SdkError<GetTagsError>

source

pub fn get_trigger(&self) -> GetTrigger

Constructs a fluent builder for the GetTrigger operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the trigger to retrieve.
On success, responds with GetTriggerOutput with field(s):
- trigger(Option<Trigger>):
  The requested trigger definition.
On failure, responds with SdkError<GetTriggerError>

source

pub fn get_triggers(&self) -> GetTriggers

Constructs a fluent builder for the GetTriggers operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
- dependent_job_name(impl Into<String>) / set_dependent_job_name(Option<String>):
  The name of the job to retrieve triggers for. The trigger that can start this job is returned, and if there is no such trigger, all triggers are returned.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of the response.
On success, responds with GetTriggersOutput with field(s):
- triggers(Option<Vec<Trigger>>):
  A list of triggers for the specified job.
- next_token(Option<String>):
  A continuation token, if not all the requested triggers have yet been returned.
On failure, responds with SdkError<GetTriggersError>

source

pub fn get_unfiltered_partition_metadata(
&self
) -> GetUnfilteredPartitionMetadata

Constructs a fluent builder for the GetUnfilteredPartitionMetadata operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>): (undocumented)
- database_name(impl Into<String>) / set_database_name(Option<String>): (undocumented)
- table_name(impl Into<String>) / set_table_name(Option<String>): (undocumented)
- partition_values(Vec<String>) / set_partition_values(Option<Vec<String>>): (undocumented)
- audit_context(AuditContext) / set_audit_context(Option<AuditContext>):
  A structure containing information for audit.
- supported_permission_types(Vec<PermissionType>) / set_supported_permission_types(Option<Vec<PermissionType>>): (undocumented)
On success, responds with GetUnfilteredPartitionMetadataOutput with field(s):
- partition(Option<Partition>):
  Represents a slice of table data.
- authorized_columns(Option<Vec<String>>): (undocumented)
- is_registered_with_lake_formation(bool): (undocumented)
On failure, responds with SdkError<GetUnfilteredPartitionMetadataError>

source

pub fn get_unfiltered_partitions_metadata(
&self
) -> GetUnfilteredPartitionsMetadata

Constructs a fluent builder for the GetUnfilteredPartitionsMetadata operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>): (undocumented)
- database_name(impl Into<String>) / set_database_name(Option<String>): (undocumented)
- table_name(impl Into<String>) / set_table_name(Option<String>): (undocumented)
- expression(impl Into<String>) / set_expression(Option<String>): (undocumented)
- audit_context(AuditContext) / set_audit_context(Option<AuditContext>):
  A structure containing information for audit.
- supported_permission_types(Vec<PermissionType>) / set_supported_permission_types(Option<Vec<PermissionType>>): (undocumented)
- next_token(impl Into<String>) / set_next_token(Option<String>): (undocumented)
- segment(Segment) / set_segment(Option<Segment>):
  Defines a non-overlapping region of a table’s partitions, allowing multiple requests to be run in parallel.
- max_results(i32) / set_max_results(Option<i32>): (undocumented)
On success, responds with GetUnfilteredPartitionsMetadataOutput with field(s):
- unfiltered_partitions(Option<Vec<UnfilteredPartition>>): (undocumented)
- next_token(Option<String>): (undocumented)
On failure, responds with SdkError<GetUnfilteredPartitionsMetadataError>

source

pub fn get_unfiltered_table_metadata(&self) -> GetUnfilteredTableMetadata

Constructs a fluent builder for the GetUnfilteredTableMetadata operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>): (undocumented)
- database_name(impl Into<String>) / set_database_name(Option<String>): (undocumented)
- name(impl Into<String>) / set_name(Option<String>): (undocumented)
- audit_context(AuditContext) / set_audit_context(Option<AuditContext>):
  A structure containing information for audit.
- supported_permission_types(Vec<PermissionType>) / set_supported_permission_types(Option<Vec<PermissionType>>): (undocumented)
On success, responds with GetUnfilteredTableMetadataOutput with field(s):
- table(Option<Table>):
  Represents a collection of related data organized in columns and rows.
- authorized_columns(Option<Vec<String>>): (undocumented)
- is_registered_with_lake_formation(bool): (undocumented)
- cell_filters(Option<Vec<ColumnRowFilter>>): (undocumented)
On failure, responds with SdkError<GetUnfilteredTableMetadataError>

source

pub fn get_user_defined_function(&self) -> GetUserDefinedFunction

Constructs a fluent builder for the GetUserDefinedFunction operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the function to be retrieved is located. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the function is located.
- function_name(impl Into<String>) / set_function_name(Option<String>):
  The name of the function.
On success, responds with GetUserDefinedFunctionOutput with field(s):
- user_defined_function(Option<UserDefinedFunction>):
  The requested function definition.
On failure, responds with SdkError<GetUserDefinedFunctionError>

source

pub fn get_user_defined_functions(&self) -> GetUserDefinedFunctions

Constructs a fluent builder for the GetUserDefinedFunctions operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the functions to be retrieved are located. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the functions are located. If none is provided, functions from all the databases across the catalog will be returned.
- pattern(impl Into<String>) / set_pattern(Option<String>):
  An optional function-name pattern string that filters the function definitions returned.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of functions to return in one response.
On success, responds with GetUserDefinedFunctionsOutput with field(s):
- user_defined_functions(Option<Vec<UserDefinedFunction>>):
  A list of requested function definitions.
- next_token(Option<String>):
  A continuation token, if the list of functions returned does not include the last requested function.
On failure, responds with SdkError<GetUserDefinedFunctionsError>

source

pub fn get_workflow(&self) -> GetWorkflow

Constructs a fluent builder for the GetWorkflow operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the workflow to retrieve.
- include_graph(bool) / set_include_graph(Option<bool>):
  Specifies whether to include a graph when returning the workflow resource metadata.
On success, responds with GetWorkflowOutput with field(s):
- workflow(Option<Workflow>):
  The resource metadata for the workflow.
On failure, responds with SdkError<GetWorkflowError>

source

pub fn get_workflow_run(&self) -> GetWorkflowRun

Constructs a fluent builder for the GetWorkflowRun operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the workflow being run.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The ID of the workflow run.
- include_graph(bool) / set_include_graph(Option<bool>):
  Specifies whether to include the workflow graph in response or not.
On success, responds with GetWorkflowRunOutput with field(s):
- run(Option<WorkflowRun>):
  The requested workflow run metadata.
On failure, responds with SdkError<GetWorkflowRunError>

source

pub fn get_workflow_run_properties(&self) -> GetWorkflowRunProperties

Constructs a fluent builder for the GetWorkflowRunProperties operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the workflow which was run.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The ID of the workflow run whose run properties should be returned.
On success, responds with GetWorkflowRunPropertiesOutput with field(s):
- run_properties(Option<HashMap<String, String>>):
  The workflow run properties which were set during the specified run.
On failure, responds with SdkError<GetWorkflowRunPropertiesError>

source

pub fn get_workflow_runs(&self) -> GetWorkflowRuns

Constructs a fluent builder for the GetWorkflowRuns operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the workflow whose metadata of runs should be returned.
- include_graph(bool) / set_include_graph(Option<bool>):
  Specifies whether to include the workflow graph in response or not.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  The maximum size of the response.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of workflow runs to be included in the response.
On success, responds with GetWorkflowRunsOutput with field(s):
- runs(Option<Vec<WorkflowRun>>):
  A list of workflow run metadata objects.
- next_token(Option<String>):
  A continuation token, if not all requested workflow runs have been returned.
On failure, responds with SdkError<GetWorkflowRunsError>

source

pub fn import_catalog_to_glue(&self) -> ImportCatalogToGlue

Constructs a fluent builder for the ImportCatalogToGlue operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the catalog to import. Currently, this should be the Amazon Web Services account ID.
On success, responds with ImportCatalogToGlueOutput
On failure, responds with SdkError<ImportCatalogToGlueError>

source

pub fn list_blueprints(&self) -> ListBlueprints

Constructs a fluent builder for the ListBlueprints operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Filters the list by an Amazon Web Services resource tag.
On success, responds with ListBlueprintsOutput with field(s):
- blueprints(Option<Vec<String>>):
  List of names of blueprints in the account.
- next_token(Option<String>):
  A continuation token, if not all blueprint names have been returned.
On failure, responds with SdkError<ListBlueprintsError>

source

pub fn list_crawlers(&self) -> ListCrawlers

Constructs a fluent builder for the ListCrawlers operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Specifies to return only these tagged resources.
On success, responds with ListCrawlersOutput with field(s):
- crawler_names(Option<Vec<String>>):
  The names of all crawlers in the account, or the crawlers with the specified tags.
- next_token(Option<String>):
  A continuation token, if the returned list does not contain the last metric available.
On failure, responds with SdkError<ListCrawlersError>

source

pub fn list_custom_entity_types(&self) -> ListCustomEntityTypes

Constructs a fluent builder for the ListCustomEntityTypes operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A paginated token to offset the results.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of results to return.
On success, responds with ListCustomEntityTypesOutput with field(s):
- custom_entity_types(Option<Vec<CustomEntityType>>):
  A list of CustomEntityType objects representing custom patterns.
- next_token(Option<String>):
  A pagination token, if more results are available.
On failure, responds with SdkError<ListCustomEntityTypesError>

source

pub fn list_dev_endpoints(&self) -> ListDevEndpoints

Constructs a fluent builder for the ListDevEndpoints operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Specifies to return only these tagged resources.
On success, responds with ListDevEndpointsOutput with field(s):
- dev_endpoint_names(Option<Vec<String>>):
  The names of all the DevEndpoints in the account, or the DevEndpoints with the specified tags.
- next_token(Option<String>):
  A continuation token, if the returned list does not contain the last metric available.
On failure, responds with SdkError<ListDevEndpointsError>

source

pub fn list_jobs(&self) -> ListJobs

Constructs a fluent builder for the ListJobs operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Specifies to return only these tagged resources.
On success, responds with ListJobsOutput with field(s):
- job_names(Option<Vec<String>>):
  The names of all jobs in the account, or the jobs with the specified tags.
- next_token(Option<String>):
  A continuation token, if the returned list does not contain the last metric available.
On failure, responds with SdkError<ListJobsError>

source

pub fn list_ml_transforms(&self) -> ListMLTransforms

Constructs a fluent builder for the ListMLTransforms operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
- filter(TransformFilterCriteria) / set_filter(Option<TransformFilterCriteria>):
  A TransformFilterCriteria used to filter the machine learning transforms.
- sort(TransformSortCriteria) / set_sort(Option<TransformSortCriteria>):
  A TransformSortCriteria used to sort the machine learning transforms.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Specifies to return only these tagged resources.
On success, responds with ListMlTransformsOutput with field(s):
- transform_ids(Option<Vec<String>>):
  The identifiers of all the machine learning transforms in the account, or the machine learning transforms with the specified tags.
- next_token(Option<String>):
  A continuation token, if the returned list does not contain the last metric available.
On failure, responds with SdkError<ListMLTransformsError>

source

pub fn list_registries(&self) -> ListRegistries

Constructs a fluent builder for the ListRegistries operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- max_results(i32) / set_max_results(Option<i32>):
  Maximum number of results required per page. If the value is not supplied, this will be defaulted to 25 per page.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
On success, responds with ListRegistriesOutput with field(s):
- registries(Option<Vec<RegistryListItem>>):
  An array of RegistryDetailedListItem objects containing minimal details of each registry.
- next_token(Option<String>):
  A continuation token for paginating the returned list of tokens, returned if the current segment of the list is not the last.
On failure, responds with SdkError<ListRegistriesError>

source

pub fn list_schemas(&self) -> ListSchemas

Constructs a fluent builder for the ListSchemas operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- registry_id(RegistryId) / set_registry_id(Option<RegistryId>):
  A wrapper structure that may contain the registry name and Amazon Resource Name (ARN).
- max_results(i32) / set_max_results(Option<i32>):
  Maximum number of results required per page. If the value is not supplied, this will be defaulted to 25 per page.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
On success, responds with ListSchemasOutput with field(s):
- schemas(Option<Vec<SchemaListItem>>):
  An array of SchemaListItem objects containing details of each schema.
- next_token(Option<String>):
  A continuation token for paginating the returned list of tokens, returned if the current segment of the list is not the last.
On failure, responds with SdkError<ListSchemasError>

source

pub fn list_schema_versions(&self) -> ListSchemaVersions

Constructs a fluent builder for the ListSchemaVersions operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure to contain schema identity fields. The structure contains:
  - SchemaId$SchemaArn: The Amazon Resource Name (ARN) of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
  - SchemaId$SchemaName: The name of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
- max_results(i32) / set_max_results(Option<i32>):
  Maximum number of results required per page. If the value is not supplied, this will be defaulted to 25 per page.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
On success, responds with ListSchemaVersionsOutput with field(s):
- schemas(Option<Vec<SchemaVersionListItem>>):
  An array of SchemaVersionList objects containing details of each schema version.
- next_token(Option<String>):
  A continuation token for paginating the returned list of tokens, returned if the current segment of the list is not the last.
On failure, responds with SdkError<ListSchemaVersionsError>

source

pub fn list_sessions(&self) -> ListSessions

Constructs a fluent builder for the ListSessions operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  The token for the next set of results, or null if there are no more result.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of results.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Tags belonging to the session.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request.
On success, responds with ListSessionsOutput with field(s):
- ids(Option<Vec<String>>):
  Returns the Id of the session.
- sessions(Option<Vec<Session>>):
  Returns the session object.
- next_token(Option<String>):
  The token for the next set of results, or null if there are no more result.
On failure, responds with SdkError<ListSessionsError>

source

pub fn list_statements(&self) -> ListStatements

Constructs a fluent builder for the ListStatements operation.

The fluent builder is configurable:
- session_id(impl Into<String>) / set_session_id(Option<String>):
  The Session ID of the statements.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request to list statements.
- next_token(impl Into<String>) / set_next_token(Option<String>): (undocumented)
On success, responds with ListStatementsOutput with field(s):
- statements(Option<Vec<Statement>>):
  Returns the list of statements.
- next_token(Option<String>): (undocumented)
On failure, responds with SdkError<ListStatementsError>

source

pub fn list_triggers(&self) -> ListTriggers

Constructs a fluent builder for the ListTriggers operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- dependent_job_name(impl Into<String>) / set_dependent_job_name(Option<String>):
  The name of the job for which to retrieve triggers. The trigger that can start this job is returned. If there is no such trigger, all triggers are returned.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
- tags(HashMap<String, String>) / set_tags(Option<HashMap<String, String>>):
  Specifies to return only these tagged resources.
On success, responds with ListTriggersOutput with field(s):
- trigger_names(Option<Vec<String>>):
  The names of all triggers in the account, or the triggers with the specified tags.
- next_token(Option<String>):
  A continuation token, if the returned list does not contain the last metric available.
On failure, responds with SdkError<ListTriggersError>

source

pub fn list_workflows(&self) -> ListWorkflows

Constructs a fluent builder for the ListWorkflows operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation request.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum size of a list to return.
On success, responds with ListWorkflowsOutput with field(s):
- workflows(Option<Vec<String>>):
  List of names of workflows in the account.
- next_token(Option<String>):
  A continuation token, if not all workflow names have been returned.
On failure, responds with SdkError<ListWorkflowsError>

source

pub fn put_data_catalog_encryption_settings(
&self
) -> PutDataCatalogEncryptionSettings

Constructs a fluent builder for the PutDataCatalogEncryptionSettings operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog to set the security configuration for. If none is provided, the Amazon Web Services account ID is used by default.
- data_catalog_encryption_settings(DataCatalogEncryptionSettings) / set_data_catalog_encryption_settings(Option<DataCatalogEncryptionSettings>):
  The security configuration to set.
On success, responds with PutDataCatalogEncryptionSettingsOutput
On failure, responds with SdkError<PutDataCatalogEncryptionSettingsError>

source

pub fn put_resource_policy(&self) -> PutResourcePolicy

Constructs a fluent builder for the PutResourcePolicy operation.

The fluent builder is configurable:
- policy_in_json(impl Into<String>) / set_policy_in_json(Option<String>):
  Contains the policy document to set, in JSON format.
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
  Do not use. For internal use only.
- policy_hash_condition(impl Into<String>) / set_policy_hash_condition(Option<String>):
  The hash value returned when the previous policy was set using PutResourcePolicy. Its purpose is to prevent concurrent modifications of a policy. Do not use this parameter if no previous policy has been set.
- policy_exists_condition(ExistCondition) / set_policy_exists_condition(Option<ExistCondition>):
  A value of MUST_EXIST is used to update a policy. A value of NOT_EXIST is used to create a new policy. If a value of NONE or a null value is used, the call does not depend on the existence of a policy.
- enable_hybrid(EnableHybridValues) / set_enable_hybrid(Option<EnableHybridValues>):
  If ‘TRUE’, indicates that you are using both methods to grant cross-account access to Data Catalog resources:
  - By directly updating the resource policy with PutResourePolicy
  - By using the Grant permissions command on the Amazon Web Services Management Console.
  Must be set to ‘TRUE’ if you have already used the Management Console to grant cross-account access, otherwise the call fails. Default is ‘FALSE’.
On success, responds with PutResourcePolicyOutput with field(s):
- policy_hash(Option<String>):
  A hash of the policy that has just been set. This must be included in a subsequent call that overwrites or updates this policy.
On failure, responds with SdkError<PutResourcePolicyError>

source

pub fn put_schema_version_metadata(&self) -> PutSchemaVersionMetadata

Constructs a fluent builder for the PutSchemaVersionMetadata operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  The unique ID for the schema.
- schema_version_number(SchemaVersionNumber) / set_schema_version_number(Option<SchemaVersionNumber>):
  The version number of the schema.
- schema_version_id(impl Into<String>) / set_schema_version_id(Option<String>):
  The unique version ID of the schema version.
- metadata_key_value(MetadataKeyValuePair) / set_metadata_key_value(Option<MetadataKeyValuePair>):
  The metadata key’s corresponding value.
On success, responds with PutSchemaVersionMetadataOutput with field(s):
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) for the schema.
- schema_name(Option<String>):
  The name for the schema.
- registry_name(Option<String>):
  The name for the registry.
- latest_version(bool):
  The latest version of the schema.
- version_number(i64):
  The version number of the schema.
- schema_version_id(Option<String>):
  The unique version ID of the schema version.
- metadata_key(Option<String>):
  The metadata key.
- metadata_value(Option<String>):
  The value of the metadata key.
On failure, responds with SdkError<PutSchemaVersionMetadataError>

source

pub fn put_workflow_run_properties(&self) -> PutWorkflowRunProperties

Constructs a fluent builder for the PutWorkflowRunProperties operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the workflow which was run.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The ID of the workflow run for which the run properties should be updated.
- run_properties(HashMap<String, String>) / set_run_properties(Option<HashMap<String, String>>):
  The properties to put for the specified run.
On success, responds with PutWorkflowRunPropertiesOutput
On failure, responds with SdkError<PutWorkflowRunPropertiesError>

source

pub fn query_schema_version_metadata(&self) -> QuerySchemaVersionMetadata

Constructs a fluent builder for the QuerySchemaVersionMetadata operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  A wrapper structure that may contain the schema name and Amazon Resource Name (ARN).
- schema_version_number(SchemaVersionNumber) / set_schema_version_number(Option<SchemaVersionNumber>):
  The version number of the schema.
- schema_version_id(impl Into<String>) / set_schema_version_id(Option<String>):
  The unique version ID of the schema version.
- metadata_list(Vec<MetadataKeyValuePair>) / set_metadata_list(Option<Vec<MetadataKeyValuePair>>):
  Search key-value pairs for metadata, if they are not provided all the metadata information will be fetched.
- max_results(i32) / set_max_results(i32):
  Maximum number of results required per page. If the value is not supplied, this will be defaulted to 25 per page.
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, if this is a continuation call.
On success, responds with QuerySchemaVersionMetadataOutput with field(s):
- metadata_info_map(Option<HashMap<String, MetadataInfo>>):
  A map of a metadata key and associated values.
- schema_version_id(Option<String>):
  The unique version ID of the schema version.
- next_token(Option<String>):
  A continuation token for paginating the returned list of tokens, returned if the current segment of the list is not the last.
On failure, responds with SdkError<QuerySchemaVersionMetadataError>

source

pub fn register_schema_version(&self) -> RegisterSchemaVersion

Constructs a fluent builder for the RegisterSchemaVersion operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure to contain schema identity fields. The structure contains:
  - SchemaId$SchemaArn: The Amazon Resource Name (ARN) of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
  - SchemaId$SchemaName: The name of the schema. Either SchemaArn or SchemaName and RegistryName has to be provided.
- schema_definition(impl Into<String>) / set_schema_definition(Option<String>):
  The schema definition using the DataFormat setting for the SchemaName.
On success, responds with RegisterSchemaVersionOutput with field(s):
- schema_version_id(Option<String>):
  The unique ID that represents the version of this schema.
- version_number(i64):
  The version of this schema (for sync flow only, in case this is the first version).
- status(Option<SchemaVersionStatus>):
  The status of the schema version.
On failure, responds with SdkError<RegisterSchemaVersionError>

source

pub fn remove_schema_version_metadata(&self) -> RemoveSchemaVersionMetadata

Constructs a fluent builder for the RemoveSchemaVersionMetadata operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  A wrapper structure that may contain the schema name and Amazon Resource Name (ARN).
- schema_version_number(SchemaVersionNumber) / set_schema_version_number(Option<SchemaVersionNumber>):
  The version number of the schema.
- schema_version_id(impl Into<String>) / set_schema_version_id(Option<String>):
  The unique version ID of the schema version.
- metadata_key_value(MetadataKeyValuePair) / set_metadata_key_value(Option<MetadataKeyValuePair>):
  The value of the metadata key.
On success, responds with RemoveSchemaVersionMetadataOutput with field(s):
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) of the schema.
- schema_name(Option<String>):
  The name of the schema.
- registry_name(Option<String>):
  The name of the registry.
- latest_version(bool):
  The latest version of the schema.
- version_number(i64):
  The version number of the schema.
- schema_version_id(Option<String>):
  The version ID for the schema version.
- metadata_key(Option<String>):
  The metadata key.
- metadata_value(Option<String>):
  The value of the metadata key.
On failure, responds with SdkError<RemoveSchemaVersionMetadataError>

source

pub fn reset_job_bookmark(&self) -> ResetJobBookmark

Constructs a fluent builder for the ResetJobBookmark operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job in question.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The unique run identifier associated with this job run.
On success, responds with ResetJobBookmarkOutput with field(s):
- job_bookmark_entry(Option<JobBookmarkEntry>):
  The reset bookmark entry.
On failure, responds with SdkError<ResetJobBookmarkError>

source

pub fn resume_workflow_run(&self) -> ResumeWorkflowRun

Constructs a fluent builder for the ResumeWorkflowRun operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the workflow to resume.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The ID of the workflow run to resume.
- node_ids(Vec<String>) / set_node_ids(Option<Vec<String>>):
  A list of the node IDs for the nodes you want to restart. The nodes that are to be restarted must have a run attempt in the original run.
On success, responds with ResumeWorkflowRunOutput with field(s):
- run_id(Option<String>):
  The new ID assigned to the resumed workflow run. Each resume of a workflow run will have a new run ID.
- node_ids(Option<Vec<String>>):
  A list of the node IDs for the nodes that were actually restarted.
On failure, responds with SdkError<ResumeWorkflowRunError>

source

pub fn run_statement(&self) -> RunStatement

Constructs a fluent builder for the RunStatement operation.

The fluent builder is configurable:
- session_id(impl Into<String>) / set_session_id(Option<String>):
  The Session Id of the statement to be run.
- code(impl Into<String>) / set_code(Option<String>):
  The statement code to be run.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request.
On success, responds with RunStatementOutput with field(s):
- id(i32):
  Returns the Id of the statement that was run.
On failure, responds with SdkError<RunStatementError>

source

pub fn search_tables(&self) -> SearchTables

Constructs a fluent builder for the SearchTables operation. This operation supports pagination; See into_paginator().

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  A unique identifier, consisting of account_id .
- next_token(impl Into<String>) / set_next_token(Option<String>):
  A continuation token, included if this is a continuation call.
- filters(Vec<PropertyPredicate>) / set_filters(Option<Vec<PropertyPredicate>>):
  A list of key-value pairs, and a comparator used to filter the search results. Returns all entities matching the predicate.
  
  The Comparator member of the PropertyPredicate struct is used only for time fields, and can be omitted for other field types. Also, when comparing string values, such as when Key=Name, a fuzzy match algorithm is used. The Key field (for example, the value of the Name field) is split on certain punctuation characters, for example, -, :, #, etc. into tokens. Then each token is exact-match compared with the Value member of PropertyPredicate. For example, if Key=Name and Value=link, tables named customer-link and xx-link-yy are returned, but xxlinkyy is not returned.
- search_text(impl Into<String>) / set_search_text(Option<String>):
  A string used for a text search.
  
  Specifying a value in quotes filters based on an exact match to the value.
- sort_criteria(Vec<SortCriterion>) / set_sort_criteria(Option<Vec<SortCriterion>>):
  A list of criteria for sorting the results by a field name, in an ascending or descending order.
- max_results(i32) / set_max_results(Option<i32>):
  The maximum number of tables to return in a single response.
- resource_share_type(ResourceShareType) / set_resource_share_type(Option<ResourceShareType>):
  Allows you to specify that you want to search the tables shared with your account. The allowable values are FOREIGN or ALL.
  - If set to FOREIGN, will search the tables shared with your account.
  - If set to ALL, will search the tables shared with your account, as well as the tables in yor local account.
On success, responds with SearchTablesOutput with field(s):
- next_token(Option<String>):
  A continuation token, present if the current list segment is not the last.
- table_list(Option<Vec<Table>>):
  A list of the requested Table objects. The SearchTables response returns only the tables that you have access to.
On failure, responds with SdkError<SearchTablesError>

source

pub fn start_blueprint_run(&self) -> StartBlueprintRun

Constructs a fluent builder for the StartBlueprintRun operation.

The fluent builder is configurable:
- blueprint_name(impl Into<String>) / set_blueprint_name(Option<String>):
  The name of the blueprint.
- parameters(impl Into<String>) / set_parameters(Option<String>):
  Specifies the parameters as a BlueprintParameters object.
- role_arn(impl Into<String>) / set_role_arn(Option<String>):
  Specifies the IAM role used to create the workflow.
On success, responds with StartBlueprintRunOutput with field(s):
- run_id(Option<String>):
  The run ID for this blueprint run.
On failure, responds with SdkError<StartBlueprintRunError>

source

pub fn start_crawler(&self) -> StartCrawler

Constructs a fluent builder for the StartCrawler operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the crawler to start.
On success, responds with StartCrawlerOutput
On failure, responds with SdkError<StartCrawlerError>

source

pub fn start_crawler_schedule(&self) -> StartCrawlerSchedule

Constructs a fluent builder for the StartCrawlerSchedule operation.

The fluent builder is configurable:
- crawler_name(impl Into<String>) / set_crawler_name(Option<String>):
  Name of the crawler to schedule.
On success, responds with StartCrawlerScheduleOutput
On failure, responds with SdkError<StartCrawlerScheduleError>

source

pub fn start_export_labels_task_run(&self) -> StartExportLabelsTaskRun

Constructs a fluent builder for the StartExportLabelsTaskRun operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the machine learning transform.
- output_s3_path(impl Into<String>) / set_output_s3_path(Option<String>):
  The Amazon S3 path where you export the labels.
On success, responds with StartExportLabelsTaskRunOutput with field(s):
- task_run_id(Option<String>):
  The unique identifier for the task run.
On failure, responds with SdkError<StartExportLabelsTaskRunError>

source

pub fn start_import_labels_task_run(&self) -> StartImportLabelsTaskRun

Constructs a fluent builder for the StartImportLabelsTaskRun operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the machine learning transform.
- input_s3_path(impl Into<String>) / set_input_s3_path(Option<String>):
  The Amazon Simple Storage Service (Amazon S3) path from where you import the labels.
- replace_all_labels(bool) / set_replace_all_labels(bool):
  Indicates whether to overwrite your existing labels.
On success, responds with StartImportLabelsTaskRunOutput with field(s):
- task_run_id(Option<String>):
  The unique identifier for the task run.
On failure, responds with SdkError<StartImportLabelsTaskRunError>

source

pub fn start_job_run(&self) -> StartJobRun

Constructs a fluent builder for the StartJobRun operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job definition to use.
- job_run_id(impl Into<String>) / set_job_run_id(Option<String>):
  The ID of a previous JobRun to retry.
- arguments(HashMap<String, String>) / set_arguments(Option<HashMap<String, String>>):
  The job arguments specifically for this run. For this job run, they replace the default arguments set in the job definition itself.
  
  You can specify arguments here that your own job-execution script consumes, as well as arguments that Glue itself consumes.
  
  For information about how to specify and consume your own Job arguments, see the Calling Glue APIs in Python topic in the developer guide.
  
  For information about the key-value pairs that Glue consumes to set up your job, see the Special Parameters Used by Glue topic in the developer guide.
- allocated_capacity(i32) / set_allocated_capacity(i32):
  This field is deprecated. Use MaxCapacity instead.
  
  The number of Glue data processing units (DPUs) to allocate to this JobRun. From 2 to 100 DPUs can be allocated; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory. For more information, see the Glue pricing page.
- timeout(i32) / set_timeout(Option<i32>):
  The JobRun timeout in minutes. This is the maximum time that a job run can consume resources before it is terminated and enters TIMEOUT status. The default is 2,880 minutes (48 hours). This overrides the timeout value set in the parent job.
- max_capacity(f64) / set_max_capacity(Option<f64>):
  The number of Glue data processing units (DPUs) that can be allocated when this job runs. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory. For more information, see the Glue pricing page.
  
  Do not set Max Capacity if using WorkerType and NumberOfWorkers.
  
  The value that can be allocated for MaxCapacity depends on whether you are running a Python shell job, or an Apache Spark ETL job:
  - When you specify a Python shell job (JobCommand.Name=“pythonshell”), you can allocate either 0.0625 or 1 DPU. The default is 0.0625 DPU.
  - When you specify an Apache Spark ETL job (JobCommand.Name=“glueetl”), you can allocate from 2 to 100 DPUs. The default is 10 DPUs. This job type cannot have a fractional DPU allocation.
- security_configuration(impl Into<String>) / set_security_configuration(Option<String>):
  The name of the SecurityConfiguration structure to be used with this job run.
- notification_property(NotificationProperty) / set_notification_property(Option<NotificationProperty>):
  Specifies configuration properties of a job run notification.
- worker_type(WorkerType) / set_worker_type(Option<WorkerType>):
  The type of predefined worker that is allocated when a job runs. Accepts a value of Standard, G.1X, or G.2X.
  - For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.
  - For the G.1X worker type, each worker provides 4 vCPU, 16 GB of memory and a 64GB disk, and 1 executor per worker.
  - For the G.2X worker type, each worker provides 8 vCPU, 32 GB of memory and a 128GB disk, and 1 executor per worker.
- number_of_workers(i32) / set_number_of_workers(Option<i32>):
  The number of workers of a defined workerType that are allocated when a job runs.
  
  The maximum number of workers you can define are 299 for G.1X, and 149 for G.2X.
On success, responds with StartJobRunOutput with field(s):
- job_run_id(Option<String>):
  The ID assigned to this job run.
On failure, responds with SdkError<StartJobRunError>

source

pub fn start_ml_evaluation_task_run(&self) -> StartMLEvaluationTaskRun

Constructs a fluent builder for the StartMLEvaluationTaskRun operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the machine learning transform.
On success, responds with StartMlEvaluationTaskRunOutput with field(s):
- task_run_id(Option<String>):
  The unique identifier associated with this run.
On failure, responds with SdkError<StartMLEvaluationTaskRunError>

source

pub fn start_ml_labeling_set_generation_task_run(
&self
) -> StartMLLabelingSetGenerationTaskRun

Constructs a fluent builder for the StartMLLabelingSetGenerationTaskRun operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  The unique identifier of the machine learning transform.
- output_s3_path(impl Into<String>) / set_output_s3_path(Option<String>):
  The Amazon Simple Storage Service (Amazon S3) path where you generate the labeling set.
On success, responds with StartMlLabelingSetGenerationTaskRunOutput with field(s):
- task_run_id(Option<String>):
  The unique run identifier that is associated with this task run.
On failure, responds with SdkError<StartMLLabelingSetGenerationTaskRunError>

source

pub fn start_trigger(&self) -> StartTrigger

Constructs a fluent builder for the StartTrigger operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the trigger to start.
On success, responds with StartTriggerOutput with field(s):
- name(Option<String>):
  The name of the trigger that was started.
On failure, responds with SdkError<StartTriggerError>

source

pub fn start_workflow_run(&self) -> StartWorkflowRun

Constructs a fluent builder for the StartWorkflowRun operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the workflow to start.
- run_properties(HashMap<String, String>) / set_run_properties(Option<HashMap<String, String>>):
  The workflow run properties for the new workflow run.
On success, responds with StartWorkflowRunOutput with field(s):
- run_id(Option<String>):
  An Id for the new run.
On failure, responds with SdkError<StartWorkflowRunError>

source

pub fn stop_crawler(&self) -> StopCrawler

Constructs a fluent builder for the StopCrawler operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the crawler to stop.
On success, responds with StopCrawlerOutput
On failure, responds with SdkError<StopCrawlerError>

source

pub fn stop_crawler_schedule(&self) -> StopCrawlerSchedule

Constructs a fluent builder for the StopCrawlerSchedule operation.

The fluent builder is configurable:
- crawler_name(impl Into<String>) / set_crawler_name(Option<String>):
  Name of the crawler whose schedule state to set.
On success, responds with StopCrawlerScheduleOutput
On failure, responds with SdkError<StopCrawlerScheduleError>

source

pub fn stop_session(&self) -> StopSession

Constructs a fluent builder for the StopSession operation.

The fluent builder is configurable:
- id(impl Into<String>) / set_id(Option<String>):
  The ID of the session to be stopped.
- request_origin(impl Into<String>) / set_request_origin(Option<String>):
  The origin of the request.
On success, responds with StopSessionOutput with field(s):
- id(Option<String>):
  Returns the Id of the stopped session.
On failure, responds with SdkError<StopSessionError>

source

pub fn stop_trigger(&self) -> StopTrigger

Constructs a fluent builder for the StopTrigger operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the trigger to stop.
On success, responds with StopTriggerOutput with field(s):
- name(Option<String>):
  The name of the trigger that was stopped.
On failure, responds with SdkError<StopTriggerError>

source

pub fn stop_workflow_run(&self) -> StopWorkflowRun

Constructs a fluent builder for the StopWorkflowRun operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the workflow to stop.
- run_id(impl Into<String>) / set_run_id(Option<String>):
  The ID of the workflow run to stop.
On success, responds with StopWorkflowRunOutput
On failure, responds with SdkError<StopWorkflowRunError>

source

pub fn tag_resource(&self) -> TagResource

Constructs a fluent builder for the TagResource operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
  The ARN of the Glue resource to which to add the tags. For more information about Glue resource ARNs, see the Glue ARN string pattern.
- tags_to_add(HashMap<String, String>) / set_tags_to_add(Option<HashMap<String, String>>):
  Tags to add to this resource.
On success, responds with TagResourceOutput
On failure, responds with SdkError<TagResourceError>

source

pub fn untag_resource(&self) -> UntagResource

Constructs a fluent builder for the UntagResource operation.

The fluent builder is configurable:
- resource_arn(impl Into<String>) / set_resource_arn(Option<String>):
  The Amazon Resource Name (ARN) of the resource from which to remove the tags.
- tags_to_remove(Vec<String>) / set_tags_to_remove(Option<Vec<String>>):
  Tags to remove from this resource.
On success, responds with UntagResourceOutput
On failure, responds with SdkError<UntagResourceError>

source

pub fn update_blueprint(&self) -> UpdateBlueprint

Constructs a fluent builder for the UpdateBlueprint operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the blueprint.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the blueprint.
- blueprint_location(impl Into<String>) / set_blueprint_location(Option<String>):
  Specifies a path in Amazon S3 where the blueprint is published.
On success, responds with UpdateBlueprintOutput with field(s):
- name(Option<String>):
  Returns the name of the blueprint that was updated.
On failure, responds with SdkError<UpdateBlueprintError>

source

pub fn update_classifier(&self) -> UpdateClassifier

Constructs a fluent builder for the UpdateClassifier operation.

The fluent builder is configurable:
- grok_classifier(UpdateGrokClassifierRequest) / set_grok_classifier(Option<UpdateGrokClassifierRequest>):
  A GrokClassifier object with updated fields.
- xml_classifier(UpdateXmlClassifierRequest) / set_xml_classifier(Option<UpdateXmlClassifierRequest>):
  An XMLClassifier object with updated fields.
- json_classifier(UpdateJsonClassifierRequest) / set_json_classifier(Option<UpdateJsonClassifierRequest>):
  A JsonClassifier object with updated fields.
- csv_classifier(UpdateCsvClassifierRequest) / set_csv_classifier(Option<UpdateCsvClassifierRequest>):
  A CsvClassifier object with updated fields.
On success, responds with UpdateClassifierOutput
On failure, responds with SdkError<UpdateClassifierError>

source

pub fn update_column_statistics_for_partition(
&self
) -> UpdateColumnStatisticsForPartition

Constructs a fluent builder for the UpdateColumnStatisticsForPartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- partition_values(Vec<String>) / set_partition_values(Option<Vec<String>>):
  A list of partition values identifying the partition.
- column_statistics_list(Vec<ColumnStatistics>) / set_column_statistics_list(Option<Vec<ColumnStatistics>>):
  A list of the column statistics.
On success, responds with UpdateColumnStatisticsForPartitionOutput with field(s):
- errors(Option<Vec<ColumnStatisticsError>>):
  Error occurred during updating column statistics data.
On failure, responds with SdkError<UpdateColumnStatisticsForPartitionError>

source

pub fn update_column_statistics_for_table(
&self
) -> UpdateColumnStatisticsForTable

Constructs a fluent builder for the UpdateColumnStatisticsForTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partitions in question reside. If none is supplied, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the partitions reside.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the partitions’ table.
- column_statistics_list(Vec<ColumnStatistics>) / set_column_statistics_list(Option<Vec<ColumnStatistics>>):
  A list of the column statistics.
On success, responds with UpdateColumnStatisticsForTableOutput with field(s):
- errors(Option<Vec<ColumnStatisticsError>>):
  List of ColumnStatisticsErrors.
On failure, responds with SdkError<UpdateColumnStatisticsForTableError>

source

pub fn update_connection(&self) -> UpdateConnection

Constructs a fluent builder for the UpdateConnection operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the connection resides. If none is provided, the Amazon Web Services account ID is used by default.
- name(impl Into<String>) / set_name(Option<String>):
  The name of the connection definition to update.
- connection_input(ConnectionInput) / set_connection_input(Option<ConnectionInput>):
  A ConnectionInput object that redefines the connection in question.
On success, responds with UpdateConnectionOutput
On failure, responds with SdkError<UpdateConnectionError>

source

pub fn update_crawler(&self) -> UpdateCrawler

Constructs a fluent builder for the UpdateCrawler operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the new crawler.
- role(impl Into<String>) / set_role(Option<String>):
  The IAM role or Amazon Resource Name (ARN) of an IAM role that is used by the new crawler to access customer resources.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The Glue database where results are stored, such as: arn:aws:daylight:us-east-1::database/sometable/*.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the new crawler.
- targets(CrawlerTargets) / set_targets(Option<CrawlerTargets>):
  A list of targets to crawl.
- schedule(impl Into<String>) / set_schedule(Option<String>):
  A cron expression used to specify the schedule (see Time-Based Schedules for Jobs and Crawlers. For example, to run something every day at 12:15 UTC, you would specify: cron(15 12 * * ? *).
- classifiers(Vec<String>) / set_classifiers(Option<Vec<String>>):
  A list of custom classifiers that the user has registered. By default, all built-in classifiers are included in a crawl, but these custom classifiers always override the default classifiers for a given classification.
- table_prefix(impl Into<String>) / set_table_prefix(Option<String>):
  The table prefix used for catalog tables that are created.
- schema_change_policy(SchemaChangePolicy) / set_schema_change_policy(Option<SchemaChangePolicy>):
  The policy for the crawler’s update and deletion behavior.
- recrawl_policy(RecrawlPolicy) / set_recrawl_policy(Option<RecrawlPolicy>):
  A policy that specifies whether to crawl the entire dataset again, or to crawl only folders that were added since the last crawler run.
- lineage_configuration(LineageConfiguration) / set_lineage_configuration(Option<LineageConfiguration>):
  Specifies data lineage configuration settings for the crawler.
- lake_formation_configuration(LakeFormationConfiguration) / set_lake_formation_configuration(Option<LakeFormationConfiguration>):
  Specifies AWS Lake Formation configuration settings for the crawler.
- configuration(impl Into<String>) / set_configuration(Option<String>):
  Crawler configuration information. This versioned JSON string allows users to specify aspects of a crawler’s behavior. For more information, see Configuring a Crawler.
- crawler_security_configuration(impl Into<String>) / set_crawler_security_configuration(Option<String>):
  The name of the SecurityConfiguration structure to be used by this crawler.
On success, responds with UpdateCrawlerOutput
On failure, responds with SdkError<UpdateCrawlerError>

source

pub fn update_crawler_schedule(&self) -> UpdateCrawlerSchedule

Constructs a fluent builder for the UpdateCrawlerSchedule operation.

The fluent builder is configurable:
- crawler_name(impl Into<String>) / set_crawler_name(Option<String>):
  The name of the crawler whose schedule to update.
- schedule(impl Into<String>) / set_schedule(Option<String>):
  The updated cron expression used to specify the schedule (see Time-Based Schedules for Jobs and Crawlers. For example, to run something every day at 12:15 UTC, you would specify: cron(15 12 * * ? *).
On success, responds with UpdateCrawlerScheduleOutput
On failure, responds with SdkError<UpdateCrawlerScheduleError>

source

pub fn update_database(&self) -> UpdateDatabase

Constructs a fluent builder for the UpdateDatabase operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog in which the metadata database resides. If none is provided, the Amazon Web Services account ID is used by default.
- name(impl Into<String>) / set_name(Option<String>):
  The name of the database to update in the catalog. For Hive compatibility, this is folded to lowercase.
- database_input(DatabaseInput) / set_database_input(Option<DatabaseInput>):
  A DatabaseInput object specifying the new definition of the metadata database in the catalog.
On success, responds with UpdateDatabaseOutput
On failure, responds with SdkError<UpdateDatabaseError>

source

pub fn update_dev_endpoint(&self) -> UpdateDevEndpoint

Constructs a fluent builder for the UpdateDevEndpoint operation.

The fluent builder is configurable:
- endpoint_name(impl Into<String>) / set_endpoint_name(Option<String>):
  The name of the DevEndpoint to be updated.
- public_key(impl Into<String>) / set_public_key(Option<String>):
  The public key for the DevEndpoint to use.
- add_public_keys(Vec<String>) / set_add_public_keys(Option<Vec<String>>):
  The list of public keys for the DevEndpoint to use.
- delete_public_keys(Vec<String>) / set_delete_public_keys(Option<Vec<String>>):
  The list of public keys to be deleted from the DevEndpoint.
- custom_libraries(DevEndpointCustomLibraries) / set_custom_libraries(Option<DevEndpointCustomLibraries>):
  Custom Python or Java libraries to be loaded in the DevEndpoint.
- update_etl_libraries(bool) / set_update_etl_libraries(bool):
  True if the list of custom libraries to be loaded in the development endpoint needs to be updated, or False if otherwise.
- delete_arguments(Vec<String>) / set_delete_arguments(Option<Vec<String>>):
  The list of argument keys to be deleted from the map of arguments used to configure the DevEndpoint.
- add_arguments(HashMap<String, String>) / set_add_arguments(Option<HashMap<String, String>>):
  The map of arguments to add the map of arguments used to configure the DevEndpoint.
  
  Valid arguments are:
  - “–enable-glue-datacatalog”: “”
  You can specify a version of Python support for development endpoints by using the Arguments parameter in the CreateDevEndpoint or UpdateDevEndpoint APIs. If no arguments are provided, the version defaults to Python 2.
On success, responds with UpdateDevEndpointOutput
On failure, responds with SdkError<UpdateDevEndpointError>

source

pub fn update_job(&self) -> UpdateJob

Constructs a fluent builder for the UpdateJob operation.

The fluent builder is configurable:
- job_name(impl Into<String>) / set_job_name(Option<String>):
  The name of the job definition to update.
- job_update(JobUpdate) / set_job_update(Option<JobUpdate>):
  Specifies the values with which to update the job definition.
On success, responds with UpdateJobOutput with field(s):
- job_name(Option<String>):
  Returns the name of the updated job definition.
On failure, responds with SdkError<UpdateJobError>

source

pub fn update_ml_transform(&self) -> UpdateMLTransform

Constructs a fluent builder for the UpdateMLTransform operation.

The fluent builder is configurable:
- transform_id(impl Into<String>) / set_transform_id(Option<String>):
  A unique identifier that was generated when the transform was created.
- name(impl Into<String>) / set_name(Option<String>):
  The unique name that you gave the transform when you created it.
- description(impl Into<String>) / set_description(Option<String>):
  A description of the transform. The default is an empty string.
- parameters(TransformParameters) / set_parameters(Option<TransformParameters>):
  The configuration parameters that are specific to the transform type (algorithm) used. Conditionally dependent on the transform type.
- role(impl Into<String>) / set_role(Option<String>):
  The name or Amazon Resource Name (ARN) of the IAM role with the required permissions.
- glue_version(impl Into<String>) / set_glue_version(Option<String>):
  This value determines which version of Glue this machine learning transform is compatible with. Glue 1.0 is recommended for most customers. If the value is not set, the Glue compatibility defaults to Glue 0.9. For more information, see Glue Versions in the developer guide.
- max_capacity(f64) / set_max_capacity(Option<f64>):
  The number of Glue data processing units (DPUs) that are allocated to task runs for this transform. You can allocate from 2 to 100 DPUs; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory. For more information, see the Glue pricing page.
  
  When the WorkerType field is set to a value other than Standard, the MaxCapacity field is set automatically and becomes read-only.
- worker_type(WorkerType) / set_worker_type(Option<WorkerType>):
  The type of predefined worker that is allocated when this task runs. Accepts a value of Standard, G.1X, or G.2X.
  - For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.
  - For the G.1X worker type, each worker provides 4 vCPU, 16 GB of memory and a 64GB disk, and 1 executor per worker.
  - For the G.2X worker type, each worker provides 8 vCPU, 32 GB of memory and a 128GB disk, and 1 executor per worker.
- number_of_workers(i32) / set_number_of_workers(Option<i32>):
  The number of workers of a defined workerType that are allocated when this task runs.
- timeout(i32) / set_timeout(Option<i32>):
  The timeout for a task run for this transform in minutes. This is the maximum time that a task run for this transform can consume resources before it is terminated and enters TIMEOUT status. The default is 2,880 minutes (48 hours).
- max_retries(i32) / set_max_retries(Option<i32>):
  The maximum number of times to retry a task for this transform after a task run fails.
On success, responds with UpdateMlTransformOutput with field(s):
- transform_id(Option<String>):
  The unique identifier for the transform that was updated.
On failure, responds with SdkError<UpdateMLTransformError>

source

pub fn update_partition(&self) -> UpdatePartition

Constructs a fluent builder for the UpdatePartition operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the partition to be updated resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database in which the table in question resides.
- table_name(impl Into<String>) / set_table_name(Option<String>):
  The name of the table in which the partition to be updated is located.
- partition_value_list(Vec<String>) / set_partition_value_list(Option<Vec<String>>):
  List of partition key values that define the partition to update.
- partition_input(PartitionInput) / set_partition_input(Option<PartitionInput>):
  The new partition object to update the partition to.
  
  The Values property can’t be changed. If you want to change the partition key values for a partition, delete and recreate the partition.
On success, responds with UpdatePartitionOutput
On failure, responds with SdkError<UpdatePartitionError>

source

pub fn update_registry(&self) -> UpdateRegistry

Constructs a fluent builder for the UpdateRegistry operation.

The fluent builder is configurable:
- registry_id(RegistryId) / set_registry_id(Option<RegistryId>):
  This is a wrapper structure that may contain the registry name and Amazon Resource Name (ARN).
- description(impl Into<String>) / set_description(Option<String>):
  A description of the registry. If description is not provided, this field will not be updated.
On success, responds with UpdateRegistryOutput with field(s):
- registry_name(Option<String>):
  The name of the updated registry.
- registry_arn(Option<String>):
  The Amazon Resource name (ARN) of the updated registry.
On failure, responds with SdkError<UpdateRegistryError>

source

pub fn update_schema(&self) -> UpdateSchema

Constructs a fluent builder for the UpdateSchema operation.

The fluent builder is configurable:
- schema_id(SchemaId) / set_schema_id(Option<SchemaId>):
  This is a wrapper structure to contain schema identity fields. The structure contains:
  - SchemaId$SchemaArn: The Amazon Resource Name (ARN) of the schema. One of SchemaArn or SchemaName has to be provided.
  - SchemaId$SchemaName: The name of the schema. One of SchemaArn or SchemaName has to be provided.
- schema_version_number(SchemaVersionNumber) / set_schema_version_number(Option<SchemaVersionNumber>):
  Version number required for check pointing. One of VersionNumber or Compatibility has to be provided.
- compatibility(Compatibility) / set_compatibility(Option<Compatibility>):
  The new compatibility setting for the schema.
- description(impl Into<String>) / set_description(Option<String>):
  The new description for the schema.
On success, responds with UpdateSchemaOutput with field(s):
- schema_arn(Option<String>):
  The Amazon Resource Name (ARN) of the schema.
- schema_name(Option<String>):
  The name of the schema.
- registry_name(Option<String>):
  The name of the registry that contains the schema.
On failure, responds with SdkError<UpdateSchemaError>

source

pub fn update_table(&self) -> UpdateTable

Constructs a fluent builder for the UpdateTable operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the table resides. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database in which the table resides. For Hive compatibility, this name is entirely lowercase.
- table_input(TableInput) / set_table_input(Option<TableInput>):
  An updated TableInput object to define the metadata table in the catalog.
- skip_archive(bool) / set_skip_archive(Option<bool>):
  By default, UpdateTable always creates an archived version of the table before updating it. However, if skipArchive is set to true, UpdateTable does not create the archived version.
- transaction_id(impl Into<String>) / set_transaction_id(Option<String>):
  The transaction ID at which to update the table contents.
- version_id(impl Into<String>) / set_version_id(Option<String>): (undocumented)
On success, responds with UpdateTableOutput
On failure, responds with SdkError<UpdateTableError>

source

pub fn update_trigger(&self) -> UpdateTrigger

Constructs a fluent builder for the UpdateTrigger operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  The name of the trigger to update.
- trigger_update(TriggerUpdate) / set_trigger_update(Option<TriggerUpdate>):
  The new values with which to update the trigger.
On success, responds with UpdateTriggerOutput with field(s):
- trigger(Option<Trigger>):
  The resulting trigger definition.
On failure, responds with SdkError<UpdateTriggerError>

source

pub fn update_user_defined_function(&self) -> UpdateUserDefinedFunction

Constructs a fluent builder for the UpdateUserDefinedFunction operation.

The fluent builder is configurable:
- catalog_id(impl Into<String>) / set_catalog_id(Option<String>):
  The ID of the Data Catalog where the function to be updated is located. If none is provided, the Amazon Web Services account ID is used by default.
- database_name(impl Into<String>) / set_database_name(Option<String>):
  The name of the catalog database where the function to be updated is located.
- function_name(impl Into<String>) / set_function_name(Option<String>):
  The name of the function.
- function_input(UserDefinedFunctionInput) / set_function_input(Option<UserDefinedFunctionInput>):
  A FunctionInput object that redefines the function in the Data Catalog.
On success, responds with UpdateUserDefinedFunctionOutput
On failure, responds with SdkError<UpdateUserDefinedFunctionError>

source

pub fn update_workflow(&self) -> UpdateWorkflow

Constructs a fluent builder for the UpdateWorkflow operation.

The fluent builder is configurable:
- name(impl Into<String>) / set_name(Option<String>):
  Name of the workflow to be updated.
- description(impl Into<String>) / set_description(Option<String>):
  The description of the workflow.
- default_run_properties(HashMap<String, String>) / set_default_run_properties(Option<HashMap<String, String>>):
  A collection of properties to be used as part of each execution of the workflow.
- max_concurrent_runs(i32) / set_max_concurrent_runs(Option<i32>):
  You can use this parameter to prevent unwanted multiple updates to data, to control costs, or in some cases, to prevent exceeding the maximum number of concurrent runs of any of the component jobs. If you leave this parameter blank, there is no limit to the number of concurrent workflow runs.
On success, responds with UpdateWorkflowOutput with field(s):
- name(Option<String>):
  The name of the workflow which was specified in input.
On failure, responds with SdkError<UpdateWorkflowError>