diff --git a/CHANGELOG.md b/CHANGELOG.md index b258f35c4f4..313ac4afdc2 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,3 +1,10 @@ +Release v1.43.21 (2022-03-18) +=== + +### Service Client Updates +* `service/glue`: Updates service API, documentation, and paginators + * Added 9 new APIs for AWS Glue Interactive Sessions: ListSessions, StopSession, CreateSession, GetSession, DeleteSession, RunStatement, GetStatement, ListStatements, CancelStatement + Release v1.43.20 (2022-03-16) === diff --git a/aws/version.go b/aws/version.go index 80a6e3914f9..94781da770d 100644 --- a/aws/version.go +++ b/aws/version.go @@ -5,4 +5,4 @@ package aws const SDKName = "aws-sdk-go" // SDKVersion is the version of this SDK -const SDKVersion = "1.43.20" +const SDKVersion = "1.43.21" diff --git a/models/apis/glue/2017-03-31/api-2.json b/models/apis/glue/2017-03-31/api-2.json index bf5bb594884..6e9868acde4 100644 --- a/models/apis/glue/2017-03-31/api-2.json +++ b/models/apis/glue/2017-03-31/api-2.json @@ -236,6 +236,23 @@ {"shape":"InternalServiceException"} ] }, + "CancelStatement":{ + "name":"CancelStatement", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"CancelStatementRequest"}, + "output":{"shape":"CancelStatementResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"EntityNotFoundException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"}, + {"shape":"IllegalSessionStateException"} + ] + }, "CheckSchemaVersionValidity":{ "name":"CheckSchemaVersionValidity", "http":{ @@ -485,6 +502,25 @@ {"shape":"ResourceNumberLimitExceededException"} ] }, + "CreateSession":{ + "name":"CreateSession", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"CreateSessionRequest"}, + "output":{"shape":"CreateSessionResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"IdempotentParameterMismatchException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"}, + {"shape":"ValidationException"}, + {"shape":"AlreadyExistsException"}, + {"shape":"ResourceNumberLimitExceededException"} + ] + }, "CreateTable":{ "name":"CreateTable", "http":{ @@ -814,6 +850,23 @@ {"shape":"OperationTimeoutException"} ] }, + "DeleteSession":{ + "name":"DeleteSession", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"DeleteSessionRequest"}, + "output":{"shape":"DeleteSessionResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"}, + {"shape":"IllegalSessionStateException"}, + {"shape":"ConcurrentModificationException"} + ] + }, "DeleteTable":{ "name":"DeleteTable", "http":{ @@ -1511,6 +1564,39 @@ {"shape":"OperationTimeoutException"} ] }, + "GetSession":{ + "name":"GetSession", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"GetSessionRequest"}, + "output":{"shape":"GetSessionResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"EntityNotFoundException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"} + ] + }, + "GetStatement":{ + "name":"GetStatement", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"GetStatementRequest"}, + "output":{"shape":"GetStatementResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"EntityNotFoundException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"}, + {"shape":"IllegalSessionStateException"} + ] + }, "GetTable":{ "name":"GetTable", "http":{ @@ -1892,6 +1978,38 @@ {"shape":"InternalServiceException"} ] }, + "ListSessions":{ + "name":"ListSessions", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"ListSessionsRequest"}, + "output":{"shape":"ListSessionsResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"InvalidInputException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"} + ] + }, + "ListStatements":{ + "name":"ListStatements", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"ListStatementsRequest"}, + "output":{"shape":"ListStatementsResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"EntityNotFoundException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"}, + {"shape":"IllegalSessionStateException"} + ] + }, "ListTriggers":{ "name":"ListTriggers", "http":{ @@ -2062,6 +2180,25 @@ {"shape":"IllegalWorkflowStateException"} ] }, + "RunStatement":{ + "name":"RunStatement", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"RunStatementRequest"}, + "output":{"shape":"RunStatementResponse"}, + "errors":[ + {"shape":"EntityNotFoundException"}, + {"shape":"AccessDeniedException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"}, + {"shape":"ValidationException"}, + {"shape":"ResourceNumberLimitExceededException"}, + {"shape":"IllegalSessionStateException"} + ] + }, "SearchTables":{ "name":"SearchTables", "http":{ @@ -2268,6 +2405,23 @@ {"shape":"OperationTimeoutException"} ] }, + "StopSession":{ + "name":"StopSession", + "http":{ + "method":"POST", + "requestUri":"/" + }, + "input":{"shape":"StopSessionRequest"}, + "output":{"shape":"StopSessionResponse"}, + "errors":[ + {"shape":"AccessDeniedException"}, + {"shape":"InternalServiceException"}, + {"shape":"OperationTimeoutException"}, + {"shape":"InvalidInputException"}, + {"shape":"IllegalSessionStateException"}, + {"shape":"ConcurrentModificationException"} + ] + }, "StopTrigger":{ "name":"StopTrigger", "http":{ @@ -2664,10 +2818,16 @@ "exception":true }, "AttemptCount":{"type":"integer"}, + "AuditColumnNamesList":{ + "type":"list", + "member":{"shape":"ColumnNameString"} + }, "AuditContext":{ "type":"structure", "members":{ - "AdditionalAuditContext":{"shape":"AuditContextString"} + "AdditionalAuditContext":{"shape":"AuditContextString"}, + "RequestedColumns":{"shape":"AuditColumnNamesList"}, + "AllColumnsRequested":{"shape":"NullableBoolean"} } }, "AuditContextString":{ @@ -3170,6 +3330,23 @@ "Status":{"shape":"TaskStatusType"} } }, + "CancelStatementRequest":{ + "type":"structure", + "required":[ + "SessionId", + "Id" + ], + "members":{ + "SessionId":{"shape":"NameString"}, + "Id":{"shape":"IntegerValue"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "CancelStatementResponse":{ + "type":"structure", + "members":{ + } + }, "CatalogEncryptionMode":{ "type":"string", "enum":[ @@ -4146,6 +4323,37 @@ "CreatedTimestamp":{"shape":"TimestampValue"} } }, + "CreateSessionRequest":{ + "type":"structure", + "required":[ + "Id", + "Role", + "Command" + ], + "members":{ + "Id":{"shape":"NameString"}, + "Description":{"shape":"DescriptionString"}, + "Role":{"shape":"OrchestrationRoleArn"}, + "Command":{"shape":"SessionCommand"}, + "Timeout":{"shape":"Timeout"}, + "IdleTimeout":{"shape":"Timeout"}, + "DefaultArguments":{"shape":"OrchestrationArgumentsMap"}, + "Connections":{"shape":"ConnectionsList"}, + "MaxCapacity":{"shape":"NullableDouble"}, + "NumberOfWorkers":{"shape":"NullableInteger"}, + "WorkerType":{"shape":"WorkerType"}, + "SecurityConfiguration":{"shape":"NameString"}, + "GlueVersion":{"shape":"GlueVersionString"}, + "Tags":{"shape":"TagsMap"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "CreateSessionResponse":{ + "type":"structure", + "members":{ + "Session":{"shape":"Session"} + } + }, "CreateTableRequest":{ "type":"structure", "required":[ @@ -4658,6 +4866,20 @@ "members":{ } }, + "DeleteSessionRequest":{ + "type":"structure", + "required":["Id"], + "members":{ + "Id":{"shape":"NameString"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "DeleteSessionResponse":{ + "type":"structure", + "members":{ + "Id":{"shape":"NameString"} + } + }, "DeleteTableRequest":{ "type":"structure", "required":[ @@ -4827,6 +5049,7 @@ "NumberOfDistinctValues":{"shape":"NonNegativeLong"} } }, + "DoubleValue":{"type":"double"}, "DynamoDBTarget":{ "type":"structure", "members":{ @@ -5734,6 +5957,38 @@ "NextToken":{"shape":"GenericString"} } }, + "GetSessionRequest":{ + "type":"structure", + "required":["Id"], + "members":{ + "Id":{"shape":"NameString"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "GetSessionResponse":{ + "type":"structure", + "members":{ + "Session":{"shape":"Session"} + } + }, + "GetStatementRequest":{ + "type":"structure", + "required":[ + "SessionId", + "Id" + ], + "members":{ + "SessionId":{"shape":"NameString"}, + "Id":{"shape":"IntegerValue"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "GetStatementResponse":{ + "type":"structure", + "members":{ + "Statement":{"shape":"Statement"} + } + }, "GetTableRequest":{ "type":"structure", "required":[ @@ -6059,7 +6314,7 @@ "type":"string", "max":10240, "min":1, - "pattern":"arn:aws:glue:.*" + "pattern":"arn:(aws|aws-us-gov|aws-cn):glue:.*" }, "GlueTable":{ "type":"structure", @@ -6135,6 +6390,13 @@ }, "exception":true }, + "IllegalSessionStateException":{ + "type":"structure", + "members":{ + "Message":{"shape":"MessageString"} + }, + "exception":true + }, "IllegalWorkflowStateException":{ "type":"structure", "members":{ @@ -6580,6 +6842,39 @@ "NextToken":{"shape":"SchemaRegistryTokenString"} } }, + "ListSessionsRequest":{ + "type":"structure", + "members":{ + "NextToken":{"shape":"OrchestrationToken"}, + "MaxResults":{"shape":"PageSize"}, + "Tags":{"shape":"TagsMap"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "ListSessionsResponse":{ + "type":"structure", + "members":{ + "Ids":{"shape":"SessionIdList"}, + "Sessions":{"shape":"SessionList"}, + "NextToken":{"shape":"OrchestrationToken"} + } + }, + "ListStatementsRequest":{ + "type":"structure", + "required":["SessionId"], + "members":{ + "SessionId":{"shape":"NameString"}, + "RequestOrigin":{"shape":"OrchestrationNameString"}, + "NextToken":{"shape":"OrchestrationToken"} + } + }, + "ListStatementsResponse":{ + "type":"structure", + "members":{ + "Statements":{"shape":"StatementList"}, + "NextToken":{"shape":"OrchestrationToken"} + } + }, "ListTriggersRequest":{ "type":"structure", "members":{ @@ -6669,6 +6964,7 @@ "NumberOfDistinctValues":{"shape":"NonNegativeLong"} } }, + "LongValue":{"type":"long"}, "MLTransform":{ "type":"structure", "members":{ @@ -6893,6 +7189,19 @@ }, "exception":true }, + "OrchestrationArgumentsMap":{ + "type":"map", + "key":{"shape":"OrchestrationNameString"}, + "value":{"shape":"OrchestrationArgumentsValue"}, + "max":75, + "min":0 + }, + "OrchestrationArgumentsValue":{ + "type":"string", + "max":4096, + "min":0, + "pattern":"[\\u0020-\\uD7FF\\uE000-\\uFFFD\\uD800\\uDC00-\\uDBFF\\uDFFF\\r\\n\\t]*" + }, "OrchestrationIAMRoleArn":{ "type":"string", "max":1024, @@ -6905,16 +7214,30 @@ "min":1, "pattern":"[\\.\\-_A-Za-z0-9]+" }, + "OrchestrationRoleArn":{ + "type":"string", + "max":2048, + "min":20, + "pattern":"arn:aws[^:]*:iam::[0-9]*:role/.+" + }, "OrchestrationS3Location":{ "type":"string", "max":8192, "min":1, "pattern":"^s3://([^/]+)/([^/]+/)*([^/]+)$" }, + "OrchestrationStatementCodeString":{ + "type":"string", + "max":68000 + }, "OrchestrationStringList":{ "type":"list", "member":{"shape":"GenericString"} }, + "OrchestrationToken":{ + "type":"string", + "max":400000 + }, "Order":{ "type":"structure", "required":[ @@ -7105,7 +7428,6 @@ }, "PolicyJsonString":{ "type":"string", - "max":10240, "min":2 }, "Predecessor":{ @@ -7438,6 +7760,24 @@ "RoleString":{"type":"string"}, "RowTag":{"type":"string"}, "RunId":{"type":"string"}, + "RunStatementRequest":{ + "type":"structure", + "required":[ + "SessionId", + "Code" + ], + "members":{ + "SessionId":{"shape":"NameString"}, + "Code":{"shape":"OrchestrationStatementCodeString"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "RunStatementResponse":{ + "type":"structure", + "members":{ + "Id":{"shape":"IntegerValue"} + } + }, "S3Encryption":{ "type":"structure", "members":{ @@ -7647,7 +7987,10 @@ "DELETING" ] }, - "ScriptLocationString":{"type":"string"}, + "ScriptLocationString":{ + "type":"string", + "max":400000 + }, "SearchPropertyPredicates":{ "type":"list", "member":{"shape":"PropertyPredicate"} @@ -7708,6 +8051,50 @@ "Parameters":{"shape":"ParametersMap"} } }, + "Session":{ + "type":"structure", + "members":{ + "Id":{"shape":"NameString"}, + "CreatedOn":{"shape":"TimestampValue"}, + "Status":{"shape":"SessionStatus"}, + "ErrorMessage":{"shape":"DescriptionString"}, + "Description":{"shape":"DescriptionString"}, + "Role":{"shape":"OrchestrationRoleArn"}, + "Command":{"shape":"SessionCommand"}, + "DefaultArguments":{"shape":"OrchestrationArgumentsMap"}, + "Connections":{"shape":"ConnectionsList"}, + "Progress":{"shape":"DoubleValue"}, + "MaxCapacity":{"shape":"NullableDouble"}, + "SecurityConfiguration":{"shape":"NameString"}, + "GlueVersion":{"shape":"GlueVersionString"} + } + }, + "SessionCommand":{ + "type":"structure", + "members":{ + "Name":{"shape":"NameString"}, + "PythonVersion":{"shape":"PythonVersionString"} + } + }, + "SessionIdList":{ + "type":"list", + "member":{"shape":"NameString"} + }, + "SessionList":{ + "type":"list", + "member":{"shape":"Session"} + }, + "SessionStatus":{ + "type":"string", + "enum":[ + "PROVISIONING", + "READY", + "FAILED", + "TIMEOUT", + "STOPPING", + "STOPPED" + ] + }, "SkewedInfo":{ "type":"structure", "members":{ @@ -7910,6 +8297,50 @@ "BatchWindow":{"shape":"NullableInteger"} } }, + "Statement":{ + "type":"structure", + "members":{ + "Id":{"shape":"IntegerValue"}, + "Code":{"shape":"GenericString"}, + "State":{"shape":"StatementState"}, + "Output":{"shape":"StatementOutput"}, + "Progress":{"shape":"DoubleValue"}, + "StartedOn":{"shape":"LongValue"}, + "CompletedOn":{"shape":"LongValue"} + } + }, + "StatementList":{ + "type":"list", + "member":{"shape":"Statement"} + }, + "StatementOutput":{ + "type":"structure", + "members":{ + "Data":{"shape":"StatementOutputData"}, + "ExecutionCount":{"shape":"IntegerValue"}, + "Status":{"shape":"StatementState"}, + "ErrorName":{"shape":"GenericString"}, + "ErrorValue":{"shape":"GenericString"}, + "Traceback":{"shape":"OrchestrationStringList"} + } + }, + "StatementOutputData":{ + "type":"structure", + "members":{ + "TextPlain":{"shape":"GenericString"} + } + }, + "StatementState":{ + "type":"string", + "enum":[ + "WAITING", + "RUNNING", + "AVAILABLE", + "CANCELLING", + "CANCELLED", + "ERROR" + ] + }, "StopCrawlerRequest":{ "type":"structure", "required":["Name"], @@ -7934,6 +8365,20 @@ "members":{ } }, + "StopSessionRequest":{ + "type":"structure", + "required":["Id"], + "members":{ + "Id":{"shape":"NameString"}, + "RequestOrigin":{"shape":"OrchestrationNameString"} + } + }, + "StopSessionResponse":{ + "type":"structure", + "members":{ + "Id":{"shape":"NameString"} + } + }, "StopTriggerRequest":{ "type":"structure", "required":["Name"], diff --git a/models/apis/glue/2017-03-31/docs-2.json b/models/apis/glue/2017-03-31/docs-2.json index 047124c02bf..efe25dc7c5b 100644 --- a/models/apis/glue/2017-03-31/docs-2.json +++ b/models/apis/glue/2017-03-31/docs-2.json @@ -17,6 +17,7 @@ "BatchStopJobRun": "

Stops one or more job runs for a specified job definition.

", "BatchUpdatePartition": "

Updates one or more partitions in a batch operation.

", "CancelMLTaskRun": "

Cancels (stops) a task run. Machine learning task runs are asynchronous tasks that Glue runs on your behalf as part of various machine learning workflows. You can cancel a machine learning task run at any time by calling CancelMLTaskRun with a task run's parent transform's TransformID and the task run's TaskRunId.

", + "CancelStatement": "

Cancels the statement..

", "CheckSchemaVersionValidity": "

Validates the supplied schema. This call has no side effects, it simply validates using the supplied schema using DataFormat as the format. Since it does not take a schema set name, no compatibility checks are performed.

", "CreateBlueprint": "

Registers a blueprint with Glue.

", "CreateClassifier": "

Creates a classifier in the user's account. This can be a GrokClassifier, an XMLClassifier, a JsonClassifier, or a CsvClassifier, depending on which field of the request is present.

", @@ -32,6 +33,7 @@ "CreateSchema": "

Creates a new schema set and registers the schema definition. Returns an error if the schema set already exists without actually registering the version.

When the schema set is created, a version checkpoint will be set to the first version. Compatibility mode \"DISABLED\" restricts any additional schema versions from being added after the first schema version. For all other compatibility modes, validation of compatibility settings will be applied only from the second version onwards when the RegisterSchemaVersion API is used.

When this API is called without a RegistryId, this will create an entry for a \"default-registry\" in the registry database tables, if it is not already present.

", "CreateScript": "

Transforms a directed acyclic graph (DAG) into code.

", "CreateSecurityConfiguration": "

Creates a new security configuration. A security configuration is a set of security properties that can be used by Glue. You can use a security configuration to encrypt data at rest. For information about using security configurations in Glue, see Encrypting Data Written by Crawlers, Jobs, and Development Endpoints.

", + "CreateSession": "

Creates a new session.

", "CreateTable": "

Creates a new table definition in the Data Catalog.

", "CreateTrigger": "

Creates a new trigger.

", "CreateUserDefinedFunction": "

Creates a new function definition in the Data Catalog.

", @@ -53,6 +55,7 @@ "DeleteSchema": "

Deletes the entire schema set, including the schema set and all of its versions. To get the status of the delete operation, you can call GetSchema API after the asynchronous call. Deleting a registry will deactivate all online operations for the schema, such as the GetSchemaByDefinition, and RegisterSchemaVersion APIs.

", "DeleteSchemaVersions": "

Remove versions from the specified schema. A version number or range may be supplied. If the compatibility mode forbids deleting of a version that is necessary, such as BACKWARDS_FULL, an error is returned. Calling the GetSchemaVersions API after this call will list the status of the deleted versions.

When the range of version numbers contain check pointed version, the API will return a 409 conflict and will not proceed with the deletion. You have to remove the checkpoint first using the DeleteSchemaCheckpoint API before using this API.

You cannot use the DeleteSchemaVersions API to delete the first schema version in the schema set. The first schema version can only be deleted by the DeleteSchema API. This operation will also delete the attached SchemaVersionMetadata under the schema versions. Hard deletes will be enforced on the database.

If the compatibility mode forbids deleting of a version that is necessary, such as BACKWARDS_FULL, an error is returned.

", "DeleteSecurityConfiguration": "

Deletes a specified security configuration.

", + "DeleteSession": "

Deletes the session.

", "DeleteTable": "

Removes a table definition from the Data Catalog.

After completing this operation, you no longer have access to the table versions and partitions that belong to the deleted table. Glue deletes these \"orphaned\" resources asynchronously in a timely manner, at the discretion of the service.

To ensure the immediate deletion of all related resources, before calling DeleteTable, use DeleteTableVersion or BatchDeleteTableVersion, and DeletePartition or BatchDeletePartition, to delete any resources that belong to the table.

", "DeleteTableVersion": "

Deletes a specified version of a table.

", "DeleteTrigger": "

Deletes a specified trigger. If the trigger is not found, no exception is thrown.

", @@ -100,6 +103,8 @@ "GetSchemaVersionsDiff": "

Fetches the schema version difference in the specified difference type between two stored schema versions in the Schema Registry.

This API allows you to compare two schema versions between two schema definitions under the same schema.

", "GetSecurityConfiguration": "

Retrieves a specified security configuration.

", "GetSecurityConfigurations": "

Retrieves a list of all security configurations.

", + "GetSession": "

Retrieves the session.

", + "GetStatement": "

Retrieves the statement.

", "GetTable": "

Retrieves the Table definition in a Data Catalog for a specified table.

", "GetTableVersion": "

Retrieves a specified version of a table.

", "GetTableVersions": "

Retrieves a list of strings that identify available versions of a specified table.

", @@ -125,6 +130,8 @@ "ListRegistries": "

Returns a list of registries that you have created, with minimal registry information. Registries in the Deleting status will not be included in the results. Empty results will be returned if there are no registries available.

", "ListSchemaVersions": "

Returns a list of schema versions that you have created, with minimal information. Schema versions in Deleted status will not be included in the results. Empty results will be returned if there are no schema versions available.

", "ListSchemas": "

Returns a list of schemas with minimal details. Schemas in Deleting status will not be included in the results. Empty results will be returned if there are no schemas available.

When the RegistryId is not provided, all the schemas across registries will be part of the API response.

", + "ListSessions": "

Retrieve a session..

", + "ListStatements": "

Lists statements for the session.

", "ListTriggers": "

Retrieves the names of all trigger resources in this Amazon Web Services account, or the resources with the specified tag. This operation allows you to see which resources are available in your account, and their names.

This operation takes the optional Tags field, which you can use as a filter on the response so that tagged resources can be retrieved as a group. If you choose to use tags filtering, only resources with the tag are retrieved.

", "ListWorkflows": "

Lists names of workflows created in the account.

", "PutDataCatalogEncryptionSettings": "

Sets the security configuration for a specified catalog. After the configuration has been set, the specified encryption is applied to every catalog write thereafter.

", @@ -136,6 +143,7 @@ "RemoveSchemaVersionMetadata": "

Removes a key value pair from the schema version metadata for the specified schema version ID.

", "ResetJobBookmark": "

Resets a bookmark entry.

", "ResumeWorkflowRun": "

Restarts selected nodes of a previous partially completed workflow run and resumes the workflow run. The selected nodes and all nodes that are downstream from the selected nodes are run.

", + "RunStatement": "

Executes the statement.

", "SearchTables": "

Searches a set of tables based on properties in the table metadata as well as on the parent database. You can search against text or filter conditions.

You can only get tables that you have access to based on the security policies defined in Lake Formation. You need at least a read-only access to the table for it to be returned. If you do not have access to all the columns in the table, these columns will not be searched against when returning the list of tables back to you. If you have access to the columns but not the data in the columns, those columns and the associated metadata for those columns will be included in the search.

", "StartBlueprintRun": "

Starts a new run of the specified blueprint.

", "StartCrawler": "

Starts a crawl using the specified crawler, regardless of what is scheduled. If the crawler is already running, returns a CrawlerRunningException.

", @@ -149,6 +157,7 @@ "StartWorkflowRun": "

Starts a new run of the specified workflow.

", "StopCrawler": "

If the specified crawler is running, stops the crawl.

", "StopCrawlerSchedule": "

Sets the schedule state of the specified crawler to NOT_SCHEDULED, but does not stop the crawler if it is already running.

", + "StopSession": "

Stops the session.

", "StopTrigger": "

Stops a specified trigger.

", "StopWorkflowRun": "

Stops the execution of the specified workflow run.

", "TagResource": "

Adds tags to a resource. A tag is a label you can assign to an Amazon Web Services resource. In Glue, you can tag only certain resources. For information about what resources you can tag, see Amazon Web Services Tags in Glue.

", @@ -215,8 +224,14 @@ "JobRun$Attempt": "

The number of the attempt to run this job.

" } }, - "AuditContext": { + "AuditColumnNamesList": { "base": null, + "refs": { + "AuditContext$RequestedColumns": "

The requested columns for audit.

" + } + }, + "AuditContext": { + "base": "

A structure containing information for audit.

", "refs": { "GetUnfilteredPartitionMetadataRequest$AuditContext": null, "GetUnfilteredPartitionsMetadataRequest$AuditContext": null, @@ -226,7 +241,7 @@ "AuditContextString": { "base": null, "refs": { - "AuditContext$AdditionalAuditContext": null + "AuditContext$AdditionalAuditContext": "

The context for the audit..

" } }, "BackfillError": { @@ -623,6 +638,16 @@ "refs": { } }, + "CancelStatementRequest": { + "base": null, + "refs": { + } + }, + "CancelStatementResponse": { + "base": null, + "refs": { + } + }, "CatalogEncryptionMode": { "base": null, "refs": { @@ -890,6 +915,7 @@ "ColumnNameString": { "base": null, "refs": { + "AuditColumnNamesList$member": null, "FindMatchesParameters$PrimaryKeyColumnName": "

The name of a column that uniquely identifies rows in the source table. Used to help identify matching records.

", "SchemaColumn$Name": "

The name of the column.

" } @@ -1088,8 +1114,10 @@ "base": "

Specifies the connections used by a job.

", "refs": { "CreateJobRequest$Connections": "

The connections used for this job.

", + "CreateSessionRequest$Connections": "

The number of connections to use for the session.

", "Job$Connections": "

The connections used for this job.

", - "JobUpdate$Connections": "

The connections used for this job.

" + "JobUpdate$Connections": "

The connections used for this job.

", + "Session$Connections": "

The number of connections used for the session.

" } }, "Crawl": { @@ -1361,6 +1389,16 @@ "refs": { } }, + "CreateSessionRequest": { + "base": "

Request to create a new session.

", + "refs": { + } + }, + "CreateSessionResponse": { + "base": null, + "refs": { + } + }, "CreateTableRequest": { "base": null, "refs": { @@ -1756,6 +1794,16 @@ "refs": { } }, + "DeleteSessionRequest": { + "base": null, + "refs": { + } + }, + "DeleteSessionResponse": { + "base": null, + "refs": { + } + }, "DeleteTableRequest": { "base": null, "refs": { @@ -1832,6 +1880,7 @@ "CreateRegistryResponse$Description": "

A description of the registry.

", "CreateSchemaInput$Description": "

An optional description of the schema. If description is not provided, there will not be any automatic default value for this.

", "CreateSchemaResponse$Description": "

A description of the schema if specified when created.

", + "CreateSessionRequest$Description": "

The description of the session.

", "CreateTriggerRequest$Description": "

A description of the new trigger.

", "Database$Description": "

A description of the database.

", "DatabaseInput$Description": "

A description of the database.

", @@ -1845,6 +1894,8 @@ "MLTransform$Description": "

A user-defined, long-form description text for the machine learning transform. Descriptions are not guaranteed to be unique and can be changed at any time.

", "RegistryListItem$Description": "

A description of the registry.

", "SchemaListItem$Description": "

A description for the schema.

", + "Session$ErrorMessage": "

The error message displayed during the session.

", + "Session$Description": "

The description of the session.

", "Table$Description": "

A description of the table.

", "TableInput$Description": "

A description of the table.

", "Trigger$Description": "

A description of this trigger.

", @@ -1906,6 +1957,13 @@ "ColumnStatisticsData$DoubleColumnStatisticsData": "

Double column statistics data.

" } }, + "DoubleValue": { + "base": null, + "refs": { + "Session$Progress": "

The code execution progress of the session.

", + "Statement$Progress": "

The code execution progress.

" + } + }, "DynamoDBTarget": { "base": "

Specifies an Amazon DynamoDB table to crawl.

", "refs": { @@ -2199,6 +2257,10 @@ "MapValue$value": null, "OrchestrationStringList$member": null, "PublicKeysList$member": null, + "Statement$Code": "

The execution code of the statement.

", + "StatementOutput$ErrorName": "

The name of the error in the output.

", + "StatementOutput$ErrorValue": "

The error value of the output.

", + "StatementOutputData$TextPlain": "

The code execution output in text format.

", "StringList$member": null, "TaskRun$LogGroupName": "

The names of the log group for secure logging, associated with this task run.

", "TaskRun$ErrorString": "

The list of error strings associated with this task run.

", @@ -2650,6 +2712,26 @@ "refs": { } }, + "GetSessionRequest": { + "base": null, + "refs": { + } + }, + "GetSessionResponse": { + "base": null, + "refs": { + } + }, + "GetStatementRequest": { + "base": null, + "refs": { + } + }, + "GetStatementResponse": { + "base": null, + "refs": { + } + }, "GetTableRequest": { "base": null, "refs": { @@ -2878,12 +2960,14 @@ "CreateDevEndpointResponse$GlueVersion": "

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.

", "CreateJobRequest$GlueVersion": "

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.

", "CreateMLTransformRequest$GlueVersion": "

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.

", + "CreateSessionRequest$GlueVersion": "

The Glue version determines the versions of Apache Spark and Python that AWS Glue supports. The GlueVersion must be greater than 2.0.

", "DevEndpoint$GlueVersion": "

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.

", "GetMLTransformResponse$GlueVersion": "

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.

", "Job$GlueVersion": "

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.

", "JobRun$GlueVersion": "

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.

", "JobUpdate$GlueVersion": "

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.

", "MLTransform$GlueVersion": "

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.

", + "Session$GlueVersion": "

The Glue version determines the versions of Apache Spark and Python that AWS Glue supports. The GlueVersion must be greater than 2.0.

", "TransformFilterCriteria$GlueVersion": "

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.

", "UpdateMLTransformRequest$GlueVersion": "

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.

" } @@ -2981,6 +3065,11 @@ "refs": { } }, + "IllegalSessionStateException": { + "base": "

The session is in an invalid state to perform a requested operation.

", + "refs": { + } + }, "IllegalWorkflowStateException": { "base": "

The workflow is in an invalid state to perform a requested operation.

", "refs": { @@ -3019,19 +3108,24 @@ "IntegerValue": { "base": null, "refs": { + "CancelStatementRequest$Id": "

The ID of the statement to be cancelled.

", "CreateDevEndpointRequest$NumberOfNodes": "

The number of Glue Data Processing Units (DPUs) to allocate to this DevEndpoint.

", "CreateDevEndpointResponse$ZeppelinRemoteSparkInterpreterPort": "

The Apache Zeppelin port for the remote Apache Spark interpreter.

", "CreateDevEndpointResponse$NumberOfNodes": "

The number of Glue Data Processing Units (DPUs) allocated to this DevEndpoint.

", "CreateJobRequest$AllocatedCapacity": "

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.

", "DevEndpoint$ZeppelinRemoteSparkInterpreterPort": "

The Apache Zeppelin port for the remote Apache Spark interpreter.

", "DevEndpoint$NumberOfNodes": "

The number of Glue Data Processing Units (DPUs) allocated to this DevEndpoint.

", + "GetStatementRequest$Id": "

The Id of the statement.

", "Job$AllocatedCapacity": "

This field is deprecated. Use MaxCapacity instead.

The number of Glue data processing units (DPUs) allocated to runs of 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.

", "JobBookmarkEntry$Version": "

The version of the job.

", "JobBookmarkEntry$Run": "

The run ID number.

", "JobBookmarkEntry$Attempt": "

The attempt ID number.

", "JobRun$AllocatedCapacity": "

This field is deprecated. Use MaxCapacity instead.

The number of Glue data processing units (DPUs) allocated 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.

", "JobUpdate$AllocatedCapacity": "

This field 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.

", + "RunStatementResponse$Id": "

Returns the Id of the statement that was run.

", "StartJobRunRequest$AllocatedCapacity": "

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.

", + "Statement$Id": "

The ID of the statement.

", + "StatementOutput$ExecutionCount": "

The execution count of the output.

", "WorkflowRunStatistics$TotalActions": "

Total number of Actions in the workflow run.

", "WorkflowRunStatistics$TimeoutActions": "

Total number of Actions that timed out.

", "WorkflowRunStatistics$FailedActions": "

Total number of Actions that have failed.

", @@ -3357,6 +3451,26 @@ "refs": { } }, + "ListSessionsRequest": { + "base": null, + "refs": { + } + }, + "ListSessionsResponse": { + "base": null, + "refs": { + } + }, + "ListStatementsRequest": { + "base": null, + "refs": { + } + }, + "ListStatementsResponse": { + "base": null, + "refs": { + } + }, "ListTriggersRequest": { "base": null, "refs": { @@ -3442,6 +3556,13 @@ "ColumnStatisticsData$LongColumnStatisticsData": "

Long column statistics data.

" } }, + "LongValue": { + "base": null, + "refs": { + "Statement$StartedOn": "

The unix time and date that the job definition was started.

", + "Statement$CompletedOn": "

The unix time and date that the job definition was completed.

" + } + }, "MLTransform": { "base": "

A structure for a machine learning transform.

", "refs": { @@ -3538,9 +3659,10 @@ "CrawlerRunningException$Message": "

A message describing the problem.

", "CrawlerStoppingException$Message": "

A message describing the problem.

", "EntityNotFoundException$Message": "

A message describing the problem.

", - "GlueEncryptionException$Message": "

A message describing the problem.

", + "GlueEncryptionException$Message": "

The message describing the problem.

", "IdempotentParameterMismatchException$Message": "

A message describing the problem.

", "IllegalBlueprintStateException$Message": null, + "IllegalSessionStateException$Message": "

A message describing the problem.

", "IllegalWorkflowStateException$Message": "

A message describing the problem.

", "InternalServiceException$Message": "

A message describing the problem.

", "InvalidInputException$Message": "

A message describing the problem.

", @@ -3643,6 +3765,7 @@ "BatchUpdatePartitionRequest$DatabaseName": "

The name of the metadata database in which the partition is to be updated.

", "BatchUpdatePartitionRequest$TableName": "

The name of the metadata table in which the partition is to be updated.

", "BlueprintRun$WorkflowName": "

The name of a workflow that is created as a result of a successful blueprint run. If a blueprint run has an error, there will not be a workflow created.

", + "CancelStatementRequest$SessionId": "

The Session ID of the statement to be cancelled.

", "CatalogEntry$DatabaseName": "

The database in which the table metadata resides.

", "CatalogEntry$TableName": "

The name of the table in question.

", "CatalogImportStatus$ImportedBy": "

The name of the person who initiated the migration.

", @@ -3680,6 +3803,8 @@ "CreatePartitionRequest$TableName": "

The name of the metadata table in which the partition is to be created.

", "CreateSecurityConfigurationRequest$Name": "

The name for the new security configuration.

", "CreateSecurityConfigurationResponse$Name": "

The name assigned to the new security configuration.

", + "CreateSessionRequest$Id": "

The ID of the session request.

", + "CreateSessionRequest$SecurityConfiguration": "

The name of the SecurityConfiguration structure to be used with the session

", "CreateTableRequest$DatabaseName": "

The catalog database in which to create the new table. For Hive compatibility, this name is entirely lowercase.

", "CreateTriggerRequest$Name": "

The name of the trigger.

", "CreateTriggerRequest$WorkflowName": "

The name of the workflow associated with the trigger.

", @@ -3714,6 +3839,8 @@ "DeletePartitionRequest$DatabaseName": "

The name of the catalog database in which the table in question resides.

", "DeletePartitionRequest$TableName": "

The name of the table that contains the partition to be deleted.

", "DeleteSecurityConfigurationRequest$Name": "

The name of the security configuration to delete.

", + "DeleteSessionRequest$Id": "

The ID of the session to be deleted.

", + "DeleteSessionResponse$Id": "

Returns the ID of the deleted session.

", "DeleteTableRequest$DatabaseName": "

The name of the catalog database in which the table resides. For Hive compatibility, this name is entirely lowercase.

", "DeleteTableRequest$Name": "

The name of the table to be deleted. For Hive compatibility, this name is entirely lowercase.

", "DeleteTableVersionRequest$DatabaseName": "

The database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.

", @@ -3754,6 +3881,8 @@ "GetPartitionsRequest$DatabaseName": "

The name of the catalog database where the partitions reside.

", "GetPartitionsRequest$TableName": "

The name of the partitions' table.

", "GetSecurityConfigurationRequest$Name": "

The name of the security configuration to retrieve.

", + "GetSessionRequest$Id": "

The ID of the session.

", + "GetStatementRequest$SessionId": "

The Session ID of the statement.

", "GetTableRequest$DatabaseName": "

The name of the database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.

", "GetTableRequest$Name": "

The name of the table for which to retrieve the definition. For Hive compatibility, this name is entirely lowercase.

", "GetTableVersionRequest$DatabaseName": "

The database in the catalog in which the table resides. For Hive compatibility, this name is entirely lowercase.

", @@ -3792,6 +3921,7 @@ "JsonClassifier$Name": "

The name of the classifier.

", "KeyList$member": null, "KeySchemaElement$Name": "

The name of a partition key.

", + "ListStatementsRequest$SessionId": "

The Session ID of the statements.

", "ListTriggersRequest$DependentJobName": "

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.

", "MLTransform$Name": "

A user-defined name for the machine learning transform. Names are not guaranteed unique and can be changed at any time.

", "MLUserDataEncryption$KmsKeyId": "

The ID for the customer-provided KMS key.

", @@ -3810,10 +3940,15 @@ "Predecessor$JobName": "

The name of the job definition used by the predecessor job run.

", "PutWorkflowRunPropertiesRequest$Name": "

Name of the workflow which was run.

", "ResumeWorkflowRunRequest$Name": "

The name of the workflow to resume.

", + "RunStatementRequest$SessionId": "

The Session Id of the statement to be run.

", "SecurityConfiguration$Name": "

The name of the security configuration.

", "SecurityGroupIdList$member": null, "SerDeInfo$Name": "

Name of the SerDe.

", "SerDeInfo$SerializationLibrary": "

Usually the class that implements the SerDe. An example is org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe.

", + "Session$Id": "

The ID of the session.

", + "Session$SecurityConfiguration": "

The name of the SecurityConfiguration structure to be used with the session.

", + "SessionCommand$Name": "

Specifies the name of the SessionCommand.Can be 'glueetl' or 'gluestreaming'.

", + "SessionIdList$member": null, "StartCrawlerRequest$Name": "

Name of the crawler to start.

", "StartCrawlerScheduleRequest$CrawlerName": "

Name of the crawler to schedule.

", "StartJobRunRequest$JobName": "

The name of the job definition to use.

", @@ -3823,6 +3958,8 @@ "StartWorkflowRunRequest$Name": "

The name of the workflow to start.

", "StopCrawlerRequest$Name": "

Name of the crawler to stop.

", "StopCrawlerScheduleRequest$CrawlerName": "

Name of the crawler whose schedule state to set.

", + "StopSessionRequest$Id": "

The ID of the session to be stopped.

", + "StopSessionResponse$Id": "

Returns the Id of the stopped session.

", "StopTriggerRequest$Name": "

The name of the trigger to stop.

", "StopTriggerResponse$Name": "

The name of the trigger that was stopped.

", "StopWorkflowRunRequest$Name": "

The name of the workflow to stop.

", @@ -3982,6 +4119,7 @@ "NullableBoolean": { "base": null, "refs": { + "AuditContext$AllColumnsRequested": "

All columns request for audit.

", "BatchGetBlueprintsRequest$IncludeBlueprint": "

Specifies whether or not to include the blueprint in the response.

", "BatchGetBlueprintsRequest$IncludeParameterSpec": "

Specifies whether or not to include the parameters, as a JSON string, for the blueprint in the response.

", "BatchGetWorkflowsRequest$IncludeGraph": "

Specifies whether to include a graph when returning the workflow resource metadata.

", @@ -4008,12 +4146,14 @@ "refs": { "CreateJobRequest$MaxCapacity": "

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:

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.

", "CreateMLTransformRequest$MaxCapacity": "

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.

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.

", + "CreateSessionRequest$MaxCapacity": "

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.

", "DynamoDBTarget$scanRate": "

The percentage of the configured read capacity units to use by the Glue crawler. Read capacity units is a term defined by DynamoDB, and is a numeric value that acts as rate limiter for the number of reads that can be performed on that table per second.

The valid values are null or a value between 0.1 to 1.5. A null value is used when user does not provide a value, and defaults to 0.5 of the configured Read Capacity Unit (for provisioned tables), or 0.25 of the max configured Read Capacity Unit (for tables using on-demand mode).

", "GetMLTransformResponse$MaxCapacity": "

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.

", "Job$MaxCapacity": "

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, an Apache Spark ETL job, or an Apache Spark streaming ETL job:

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.

", "JobRun$MaxCapacity": "

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:

", "JobUpdate$MaxCapacity": "

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:

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.

", "MLTransform$MaxCapacity": "

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.

When the WorkerType field is set to a value other than Standard, the MaxCapacity field is set automatically and becomes read-only.

", + "Session$MaxCapacity": "

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.

", "StartJobRunRequest$MaxCapacity": "

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:

", "UpdateMLTransformRequest$MaxCapacity": "

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.

" } @@ -4026,6 +4166,7 @@ "CreateJobRequest$NumberOfWorkers": "

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.

", "CreateMLTransformRequest$NumberOfWorkers": "

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

", "CreateMLTransformRequest$MaxRetries": "

The maximum number of times to retry a task for this transform after a task run fails.

", + "CreateSessionRequest$NumberOfWorkers": "

The number of workers to use for the session.

", "CreateWorkflowRequest$MaxConcurrentRuns": "

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.

", "DevEndpoint$NumberOfWorkers": "

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.

", "GetMLTransformResponse$NumberOfWorkers": "

The number of workers of a defined workerType that are allocated when this task runs.

", @@ -4050,6 +4191,19 @@ "refs": { } }, + "OrchestrationArgumentsMap": { + "base": null, + "refs": { + "CreateSessionRequest$DefaultArguments": "

A map array of key-value pairs. Max is 75 pairs.

", + "Session$DefaultArguments": "

A map array of key-value pairs. Max is 75 pairs.

" + } + }, + "OrchestrationArgumentsValue": { + "base": null, + "refs": { + "OrchestrationArgumentsMap$value": null + } + }, "OrchestrationIAMRoleArn": { "base": null, "refs": { @@ -4065,12 +4219,29 @@ "BlueprintDetails$BlueprintName": "

The name of the blueprint.

", "BlueprintNames$member": null, "BlueprintRun$BlueprintName": "

The name of the blueprint.

", + "CancelStatementRequest$RequestOrigin": "

The origin of the request to cancel the statement.

", "CreateBlueprintRequest$Name": "

The name of the blueprint.

", + "CreateSessionRequest$RequestOrigin": "

The origin of the request.

", + "DeleteSessionRequest$RequestOrigin": "

The name of the origin of the delete session request.

", "GetBlueprintRunRequest$BlueprintName": "

The name of the blueprint.

", + "GetSessionRequest$RequestOrigin": "

The origin of the request.

", + "GetStatementRequest$RequestOrigin": "

The origin of the request.

", + "ListSessionsRequest$RequestOrigin": "

The origin of the request.

", + "ListStatementsRequest$RequestOrigin": "

The origin of the request to list statements.

", + "OrchestrationArgumentsMap$key": null, + "RunStatementRequest$RequestOrigin": "

The origin of the request.

", "StartBlueprintRunRequest$BlueprintName": "

The name of the blueprint.

", + "StopSessionRequest$RequestOrigin": "

The origin of the request.

", "UpdateBlueprintRequest$Name": "

The name of the blueprint.

" } }, + "OrchestrationRoleArn": { + "base": null, + "refs": { + "CreateSessionRequest$Role": "

The IAM Role ARN

", + "Session$Role": "

The name or Amazon Resource Name (ARN) of the IAM role associated with the Session.

" + } + }, "OrchestrationS3Location": { "base": null, "refs": { @@ -4078,10 +4249,26 @@ "UpdateBlueprintRequest$BlueprintLocation": "

Specifies a path in Amazon S3 where the blueprint is published.

" } }, + "OrchestrationStatementCodeString": { + "base": null, + "refs": { + "RunStatementRequest$Code": "

The statement code to be run.

" + } + }, "OrchestrationStringList": { "base": null, "refs": { - "ConnectionsList$Connections": "

A list of connections used by the job.

" + "ConnectionsList$Connections": "

A list of connections used by the job.

", + "StatementOutput$Traceback": "

The traceback of the output.

" + } + }, + "OrchestrationToken": { + "base": null, + "refs": { + "ListSessionsRequest$NextToken": "

The token for the next set of results, or null if there are no more result.

", + "ListSessionsResponse$NextToken": "

The token for the next set of results, or null if there are no more result.

", + "ListStatementsRequest$NextToken": null, + "ListStatementsResponse$NextToken": null } }, "Order": { @@ -4132,6 +4319,7 @@ "ListDevEndpointsRequest$MaxResults": "

The maximum size of a list to return.

", "ListJobsRequest$MaxResults": "

The maximum size of a list to return.

", "ListMLTransformsRequest$MaxResults": "

The maximum size of a list to return.

", + "ListSessionsRequest$MaxResults": "

The maximum number of results.

", "ListTriggersRequest$MaxResults": "

The maximum size of a list to return.

", "ListWorkflowsRequest$MaxResults": "

The maximum size of a list to return.

", "SearchTablesRequest$MaxResults": "

The maximum number of tables to return in a single response.

" @@ -4429,7 +4617,8 @@ "PythonVersionString": { "base": null, "refs": { - "JobCommand$PythonVersion": "

The Python version being used to run a Python shell job. Allowed values are 2 or 3.

" + "JobCommand$PythonVersion": "

The Python version being used to run a Python shell job. Allowed values are 2 or 3.

", + "SessionCommand$PythonVersion": "

Specifies the Python version. The Python version indicates the version supported for jobs of type Spark.

" } }, "QuerySchemaVersionMetadataInput": { @@ -4629,6 +4818,16 @@ "ResetJobBookmarkRequest$RunId": "

The unique run identifier associated with this job run.

" } }, + "RunStatementRequest": { + "base": null, + "refs": { + } + }, + "RunStatementResponse": { + "base": null, + "refs": { + } + }, "S3Encryption": { "base": "

Specifies how Amazon Simple Storage Service (Amazon S3) data should be encrypted.

", "refs": { @@ -4953,6 +5152,39 @@ "StorageDescriptor$SerdeInfo": "

The serialization/deserialization (SerDe) information.

" } }, + "Session": { + "base": "

The period in which a remote Spark runtime environment is running.

", + "refs": { + "CreateSessionResponse$Session": "

Returns the session object in the response.

", + "GetSessionResponse$Session": "

The session object is returned in the response.

", + "SessionList$member": null + } + }, + "SessionCommand": { + "base": "

The SessionCommand that runs the job.

", + "refs": { + "CreateSessionRequest$Command": "

The SessionCommand that runs the job.

", + "Session$Command": "

The command object.See SessionCommand.

" + } + }, + "SessionIdList": { + "base": null, + "refs": { + "ListSessionsResponse$Ids": "

Returns the Id of the session.

" + } + }, + "SessionList": { + "base": null, + "refs": { + "ListSessionsResponse$Sessions": "

Returns the session object.

" + } + }, + "SessionStatus": { + "base": null, + "refs": { + "Session$Status": "

The session status.

" + } + }, "SkewedInfo": { "base": "

Specifies skewed values in a table. Skewed values are those that occur with very high frequency.

", "refs": { @@ -5090,6 +5322,38 @@ "WorkflowRun$StartingEventBatchCondition": "

The batch condition that started the workflow run.

" } }, + "Statement": { + "base": "

The statement or request for a particular action to occur in a session.

", + "refs": { + "GetStatementResponse$Statement": "

Returns the statement.

", + "StatementList$member": null + } + }, + "StatementList": { + "base": null, + "refs": { + "ListStatementsResponse$Statements": "

Returns the list of statements.

" + } + }, + "StatementOutput": { + "base": "

The code execution output in JSON format.

", + "refs": { + "Statement$Output": "

The output in JSON.

" + } + }, + "StatementOutputData": { + "base": "

The code execution output in JSON format.

", + "refs": { + "StatementOutput$Data": "

The code execution output.

" + } + }, + "StatementState": { + "base": null, + "refs": { + "Statement$State": "

The state while request is actioned.

", + "StatementOutput$Status": "

The status of the code execution output.

" + } + }, "StopCrawlerRequest": { "base": null, "refs": { @@ -5110,6 +5374,16 @@ "refs": { } }, + "StopSessionRequest": { + "base": null, + "refs": { + } + }, + "StopSessionResponse": { + "base": null, + "refs": { + } + }, "StopTriggerRequest": { "base": null, "refs": { @@ -5279,6 +5553,7 @@ "CreateRegistryResponse$Tags": "

The tags for the registry.

", "CreateSchemaInput$Tags": "

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.

", "CreateSchemaResponse$Tags": "

The tags for the schema.

", + "CreateSessionRequest$Tags": "

The map of key value pairs (tags) belonging to the session.

", "CreateTriggerRequest$Tags": "

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.

", "CreateWorkflowRequest$Tags": "

The tags to be used with this workflow.

", "GetTagsResponse$Tags": "

The requested tags.

", @@ -5287,6 +5562,7 @@ "ListDevEndpointsRequest$Tags": "

Specifies to return only these tagged resources.

", "ListJobsRequest$Tags": "

Specifies to return only these tagged resources.

", "ListMLTransformsRequest$Tags": "

Specifies to return only these tagged resources.

", + "ListSessionsRequest$Tags": "

Tags belonging to the session.

", "ListTriggersRequest$Tags": "

Specifies to return only these tagged resources.

", "TagResourceRequest$TagsToAdd": "

Tags to add to this resource.

" } @@ -5350,6 +5626,8 @@ "Action$Timeout": "

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.

", "CreateJobRequest$Timeout": "

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

", "CreateMLTransformRequest$Timeout": "

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

", + "CreateSessionRequest$Timeout": "

The number of seconds before request times out.

", + "CreateSessionRequest$IdleTimeout": "

The number of seconds when idle before request times out.

", "GetMLTransformResponse$Timeout": "

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

", "Job$Timeout": "

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

", "JobRun$Timeout": "

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.

", @@ -5437,6 +5715,7 @@ "JobRun$CompletedOn": "

The date and time that this job run completed.

", "LastActiveDefinition$LastModifiedOn": "

The date and time the blueprint was last modified.

", "SecurityConfiguration$CreatedTimeStamp": "

The time at which this security configuration was created.

", + "Session$CreatedOn": "

The time and date when the session was created.

", "Workflow$CreatedOn": "

The date and time when the workflow was created.

", "Workflow$LastModifiedOn": "

The date and time when the workflow was last modified.

", "WorkflowRun$StartedOn": "

The date and time when the workflow run was started.

", @@ -6010,6 +6289,7 @@ "CreateDevEndpointResponse$WorkerType": "

The type of predefined worker that is allocated to the development endpoint. May be a value of Standard, G.1X, or G.2X.

", "CreateJobRequest$WorkerType": "

The type of predefined worker that is allocated when a job runs. Accepts a value of Standard, G.1X, or G.2X.

", "CreateMLTransformRequest$WorkerType": "

The type of predefined worker that is allocated when this task runs. Accepts a value of Standard, G.1X, or G.2X.

MaxCapacity is a mutually exclusive option with NumberOfWorkers and WorkerType.

", + "CreateSessionRequest$WorkerType": "

The Worker Type. Can be one of G.1X, G.2X, Standard

", "DevEndpoint$WorkerType": "

The type of predefined worker that is allocated to the development endpoint. Accepts a value of Standard, G.1X, or G.2X.

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.

", "GetMLTransformResponse$WorkerType": "

The type of predefined worker that is allocated when this task runs. Accepts a value of Standard, G.1X, or G.2X.

", "Job$WorkerType": "

The type of predefined worker that is allocated when a job runs. Accepts a value of Standard, G.1X, or G.2X.

", diff --git a/models/apis/glue/2017-03-31/paginators-1.json b/models/apis/glue/2017-03-31/paginators-1.json index a5724aaf99c..9049b86f169 100644 --- a/models/apis/glue/2017-03-31/paginators-1.json +++ b/models/apis/glue/2017-03-31/paginators-1.json @@ -150,6 +150,11 @@ "output_token": "NextToken", "result_key": "Schemas" }, + "ListSessions": { + "input_token": "NextToken", + "limit_key": "MaxResults", + "output_token": "NextToken" + }, "ListTriggers": { "input_token": "NextToken", "limit_key": "MaxResults", diff --git a/service/glue/api.go b/service/glue/api.go index a708fc39482..7d3495a7743 100644 --- a/service/glue/api.go +++ b/service/glue/api.go @@ -1357,6 +1357,101 @@ func (c *Glue) CancelMLTaskRunWithContext(ctx aws.Context, input *CancelMLTaskRu return out, req.Send() } +const opCancelStatement = "CancelStatement" + +// CancelStatementRequest generates a "aws/request.Request" representing the +// client's request for the CancelStatement operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See CancelStatement for more information on using the CancelStatement +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the CancelStatementRequest method. +// req, resp := client.CancelStatementRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/CancelStatement +func (c *Glue) CancelStatementRequest(input *CancelStatementInput) (req *request.Request, output *CancelStatementOutput) { + op := &request.Operation{ + Name: opCancelStatement, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &CancelStatementInput{} + } + + output = &CancelStatementOutput{} + req = c.newRequest(op, input, output) + req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) + return +} + +// CancelStatement API operation for AWS Glue. +// +// Cancels the statement.. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation CancelStatement for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * EntityNotFoundException +// A specified entity does not exist +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// * IllegalSessionStateException +// The session is in an invalid state to perform a requested operation. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/CancelStatement +func (c *Glue) CancelStatement(input *CancelStatementInput) (*CancelStatementOutput, error) { + req, out := c.CancelStatementRequest(input) + return out, req.Send() +} + +// CancelStatementWithContext is the same as CancelStatement with the addition of +// the ability to pass a context and additional request options. +// +// See CancelStatement for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) CancelStatementWithContext(ctx aws.Context, input *CancelStatementInput, opts ...request.Option) (*CancelStatementOutput, error) { + req, out := c.CancelStatementRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opCheckSchemaVersionValidity = "CheckSchemaVersionValidity" // CheckSchemaVersionValidityRequest generates a "aws/request.Request" representing the @@ -2788,6 +2883,106 @@ func (c *Glue) CreateSecurityConfigurationWithContext(ctx aws.Context, input *Cr return out, req.Send() } +const opCreateSession = "CreateSession" + +// CreateSessionRequest generates a "aws/request.Request" representing the +// client's request for the CreateSession operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See CreateSession for more information on using the CreateSession +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the CreateSessionRequest method. +// req, resp := client.CreateSessionRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/CreateSession +func (c *Glue) CreateSessionRequest(input *CreateSessionInput) (req *request.Request, output *CreateSessionOutput) { + op := &request.Operation{ + Name: opCreateSession, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &CreateSessionInput{} + } + + output = &CreateSessionOutput{} + req = c.newRequest(op, input, output) + return +} + +// CreateSession API operation for AWS Glue. +// +// Creates a new session. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation CreateSession for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * IdempotentParameterMismatchException +// The same unique identifier was associated with two different records. +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// * ValidationException +// A value could not be validated. +// +// * AlreadyExistsException +// A resource to be created or added already exists. +// +// * ResourceNumberLimitExceededException +// A resource numerical limit was exceeded. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/CreateSession +func (c *Glue) CreateSession(input *CreateSessionInput) (*CreateSessionOutput, error) { + req, out := c.CreateSessionRequest(input) + return out, req.Send() +} + +// CreateSessionWithContext is the same as CreateSession with the addition of +// the ability to pass a context and additional request options. +// +// See CreateSession for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) CreateSessionWithContext(ctx aws.Context, input *CreateSessionInput, opts ...request.Option) (*CreateSessionOutput, error) { + req, out := c.CreateSessionRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opCreateTable = "CreateTable" // CreateTableRequest generates a "aws/request.Request" representing the @@ -4738,6 +4933,100 @@ func (c *Glue) DeleteSecurityConfigurationWithContext(ctx aws.Context, input *De return out, req.Send() } +const opDeleteSession = "DeleteSession" + +// DeleteSessionRequest generates a "aws/request.Request" representing the +// client's request for the DeleteSession operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See DeleteSession for more information on using the DeleteSession +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the DeleteSessionRequest method. +// req, resp := client.DeleteSessionRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/DeleteSession +func (c *Glue) DeleteSessionRequest(input *DeleteSessionInput) (req *request.Request, output *DeleteSessionOutput) { + op := &request.Operation{ + Name: opDeleteSession, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &DeleteSessionInput{} + } + + output = &DeleteSessionOutput{} + req = c.newRequest(op, input, output) + return +} + +// DeleteSession API operation for AWS Glue. +// +// Deletes the session. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation DeleteSession for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// * IllegalSessionStateException +// The session is in an invalid state to perform a requested operation. +// +// * ConcurrentModificationException +// Two processes are trying to modify a resource simultaneously. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/DeleteSession +func (c *Glue) DeleteSession(input *DeleteSessionInput) (*DeleteSessionOutput, error) { + req, out := c.DeleteSessionRequest(input) + return out, req.Send() +} + +// DeleteSessionWithContext is the same as DeleteSession with the addition of +// the ability to pass a context and additional request options. +// +// See DeleteSession for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) DeleteSessionWithContext(ctx aws.Context, input *DeleteSessionInput, opts ...request.Option) (*DeleteSessionOutput, error) { + req, out := c.DeleteSessionRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opDeleteTable = "DeleteTable" // DeleteTableRequest generates a "aws/request.Request" representing the @@ -9783,6 +10072,191 @@ func (c *Glue) GetSecurityConfigurationsPagesWithContext(ctx aws.Context, input return p.Err() } +const opGetSession = "GetSession" + +// GetSessionRequest generates a "aws/request.Request" representing the +// client's request for the GetSession operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See GetSession for more information on using the GetSession +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the GetSessionRequest method. +// req, resp := client.GetSessionRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetSession +func (c *Glue) GetSessionRequest(input *GetSessionInput) (req *request.Request, output *GetSessionOutput) { + op := &request.Operation{ + Name: opGetSession, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &GetSessionInput{} + } + + output = &GetSessionOutput{} + req = c.newRequest(op, input, output) + return +} + +// GetSession API operation for AWS Glue. +// +// Retrieves the session. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation GetSession for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * EntityNotFoundException +// A specified entity does not exist +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetSession +func (c *Glue) GetSession(input *GetSessionInput) (*GetSessionOutput, error) { + req, out := c.GetSessionRequest(input) + return out, req.Send() +} + +// GetSessionWithContext is the same as GetSession with the addition of +// the ability to pass a context and additional request options. +// +// See GetSession for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) GetSessionWithContext(ctx aws.Context, input *GetSessionInput, opts ...request.Option) (*GetSessionOutput, error) { + req, out := c.GetSessionRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + +const opGetStatement = "GetStatement" + +// GetStatementRequest generates a "aws/request.Request" representing the +// client's request for the GetStatement operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See GetStatement for more information on using the GetStatement +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the GetStatementRequest method. +// req, resp := client.GetStatementRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetStatement +func (c *Glue) GetStatementRequest(input *GetStatementInput) (req *request.Request, output *GetStatementOutput) { + op := &request.Operation{ + Name: opGetStatement, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &GetStatementInput{} + } + + output = &GetStatementOutput{} + req = c.newRequest(op, input, output) + return +} + +// GetStatement API operation for AWS Glue. +// +// Retrieves the statement. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation GetStatement for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * EntityNotFoundException +// A specified entity does not exist +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// * IllegalSessionStateException +// The session is in an invalid state to perform a requested operation. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetStatement +func (c *Glue) GetStatement(input *GetStatementInput) (*GetStatementOutput, error) { + req, out := c.GetStatementRequest(input) + return out, req.Send() +} + +// GetStatementWithContext is the same as GetStatement with the addition of +// the ability to pass a context and additional request options. +// +// See GetStatement for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) GetStatementWithContext(ctx aws.Context, input *GetStatementInput, opts ...request.Option) (*GetStatementOutput, error) { + req, out := c.GetStatementRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opGetTable = "GetTable" // GetTableRequest generates a "aws/request.Request" representing the @@ -12837,6 +13311,246 @@ func (c *Glue) ListSchemasPagesWithContext(ctx aws.Context, input *ListSchemasIn return p.Err() } +const opListSessions = "ListSessions" + +// ListSessionsRequest generates a "aws/request.Request" representing the +// client's request for the ListSessions operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See ListSessions for more information on using the ListSessions +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the ListSessionsRequest method. +// req, resp := client.ListSessionsRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/ListSessions +func (c *Glue) ListSessionsRequest(input *ListSessionsInput) (req *request.Request, output *ListSessionsOutput) { + op := &request.Operation{ + Name: opListSessions, + HTTPMethod: "POST", + HTTPPath: "/", + Paginator: &request.Paginator{ + InputTokens: []string{"NextToken"}, + OutputTokens: []string{"NextToken"}, + LimitToken: "MaxResults", + TruncationToken: "", + }, + } + + if input == nil { + input = &ListSessionsInput{} + } + + output = &ListSessionsOutput{} + req = c.newRequest(op, input, output) + return +} + +// ListSessions API operation for AWS Glue. +// +// Retrieve a session.. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation ListSessions for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * InvalidInputException +// The input provided was not valid. +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/ListSessions +func (c *Glue) ListSessions(input *ListSessionsInput) (*ListSessionsOutput, error) { + req, out := c.ListSessionsRequest(input) + return out, req.Send() +} + +// ListSessionsWithContext is the same as ListSessions with the addition of +// the ability to pass a context and additional request options. +// +// See ListSessions for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) ListSessionsWithContext(ctx aws.Context, input *ListSessionsInput, opts ...request.Option) (*ListSessionsOutput, error) { + req, out := c.ListSessionsRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + +// ListSessionsPages iterates over the pages of a ListSessions operation, +// calling the "fn" function with the response data for each page. To stop +// iterating, return false from the fn function. +// +// See ListSessions method for more information on how to use this operation. +// +// Note: This operation can generate multiple requests to a service. +// +// // Example iterating over at most 3 pages of a ListSessions operation. +// pageNum := 0 +// err := client.ListSessionsPages(params, +// func(page *glue.ListSessionsOutput, lastPage bool) bool { +// pageNum++ +// fmt.Println(page) +// return pageNum <= 3 +// }) +// +func (c *Glue) ListSessionsPages(input *ListSessionsInput, fn func(*ListSessionsOutput, bool) bool) error { + return c.ListSessionsPagesWithContext(aws.BackgroundContext(), input, fn) +} + +// ListSessionsPagesWithContext same as ListSessionsPages except +// it takes a Context and allows setting request options on the pages. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) ListSessionsPagesWithContext(ctx aws.Context, input *ListSessionsInput, fn func(*ListSessionsOutput, bool) bool, opts ...request.Option) error { + p := request.Pagination{ + NewRequest: func() (*request.Request, error) { + var inCpy *ListSessionsInput + if input != nil { + tmp := *input + inCpy = &tmp + } + req, _ := c.ListSessionsRequest(inCpy) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return req, nil + }, + } + + for p.Next() { + if !fn(p.Page().(*ListSessionsOutput), !p.HasNextPage()) { + break + } + } + + return p.Err() +} + +const opListStatements = "ListStatements" + +// ListStatementsRequest generates a "aws/request.Request" representing the +// client's request for the ListStatements operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See ListStatements for more information on using the ListStatements +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the ListStatementsRequest method. +// req, resp := client.ListStatementsRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/ListStatements +func (c *Glue) ListStatementsRequest(input *ListStatementsInput) (req *request.Request, output *ListStatementsOutput) { + op := &request.Operation{ + Name: opListStatements, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &ListStatementsInput{} + } + + output = &ListStatementsOutput{} + req = c.newRequest(op, input, output) + return +} + +// ListStatements API operation for AWS Glue. +// +// Lists statements for the session. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation ListStatements for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * EntityNotFoundException +// A specified entity does not exist +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// * IllegalSessionStateException +// The session is in an invalid state to perform a requested operation. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/ListStatements +func (c *Glue) ListStatements(input *ListStatementsInput) (*ListStatementsOutput, error) { + req, out := c.ListStatementsRequest(input) + return out, req.Send() +} + +// ListStatementsWithContext is the same as ListStatements with the addition of +// the ability to pass a context and additional request options. +// +// See ListStatements for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) ListStatementsWithContext(ctx aws.Context, input *ListStatementsInput, opts ...request.Option) (*ListStatementsOutput, error) { + req, out := c.ListStatementsRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opListTriggers = "ListTriggers" // ListTriggersRequest generates a "aws/request.Request" representing the @@ -13965,6 +14679,106 @@ func (c *Glue) ResumeWorkflowRunWithContext(ctx aws.Context, input *ResumeWorkfl return out, req.Send() } +const opRunStatement = "RunStatement" + +// RunStatementRequest generates a "aws/request.Request" representing the +// client's request for the RunStatement operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See RunStatement for more information on using the RunStatement +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the RunStatementRequest method. +// req, resp := client.RunStatementRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/RunStatement +func (c *Glue) RunStatementRequest(input *RunStatementInput) (req *request.Request, output *RunStatementOutput) { + op := &request.Operation{ + Name: opRunStatement, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &RunStatementInput{} + } + + output = &RunStatementOutput{} + req = c.newRequest(op, input, output) + return +} + +// RunStatement API operation for AWS Glue. +// +// Executes the statement. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation RunStatement for usage and error information. +// +// Returned Error Types: +// * EntityNotFoundException +// A specified entity does not exist +// +// * AccessDeniedException +// Access to a resource was denied. +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// * ValidationException +// A value could not be validated. +// +// * ResourceNumberLimitExceededException +// A resource numerical limit was exceeded. +// +// * IllegalSessionStateException +// The session is in an invalid state to perform a requested operation. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/RunStatement +func (c *Glue) RunStatement(input *RunStatementInput) (*RunStatementOutput, error) { + req, out := c.RunStatementRequest(input) + return out, req.Send() +} + +// RunStatementWithContext is the same as RunStatement with the addition of +// the ability to pass a context and additional request options. +// +// See RunStatement for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) RunStatementWithContext(ctx aws.Context, input *RunStatementInput, opts ...request.Option) (*RunStatementOutput, error) { + req, out := c.RunStatementRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opSearchTables = "SearchTables" // SearchTablesRequest generates a "aws/request.Request" representing the @@ -15269,6 +16083,100 @@ func (c *Glue) StopCrawlerScheduleWithContext(ctx aws.Context, input *StopCrawle return out, req.Send() } +const opStopSession = "StopSession" + +// StopSessionRequest generates a "aws/request.Request" representing the +// client's request for the StopSession operation. The "output" return +// value will be populated with the request's response once the request completes +// successfully. +// +// Use "Send" method on the returned Request to send the API call to the service. +// the "output" return value is not valid until after Send returns without error. +// +// See StopSession for more information on using the StopSession +// API call, and error handling. +// +// This method is useful when you want to inject custom logic or configuration +// into the SDK's request lifecycle. Such as custom headers, or retry logic. +// +// +// // Example sending a request using the StopSessionRequest method. +// req, resp := client.StopSessionRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/StopSession +func (c *Glue) StopSessionRequest(input *StopSessionInput) (req *request.Request, output *StopSessionOutput) { + op := &request.Operation{ + Name: opStopSession, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &StopSessionInput{} + } + + output = &StopSessionOutput{} + req = c.newRequest(op, input, output) + return +} + +// StopSession API operation for AWS Glue. +// +// Stops the session. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Glue's +// API operation StopSession for usage and error information. +// +// Returned Error Types: +// * AccessDeniedException +// Access to a resource was denied. +// +// * InternalServiceException +// An internal service error occurred. +// +// * OperationTimeoutException +// The operation timed out. +// +// * InvalidInputException +// The input provided was not valid. +// +// * IllegalSessionStateException +// The session is in an invalid state to perform a requested operation. +// +// * ConcurrentModificationException +// Two processes are trying to modify a resource simultaneously. +// +// See also, https://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/StopSession +func (c *Glue) StopSession(input *StopSessionInput) (*StopSessionOutput, error) { + req, out := c.StopSessionRequest(input) + return out, req.Send() +} + +// StopSessionWithContext is the same as StopSession with the addition of +// the ability to pass a context and additional request options. +// +// See StopSession for details on how to use this API operation. +// +// The context must be non-nil and will be used for request cancellation. If +// the context is nil a panic will occur. In the future the SDK may create +// sub-contexts for http.Requests. See https://golang.org/pkg/context/ +// for more information on using Contexts. +func (c *Glue) StopSessionWithContext(ctx aws.Context, input *StopSessionInput, opts ...request.Option) (*StopSessionOutput, error) { + req, out := c.StopSessionRequest(input) + req.SetContext(ctx) + req.ApplyOptions(opts...) + return out, req.Send() +} + const opStopTrigger = "StopTrigger" // StopTriggerRequest generates a "aws/request.Request" representing the @@ -17566,10 +18474,18 @@ func (s *AlreadyExistsException) RequestID() string { return s.RespMetadata.RequestID } +// A structure containing information for audit. type AuditContext struct { _ struct{} `type:"structure"` + // The context for the audit.. AdditionalAuditContext *string `type:"string"` + + // All columns request for audit. + AllColumnsRequested *bool `type:"boolean"` + + // The requested columns for audit. + RequestedColumns []*string `type:"list"` } // String returns the string representation. @@ -17596,6 +18512,18 @@ func (s *AuditContext) SetAdditionalAuditContext(v string) *AuditContext { return s } +// SetAllColumnsRequested sets the AllColumnsRequested field's value. +func (s *AuditContext) SetAllColumnsRequested(v bool) *AuditContext { + s.AllColumnsRequested = &v + return s +} + +// SetRequestedColumns sets the RequestedColumns field's value. +func (s *AuditContext) SetRequestedColumns(v []*string) *AuditContext { + s.RequestedColumns = v + return s +} + // A list of errors that can occur when registering partition indexes for an // existing table. // @@ -19975,6 +20903,103 @@ func (s *CancelMLTaskRunOutput) SetTransformId(v string) *CancelMLTaskRunOutput return s } +type CancelStatementInput struct { + _ struct{} `type:"structure"` + + // The ID of the statement to be cancelled. + // + // Id is a required field + Id *int64 `type:"integer" required:"true"` + + // The origin of the request to cancel the statement. + RequestOrigin *string `min:"1" type:"string"` + + // The Session ID of the statement to be cancelled. + // + // SessionId is a required field + SessionId *string `min:"1" type:"string" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CancelStatementInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CancelStatementInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *CancelStatementInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "CancelStatementInput"} + if s.Id == nil { + invalidParams.Add(request.NewErrParamRequired("Id")) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + if s.SessionId == nil { + invalidParams.Add(request.NewErrParamRequired("SessionId")) + } + if s.SessionId != nil && len(*s.SessionId) < 1 { + invalidParams.Add(request.NewErrParamMinLen("SessionId", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetId sets the Id field's value. +func (s *CancelStatementInput) SetId(v int64) *CancelStatementInput { + s.Id = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *CancelStatementInput) SetRequestOrigin(v string) *CancelStatementInput { + s.RequestOrigin = &v + return s +} + +// SetSessionId sets the SessionId field's value. +func (s *CancelStatementInput) SetSessionId(v string) *CancelStatementInput { + s.SessionId = &v + return s +} + +type CancelStatementOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CancelStatementOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CancelStatementOutput) GoString() string { + return s.String() +} + // Specifies a table definition in the Glue Data Catalog. type CatalogEntry struct { _ struct{} `type:"structure"` @@ -25561,6 +26586,249 @@ func (s *CreateSecurityConfigurationOutput) SetName(v string) *CreateSecurityCon return s } +// Request to create a new session. +type CreateSessionInput struct { + _ struct{} `type:"structure"` + + // The SessionCommand that runs the job. + // + // Command is a required field + Command *SessionCommand `type:"structure" required:"true"` + + // The number of connections to use for the session. + Connections *ConnectionsList `type:"structure"` + + // A map array of key-value pairs. Max is 75 pairs. + DefaultArguments map[string]*string `type:"map"` + + // The description of the session. + Description *string `type:"string"` + + // The Glue version determines the versions of Apache Spark and Python that + // AWS Glue supports. The GlueVersion must be greater than 2.0. + GlueVersion *string `min:"1" type:"string"` + + // The ID of the session request. + // + // Id is a required field + Id *string `min:"1" type:"string" required:"true"` + + // The number of seconds when idle before request times out. + IdleTimeout *int64 `min:"1" type:"integer"` + + // 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. + MaxCapacity *float64 `type:"double"` + + // The number of workers to use for the session. + NumberOfWorkers *int64 `type:"integer"` + + // The origin of the request. + RequestOrigin *string `min:"1" type:"string"` + + // The IAM Role ARN + // + // Role is a required field + Role *string `min:"20" type:"string" required:"true"` + + // The name of the SecurityConfiguration structure to be used with the session + SecurityConfiguration *string `min:"1" type:"string"` + + // The map of key value pairs (tags) belonging to the session. + Tags map[string]*string `type:"map"` + + // The number of seconds before request times out. + Timeout *int64 `min:"1" type:"integer"` + + // The Worker Type. Can be one of G.1X, G.2X, Standard + WorkerType *string `type:"string" enum:"WorkerType"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CreateSessionInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CreateSessionInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *CreateSessionInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "CreateSessionInput"} + if s.Command == nil { + invalidParams.Add(request.NewErrParamRequired("Command")) + } + if s.GlueVersion != nil && len(*s.GlueVersion) < 1 { + invalidParams.Add(request.NewErrParamMinLen("GlueVersion", 1)) + } + if s.Id == nil { + invalidParams.Add(request.NewErrParamRequired("Id")) + } + if s.Id != nil && len(*s.Id) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Id", 1)) + } + if s.IdleTimeout != nil && *s.IdleTimeout < 1 { + invalidParams.Add(request.NewErrParamMinValue("IdleTimeout", 1)) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + if s.Role == nil { + invalidParams.Add(request.NewErrParamRequired("Role")) + } + if s.Role != nil && len(*s.Role) < 20 { + invalidParams.Add(request.NewErrParamMinLen("Role", 20)) + } + if s.SecurityConfiguration != nil && len(*s.SecurityConfiguration) < 1 { + invalidParams.Add(request.NewErrParamMinLen("SecurityConfiguration", 1)) + } + if s.Timeout != nil && *s.Timeout < 1 { + invalidParams.Add(request.NewErrParamMinValue("Timeout", 1)) + } + if s.Command != nil { + if err := s.Command.Validate(); err != nil { + invalidParams.AddNested("Command", err.(request.ErrInvalidParams)) + } + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetCommand sets the Command field's value. +func (s *CreateSessionInput) SetCommand(v *SessionCommand) *CreateSessionInput { + s.Command = v + return s +} + +// SetConnections sets the Connections field's value. +func (s *CreateSessionInput) SetConnections(v *ConnectionsList) *CreateSessionInput { + s.Connections = v + return s +} + +// SetDefaultArguments sets the DefaultArguments field's value. +func (s *CreateSessionInput) SetDefaultArguments(v map[string]*string) *CreateSessionInput { + s.DefaultArguments = v + return s +} + +// SetDescription sets the Description field's value. +func (s *CreateSessionInput) SetDescription(v string) *CreateSessionInput { + s.Description = &v + return s +} + +// SetGlueVersion sets the GlueVersion field's value. +func (s *CreateSessionInput) SetGlueVersion(v string) *CreateSessionInput { + s.GlueVersion = &v + return s +} + +// SetId sets the Id field's value. +func (s *CreateSessionInput) SetId(v string) *CreateSessionInput { + s.Id = &v + return s +} + +// SetIdleTimeout sets the IdleTimeout field's value. +func (s *CreateSessionInput) SetIdleTimeout(v int64) *CreateSessionInput { + s.IdleTimeout = &v + return s +} + +// SetMaxCapacity sets the MaxCapacity field's value. +func (s *CreateSessionInput) SetMaxCapacity(v float64) *CreateSessionInput { + s.MaxCapacity = &v + return s +} + +// SetNumberOfWorkers sets the NumberOfWorkers field's value. +func (s *CreateSessionInput) SetNumberOfWorkers(v int64) *CreateSessionInput { + s.NumberOfWorkers = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *CreateSessionInput) SetRequestOrigin(v string) *CreateSessionInput { + s.RequestOrigin = &v + return s +} + +// SetRole sets the Role field's value. +func (s *CreateSessionInput) SetRole(v string) *CreateSessionInput { + s.Role = &v + return s +} + +// SetSecurityConfiguration sets the SecurityConfiguration field's value. +func (s *CreateSessionInput) SetSecurityConfiguration(v string) *CreateSessionInput { + s.SecurityConfiguration = &v + return s +} + +// SetTags sets the Tags field's value. +func (s *CreateSessionInput) SetTags(v map[string]*string) *CreateSessionInput { + s.Tags = v + return s +} + +// SetTimeout sets the Timeout field's value. +func (s *CreateSessionInput) SetTimeout(v int64) *CreateSessionInput { + s.Timeout = &v + return s +} + +// SetWorkerType sets the WorkerType field's value. +func (s *CreateSessionInput) SetWorkerType(v string) *CreateSessionInput { + s.WorkerType = &v + return s +} + +type CreateSessionOutput struct { + _ struct{} `type:"structure"` + + // Returns the session object in the response. + Session *Session `type:"structure"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CreateSessionOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s CreateSessionOutput) GoString() string { + return s.String() +} + +// SetSession sets the Session field's value. +func (s *CreateSessionOutput) SetSession(v *Session) *CreateSessionOutput { + s.Session = v + return s +} + type CreateTableInput struct { _ struct{} `type:"structure"` @@ -28492,6 +29760,98 @@ func (s DeleteSecurityConfigurationOutput) GoString() string { return s.String() } +type DeleteSessionInput struct { + _ struct{} `type:"structure"` + + // The ID of the session to be deleted. + // + // Id is a required field + Id *string `min:"1" type:"string" required:"true"` + + // The name of the origin of the delete session request. + RequestOrigin *string `min:"1" type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteSessionInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteSessionInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DeleteSessionInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DeleteSessionInput"} + if s.Id == nil { + invalidParams.Add(request.NewErrParamRequired("Id")) + } + if s.Id != nil && len(*s.Id) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Id", 1)) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetId sets the Id field's value. +func (s *DeleteSessionInput) SetId(v string) *DeleteSessionInput { + s.Id = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *DeleteSessionInput) SetRequestOrigin(v string) *DeleteSessionInput { + s.RequestOrigin = &v + return s +} + +type DeleteSessionOutput struct { + _ struct{} `type:"structure"` + + // Returns the ID of the deleted session. + Id *string `min:"1" type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteSessionOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s DeleteSessionOutput) GoString() string { + return s.String() +} + +// SetId sets the Id field's value. +func (s *DeleteSessionOutput) SetId(v string) *DeleteSessionOutput { + s.Id = &v + return s +} + type DeleteTableInput struct { _ struct{} `type:"structure"` @@ -29698,7 +31058,7 @@ type EncryptionException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` - // A message describing the problem. + // The message describing the problem. Message_ *string `locationName:"Message" type:"string"` } @@ -35414,6 +36774,204 @@ func (s *GetSecurityConfigurationsOutput) SetSecurityConfigurations(v []*Securit return s } +type GetSessionInput struct { + _ struct{} `type:"structure"` + + // The ID of the session. + // + // Id is a required field + Id *string `min:"1" type:"string" required:"true"` + + // The origin of the request. + RequestOrigin *string `min:"1" type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetSessionInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetSessionInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *GetSessionInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "GetSessionInput"} + if s.Id == nil { + invalidParams.Add(request.NewErrParamRequired("Id")) + } + if s.Id != nil && len(*s.Id) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Id", 1)) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetId sets the Id field's value. +func (s *GetSessionInput) SetId(v string) *GetSessionInput { + s.Id = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *GetSessionInput) SetRequestOrigin(v string) *GetSessionInput { + s.RequestOrigin = &v + return s +} + +type GetSessionOutput struct { + _ struct{} `type:"structure"` + + // The session object is returned in the response. + Session *Session `type:"structure"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetSessionOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetSessionOutput) GoString() string { + return s.String() +} + +// SetSession sets the Session field's value. +func (s *GetSessionOutput) SetSession(v *Session) *GetSessionOutput { + s.Session = v + return s +} + +type GetStatementInput struct { + _ struct{} `type:"structure"` + + // The Id of the statement. + // + // Id is a required field + Id *int64 `type:"integer" required:"true"` + + // The origin of the request. + RequestOrigin *string `min:"1" type:"string"` + + // The Session ID of the statement. + // + // SessionId is a required field + SessionId *string `min:"1" type:"string" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetStatementInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetStatementInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *GetStatementInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "GetStatementInput"} + if s.Id == nil { + invalidParams.Add(request.NewErrParamRequired("Id")) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + if s.SessionId == nil { + invalidParams.Add(request.NewErrParamRequired("SessionId")) + } + if s.SessionId != nil && len(*s.SessionId) < 1 { + invalidParams.Add(request.NewErrParamMinLen("SessionId", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetId sets the Id field's value. +func (s *GetStatementInput) SetId(v int64) *GetStatementInput { + s.Id = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *GetStatementInput) SetRequestOrigin(v string) *GetStatementInput { + s.RequestOrigin = &v + return s +} + +// SetSessionId sets the SessionId field's value. +func (s *GetStatementInput) SetSessionId(v string) *GetStatementInput { + s.SessionId = &v + return s +} + +type GetStatementOutput struct { + _ struct{} `type:"structure"` + + // Returns the statement. + Statement *Statement `type:"structure"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetStatementOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s GetStatementOutput) GoString() string { + return s.String() +} + +// SetStatement sets the Statement field's value. +func (s *GetStatementOutput) SetStatement(v *Statement) *GetStatementOutput { + s.Statement = v + return s +} + type GetTableInput struct { _ struct{} `type:"structure"` @@ -36239,6 +37797,7 @@ func (s *GetTriggersOutput) SetTriggers(v []*Trigger) *GetTriggersOutput { type GetUnfilteredPartitionMetadataInput struct { _ struct{} `type:"structure"` + // A structure containing information for audit. AuditContext *AuditContext `type:"structure"` // CatalogId is a required field @@ -36398,6 +37957,7 @@ func (s *GetUnfilteredPartitionMetadataOutput) SetPartition(v *Partition) *GetUn type GetUnfilteredPartitionsMetadataInput struct { _ struct{} `type:"structure"` + // A structure containing information for audit. AuditContext *AuditContext `type:"structure"` // CatalogId is a required field @@ -36578,6 +38138,7 @@ func (s *GetUnfilteredPartitionsMetadataOutput) SetUnfilteredPartitions(v []*Unf type GetUnfilteredTableMetadataInput struct { _ struct{} `type:"structure"` + // A structure containing information for audit. AuditContext *AuditContext `type:"structure"` // CatalogId is a required field @@ -37673,6 +39234,71 @@ func (s *IllegalBlueprintStateException) RequestID() string { return s.RespMetadata.RequestID } +// The session is in an invalid state to perform a requested operation. +type IllegalSessionStateException struct { + _ struct{} `type:"structure"` + RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` + + // A message describing the problem. + Message_ *string `locationName:"Message" type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s IllegalSessionStateException) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s IllegalSessionStateException) GoString() string { + return s.String() +} + +func newErrorIllegalSessionStateException(v protocol.ResponseMetadata) error { + return &IllegalSessionStateException{ + RespMetadata: v, + } +} + +// Code returns the exception type name. +func (s *IllegalSessionStateException) Code() string { + return "IllegalSessionStateException" +} + +// Message returns the exception's message. +func (s *IllegalSessionStateException) Message() string { + if s.Message_ != nil { + return *s.Message_ + } + return "" +} + +// OrigErr always returns nil, satisfies awserr.Error interface. +func (s *IllegalSessionStateException) OrigErr() error { + return nil +} + +func (s *IllegalSessionStateException) Error() string { + return fmt.Sprintf("%s: %s", s.Code(), s.Message()) +} + +// Status code returns the HTTP status code for the request's response error. +func (s *IllegalSessionStateException) StatusCode() int { + return s.RespMetadata.StatusCode +} + +// RequestID returns the service's response RequestID for request. +func (s *IllegalSessionStateException) RequestID() string { + return s.RespMetadata.RequestID +} + // The workflow is in an invalid state to perform a requested operation. type IllegalWorkflowStateException struct { _ struct{} `type:"structure"` @@ -40377,6 +42003,237 @@ func (s *ListSchemasOutput) SetSchemas(v []*SchemaListItem) *ListSchemasOutput { return s } +type ListSessionsInput struct { + _ struct{} `type:"structure"` + + // The maximum number of results. + MaxResults *int64 `min:"1" type:"integer"` + + // The token for the next set of results, or null if there are no more result. + NextToken *string `type:"string"` + + // The origin of the request. + RequestOrigin *string `min:"1" type:"string"` + + // Tags belonging to the session. + Tags map[string]*string `type:"map"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListSessionsInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListSessionsInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *ListSessionsInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "ListSessionsInput"} + if s.MaxResults != nil && *s.MaxResults < 1 { + invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetMaxResults sets the MaxResults field's value. +func (s *ListSessionsInput) SetMaxResults(v int64) *ListSessionsInput { + s.MaxResults = &v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *ListSessionsInput) SetNextToken(v string) *ListSessionsInput { + s.NextToken = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *ListSessionsInput) SetRequestOrigin(v string) *ListSessionsInput { + s.RequestOrigin = &v + return s +} + +// SetTags sets the Tags field's value. +func (s *ListSessionsInput) SetTags(v map[string]*string) *ListSessionsInput { + s.Tags = v + return s +} + +type ListSessionsOutput struct { + _ struct{} `type:"structure"` + + // Returns the Id of the session. + Ids []*string `type:"list"` + + // The token for the next set of results, or null if there are no more result. + NextToken *string `type:"string"` + + // Returns the session object. + Sessions []*Session `type:"list"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListSessionsOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListSessionsOutput) GoString() string { + return s.String() +} + +// SetIds sets the Ids field's value. +func (s *ListSessionsOutput) SetIds(v []*string) *ListSessionsOutput { + s.Ids = v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *ListSessionsOutput) SetNextToken(v string) *ListSessionsOutput { + s.NextToken = &v + return s +} + +// SetSessions sets the Sessions field's value. +func (s *ListSessionsOutput) SetSessions(v []*Session) *ListSessionsOutput { + s.Sessions = v + return s +} + +type ListStatementsInput struct { + _ struct{} `type:"structure"` + + NextToken *string `type:"string"` + + // The origin of the request to list statements. + RequestOrigin *string `min:"1" type:"string"` + + // The Session ID of the statements. + // + // SessionId is a required field + SessionId *string `min:"1" type:"string" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListStatementsInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListStatementsInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *ListStatementsInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "ListStatementsInput"} + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + if s.SessionId == nil { + invalidParams.Add(request.NewErrParamRequired("SessionId")) + } + if s.SessionId != nil && len(*s.SessionId) < 1 { + invalidParams.Add(request.NewErrParamMinLen("SessionId", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetNextToken sets the NextToken field's value. +func (s *ListStatementsInput) SetNextToken(v string) *ListStatementsInput { + s.NextToken = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *ListStatementsInput) SetRequestOrigin(v string) *ListStatementsInput { + s.RequestOrigin = &v + return s +} + +// SetSessionId sets the SessionId field's value. +func (s *ListStatementsInput) SetSessionId(v string) *ListStatementsInput { + s.SessionId = &v + return s +} + +type ListStatementsOutput struct { + _ struct{} `type:"structure"` + + NextToken *string `type:"string"` + + // Returns the list of statements. + Statements []*Statement `type:"list"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListStatementsOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s ListStatementsOutput) GoString() string { + return s.String() +} + +// SetNextToken sets the NextToken field's value. +func (s *ListStatementsOutput) SetNextToken(v string) *ListStatementsOutput { + s.NextToken = &v + return s +} + +// SetStatements sets the Statements field's value. +func (s *ListStatementsOutput) SetStatements(v []*Statement) *ListStatementsOutput { + s.Statements = v + return s +} + type ListTriggersInput struct { _ struct{} `type:"structure"` @@ -44080,6 +45937,112 @@ func (s *ResumeWorkflowRunOutput) SetRunId(v string) *ResumeWorkflowRunOutput { return s } +type RunStatementInput struct { + _ struct{} `type:"structure"` + + // The statement code to be run. + // + // Code is a required field + Code *string `type:"string" required:"true"` + + // The origin of the request. + RequestOrigin *string `min:"1" type:"string"` + + // The Session Id of the statement to be run. + // + // SessionId is a required field + SessionId *string `min:"1" type:"string" required:"true"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s RunStatementInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s RunStatementInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *RunStatementInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "RunStatementInput"} + if s.Code == nil { + invalidParams.Add(request.NewErrParamRequired("Code")) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + if s.SessionId == nil { + invalidParams.Add(request.NewErrParamRequired("SessionId")) + } + if s.SessionId != nil && len(*s.SessionId) < 1 { + invalidParams.Add(request.NewErrParamMinLen("SessionId", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetCode sets the Code field's value. +func (s *RunStatementInput) SetCode(v string) *RunStatementInput { + s.Code = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *RunStatementInput) SetRequestOrigin(v string) *RunStatementInput { + s.RequestOrigin = &v + return s +} + +// SetSessionId sets the SessionId field's value. +func (s *RunStatementInput) SetSessionId(v string) *RunStatementInput { + s.SessionId = &v + return s +} + +type RunStatementOutput struct { + _ struct{} `type:"structure"` + + // Returns the Id of the statement that was run. + Id *int64 `type:"integer"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s RunStatementOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s RunStatementOutput) GoString() string { + return s.String() +} + +// SetId sets the Id field's value. +func (s *RunStatementOutput) SetId(v int64) *RunStatementOutput { + s.Id = &v + return s +} + // Specifies how Amazon Simple Storage Service (Amazon S3) data should be encrypted. type S3Encryption struct { _ struct{} `type:"structure"` @@ -45274,6 +47237,205 @@ func (s *SerDeInfo) SetSerializationLibrary(v string) *SerDeInfo { return s } +// The period in which a remote Spark runtime environment is running. +type Session struct { + _ struct{} `type:"structure"` + + // The command object.See SessionCommand. + Command *SessionCommand `type:"structure"` + + // The number of connections used for the session. + Connections *ConnectionsList `type:"structure"` + + // The time and date when the session was created. + CreatedOn *time.Time `type:"timestamp"` + + // A map array of key-value pairs. Max is 75 pairs. + DefaultArguments map[string]*string `type:"map"` + + // The description of the session. + Description *string `type:"string"` + + // The error message displayed during the session. + ErrorMessage *string `type:"string"` + + // The Glue version determines the versions of Apache Spark and Python that + // AWS Glue supports. The GlueVersion must be greater than 2.0. + GlueVersion *string `min:"1" type:"string"` + + // The ID of the session. + Id *string `min:"1" type:"string"` + + // 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. + MaxCapacity *float64 `type:"double"` + + // The code execution progress of the session. + Progress *float64 `type:"double"` + + // The name or Amazon Resource Name (ARN) of the IAM role associated with the + // Session. + Role *string `min:"20" type:"string"` + + // The name of the SecurityConfiguration structure to be used with the session. + SecurityConfiguration *string `min:"1" type:"string"` + + // The session status. + Status *string `type:"string" enum:"SessionStatus"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s Session) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s Session) GoString() string { + return s.String() +} + +// SetCommand sets the Command field's value. +func (s *Session) SetCommand(v *SessionCommand) *Session { + s.Command = v + return s +} + +// SetConnections sets the Connections field's value. +func (s *Session) SetConnections(v *ConnectionsList) *Session { + s.Connections = v + return s +} + +// SetCreatedOn sets the CreatedOn field's value. +func (s *Session) SetCreatedOn(v time.Time) *Session { + s.CreatedOn = &v + return s +} + +// SetDefaultArguments sets the DefaultArguments field's value. +func (s *Session) SetDefaultArguments(v map[string]*string) *Session { + s.DefaultArguments = v + return s +} + +// SetDescription sets the Description field's value. +func (s *Session) SetDescription(v string) *Session { + s.Description = &v + return s +} + +// SetErrorMessage sets the ErrorMessage field's value. +func (s *Session) SetErrorMessage(v string) *Session { + s.ErrorMessage = &v + return s +} + +// SetGlueVersion sets the GlueVersion field's value. +func (s *Session) SetGlueVersion(v string) *Session { + s.GlueVersion = &v + return s +} + +// SetId sets the Id field's value. +func (s *Session) SetId(v string) *Session { + s.Id = &v + return s +} + +// SetMaxCapacity sets the MaxCapacity field's value. +func (s *Session) SetMaxCapacity(v float64) *Session { + s.MaxCapacity = &v + return s +} + +// SetProgress sets the Progress field's value. +func (s *Session) SetProgress(v float64) *Session { + s.Progress = &v + return s +} + +// SetRole sets the Role field's value. +func (s *Session) SetRole(v string) *Session { + s.Role = &v + return s +} + +// SetSecurityConfiguration sets the SecurityConfiguration field's value. +func (s *Session) SetSecurityConfiguration(v string) *Session { + s.SecurityConfiguration = &v + return s +} + +// SetStatus sets the Status field's value. +func (s *Session) SetStatus(v string) *Session { + s.Status = &v + return s +} + +// The SessionCommand that runs the job. +type SessionCommand struct { + _ struct{} `type:"structure"` + + // Specifies the name of the SessionCommand.Can be 'glueetl' or 'gluestreaming'. + Name *string `min:"1" type:"string"` + + // Specifies the Python version. The Python version indicates the version supported + // for jobs of type Spark. + PythonVersion *string `type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s SessionCommand) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s SessionCommand) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *SessionCommand) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "SessionCommand"} + if s.Name != nil && len(*s.Name) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Name", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetName sets the Name field's value. +func (s *SessionCommand) SetName(v string) *SessionCommand { + s.Name = &v + return s +} + +// SetPythonVersion sets the PythonVersion field's value. +func (s *SessionCommand) SetPythonVersion(v string) *SessionCommand { + s.PythonVersion = &v + return s +} + // Specifies skewed values in a table. Skewed values are those that occur with // very high frequency. type SkewedInfo struct { @@ -46429,6 +48591,201 @@ func (s *StartingEventBatchCondition) SetBatchWindow(v int64) *StartingEventBatc return s } +// The statement or request for a particular action to occur in a session. +type Statement struct { + _ struct{} `type:"structure"` + + // The execution code of the statement. + Code *string `type:"string"` + + // The unix time and date that the job definition was completed. + CompletedOn *int64 `type:"long"` + + // The ID of the statement. + Id *int64 `type:"integer"` + + // The output in JSON. + Output *StatementOutput_ `type:"structure"` + + // The code execution progress. + Progress *float64 `type:"double"` + + // The unix time and date that the job definition was started. + StartedOn *int64 `type:"long"` + + // The state while request is actioned. + State *string `type:"string" enum:"StatementState"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s Statement) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s Statement) GoString() string { + return s.String() +} + +// SetCode sets the Code field's value. +func (s *Statement) SetCode(v string) *Statement { + s.Code = &v + return s +} + +// SetCompletedOn sets the CompletedOn field's value. +func (s *Statement) SetCompletedOn(v int64) *Statement { + s.CompletedOn = &v + return s +} + +// SetId sets the Id field's value. +func (s *Statement) SetId(v int64) *Statement { + s.Id = &v + return s +} + +// SetOutput sets the Output field's value. +func (s *Statement) SetOutput(v *StatementOutput_) *Statement { + s.Output = v + return s +} + +// SetProgress sets the Progress field's value. +func (s *Statement) SetProgress(v float64) *Statement { + s.Progress = &v + return s +} + +// SetStartedOn sets the StartedOn field's value. +func (s *Statement) SetStartedOn(v int64) *Statement { + s.StartedOn = &v + return s +} + +// SetState sets the State field's value. +func (s *Statement) SetState(v string) *Statement { + s.State = &v + return s +} + +// The code execution output in JSON format. +type StatementOutputData struct { + _ struct{} `type:"structure"` + + // The code execution output in text format. + TextPlain *string `type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StatementOutputData) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StatementOutputData) GoString() string { + return s.String() +} + +// SetTextPlain sets the TextPlain field's value. +func (s *StatementOutputData) SetTextPlain(v string) *StatementOutputData { + s.TextPlain = &v + return s +} + +// The code execution output in JSON format. +type StatementOutput_ struct { + _ struct{} `type:"structure"` + + // The code execution output. + Data *StatementOutputData `type:"structure"` + + // The name of the error in the output. + ErrorName *string `type:"string"` + + // The error value of the output. + ErrorValue *string `type:"string"` + + // The execution count of the output. + ExecutionCount *int64 `type:"integer"` + + // The status of the code execution output. + Status *string `type:"string" enum:"StatementState"` + + // The traceback of the output. + Traceback []*string `type:"list"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StatementOutput_) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StatementOutput_) GoString() string { + return s.String() +} + +// SetData sets the Data field's value. +func (s *StatementOutput_) SetData(v *StatementOutputData) *StatementOutput_ { + s.Data = v + return s +} + +// SetErrorName sets the ErrorName field's value. +func (s *StatementOutput_) SetErrorName(v string) *StatementOutput_ { + s.ErrorName = &v + return s +} + +// SetErrorValue sets the ErrorValue field's value. +func (s *StatementOutput_) SetErrorValue(v string) *StatementOutput_ { + s.ErrorValue = &v + return s +} + +// SetExecutionCount sets the ExecutionCount field's value. +func (s *StatementOutput_) SetExecutionCount(v int64) *StatementOutput_ { + s.ExecutionCount = &v + return s +} + +// SetStatus sets the Status field's value. +func (s *StatementOutput_) SetStatus(v string) *StatementOutput_ { + s.Status = &v + return s +} + +// SetTraceback sets the Traceback field's value. +func (s *StatementOutput_) SetTraceback(v []*string) *StatementOutput_ { + s.Traceback = v + return s +} + type StopCrawlerInput struct { _ struct{} `type:"structure"` @@ -46571,6 +48928,98 @@ func (s StopCrawlerScheduleOutput) GoString() string { return s.String() } +type StopSessionInput struct { + _ struct{} `type:"structure"` + + // The ID of the session to be stopped. + // + // Id is a required field + Id *string `min:"1" type:"string" required:"true"` + + // The origin of the request. + RequestOrigin *string `min:"1" type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StopSessionInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StopSessionInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *StopSessionInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "StopSessionInput"} + if s.Id == nil { + invalidParams.Add(request.NewErrParamRequired("Id")) + } + if s.Id != nil && len(*s.Id) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Id", 1)) + } + if s.RequestOrigin != nil && len(*s.RequestOrigin) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RequestOrigin", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetId sets the Id field's value. +func (s *StopSessionInput) SetId(v string) *StopSessionInput { + s.Id = &v + return s +} + +// SetRequestOrigin sets the RequestOrigin field's value. +func (s *StopSessionInput) SetRequestOrigin(v string) *StopSessionInput { + s.RequestOrigin = &v + return s +} + +type StopSessionOutput struct { + _ struct{} `type:"structure"` + + // Returns the Id of the stopped session. + Id *string `min:"1" type:"string"` +} + +// String returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StopSessionOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation. +// +// API parameter values that are decorated as "sensitive" in the API will not +// be included in the string output. The member name will be present, but the +// value will be replaced with "sensitive". +func (s StopSessionOutput) GoString() string { + return s.String() +} + +// SetId sets the Id field's value. +func (s *StopSessionOutput) SetId(v string) *StopSessionOutput { + s.Id = &v + return s +} + type StopTriggerInput struct { _ struct{} `type:"structure"` @@ -53191,6 +55640,38 @@ func SchemaVersionStatus_Values() []string { } } +const ( + // SessionStatusProvisioning is a SessionStatus enum value + SessionStatusProvisioning = "PROVISIONING" + + // SessionStatusReady is a SessionStatus enum value + SessionStatusReady = "READY" + + // SessionStatusFailed is a SessionStatus enum value + SessionStatusFailed = "FAILED" + + // SessionStatusTimeout is a SessionStatus enum value + SessionStatusTimeout = "TIMEOUT" + + // SessionStatusStopping is a SessionStatus enum value + SessionStatusStopping = "STOPPING" + + // SessionStatusStopped is a SessionStatus enum value + SessionStatusStopped = "STOPPED" +) + +// SessionStatus_Values returns all elements of the SessionStatus enum +func SessionStatus_Values() []string { + return []string{ + SessionStatusProvisioning, + SessionStatusReady, + SessionStatusFailed, + SessionStatusTimeout, + SessionStatusStopping, + SessionStatusStopped, + } +} + const ( // SortAsc is a Sort enum value SortAsc = "ASC" @@ -53223,6 +55704,38 @@ func SortDirectionType_Values() []string { } } +const ( + // StatementStateWaiting is a StatementState enum value + StatementStateWaiting = "WAITING" + + // StatementStateRunning is a StatementState enum value + StatementStateRunning = "RUNNING" + + // StatementStateAvailable is a StatementState enum value + StatementStateAvailable = "AVAILABLE" + + // StatementStateCancelling is a StatementState enum value + StatementStateCancelling = "CANCELLING" + + // StatementStateCancelled is a StatementState enum value + StatementStateCancelled = "CANCELLED" + + // StatementStateError is a StatementState enum value + StatementStateError = "ERROR" +) + +// StatementState_Values returns all elements of the StatementState enum +func StatementState_Values() []string { + return []string{ + StatementStateWaiting, + StatementStateRunning, + StatementStateAvailable, + StatementStateCancelling, + StatementStateCancelled, + StatementStateError, + } +} + const ( // TaskRunSortColumnTypeTaskRunType is a TaskRunSortColumnType enum value TaskRunSortColumnTypeTaskRunType = "TASK_RUN_TYPE" diff --git a/service/glue/errors.go b/service/glue/errors.go index 5a687354a1d..55010d5d85f 100644 --- a/service/glue/errors.go +++ b/service/glue/errors.go @@ -84,6 +84,12 @@ const ( // "IllegalBlueprintStateException". ErrCodeIllegalBlueprintStateException = "IllegalBlueprintStateException" + // ErrCodeIllegalSessionStateException for service response error code + // "IllegalSessionStateException". + // + // The session is in an invalid state to perform a requested operation. + ErrCodeIllegalSessionStateException = "IllegalSessionStateException" + // ErrCodeIllegalWorkflowStateException for service response error code // "IllegalWorkflowStateException". // @@ -187,6 +193,7 @@ var exceptionFromCode = map[string]func(protocol.ResponseMetadata) error{ "EntityNotFoundException": newErrorEntityNotFoundException, "IdempotentParameterMismatchException": newErrorIdempotentParameterMismatchException, "IllegalBlueprintStateException": newErrorIllegalBlueprintStateException, + "IllegalSessionStateException": newErrorIllegalSessionStateException, "IllegalWorkflowStateException": newErrorIllegalWorkflowStateException, "InternalServiceException": newErrorInternalServiceException, "InvalidInputException": newErrorInvalidInputException, diff --git a/service/glue/glueiface/interface.go b/service/glue/glueiface/interface.go index 0cf7f3f670b..1a612f2cd6f 100644 --- a/service/glue/glueiface/interface.go +++ b/service/glue/glueiface/interface.go @@ -120,6 +120,10 @@ type GlueAPI interface { CancelMLTaskRunWithContext(aws.Context, *glue.CancelMLTaskRunInput, ...request.Option) (*glue.CancelMLTaskRunOutput, error) CancelMLTaskRunRequest(*glue.CancelMLTaskRunInput) (*request.Request, *glue.CancelMLTaskRunOutput) + CancelStatement(*glue.CancelStatementInput) (*glue.CancelStatementOutput, error) + CancelStatementWithContext(aws.Context, *glue.CancelStatementInput, ...request.Option) (*glue.CancelStatementOutput, error) + CancelStatementRequest(*glue.CancelStatementInput) (*request.Request, *glue.CancelStatementOutput) + CheckSchemaVersionValidity(*glue.CheckSchemaVersionValidityInput) (*glue.CheckSchemaVersionValidityOutput, error) CheckSchemaVersionValidityWithContext(aws.Context, *glue.CheckSchemaVersionValidityInput, ...request.Option) (*glue.CheckSchemaVersionValidityOutput, error) CheckSchemaVersionValidityRequest(*glue.CheckSchemaVersionValidityInput) (*request.Request, *glue.CheckSchemaVersionValidityOutput) @@ -180,6 +184,10 @@ type GlueAPI interface { CreateSecurityConfigurationWithContext(aws.Context, *glue.CreateSecurityConfigurationInput, ...request.Option) (*glue.CreateSecurityConfigurationOutput, error) CreateSecurityConfigurationRequest(*glue.CreateSecurityConfigurationInput) (*request.Request, *glue.CreateSecurityConfigurationOutput) + CreateSession(*glue.CreateSessionInput) (*glue.CreateSessionOutput, error) + CreateSessionWithContext(aws.Context, *glue.CreateSessionInput, ...request.Option) (*glue.CreateSessionOutput, error) + CreateSessionRequest(*glue.CreateSessionInput) (*request.Request, *glue.CreateSessionOutput) + CreateTable(*glue.CreateTableInput) (*glue.CreateTableOutput, error) CreateTableWithContext(aws.Context, *glue.CreateTableInput, ...request.Option) (*glue.CreateTableOutput, error) CreateTableRequest(*glue.CreateTableInput) (*request.Request, *glue.CreateTableOutput) @@ -264,6 +272,10 @@ type GlueAPI interface { DeleteSecurityConfigurationWithContext(aws.Context, *glue.DeleteSecurityConfigurationInput, ...request.Option) (*glue.DeleteSecurityConfigurationOutput, error) DeleteSecurityConfigurationRequest(*glue.DeleteSecurityConfigurationInput) (*request.Request, *glue.DeleteSecurityConfigurationOutput) + DeleteSession(*glue.DeleteSessionInput) (*glue.DeleteSessionOutput, error) + DeleteSessionWithContext(aws.Context, *glue.DeleteSessionInput, ...request.Option) (*glue.DeleteSessionOutput, error) + DeleteSessionRequest(*glue.DeleteSessionInput) (*request.Request, *glue.DeleteSessionOutput) + DeleteTable(*glue.DeleteTableInput) (*glue.DeleteTableOutput, error) DeleteTableWithContext(aws.Context, *glue.DeleteTableInput, ...request.Option) (*glue.DeleteTableOutput, error) DeleteTableRequest(*glue.DeleteTableInput) (*request.Request, *glue.DeleteTableOutput) @@ -497,6 +509,14 @@ type GlueAPI interface { GetSecurityConfigurationsPages(*glue.GetSecurityConfigurationsInput, func(*glue.GetSecurityConfigurationsOutput, bool) bool) error GetSecurityConfigurationsPagesWithContext(aws.Context, *glue.GetSecurityConfigurationsInput, func(*glue.GetSecurityConfigurationsOutput, bool) bool, ...request.Option) error + GetSession(*glue.GetSessionInput) (*glue.GetSessionOutput, error) + GetSessionWithContext(aws.Context, *glue.GetSessionInput, ...request.Option) (*glue.GetSessionOutput, error) + GetSessionRequest(*glue.GetSessionInput) (*request.Request, *glue.GetSessionOutput) + + GetStatement(*glue.GetStatementInput) (*glue.GetStatementOutput, error) + GetStatementWithContext(aws.Context, *glue.GetStatementInput, ...request.Option) (*glue.GetStatementOutput, error) + GetStatementRequest(*glue.GetStatementInput) (*request.Request, *glue.GetStatementOutput) + GetTable(*glue.GetTableInput) (*glue.GetTableOutput, error) GetTableWithContext(aws.Context, *glue.GetTableInput, ...request.Option) (*glue.GetTableOutput, error) GetTableRequest(*glue.GetTableInput) (*request.Request, *glue.GetTableOutput) @@ -639,6 +659,17 @@ type GlueAPI interface { ListSchemasPages(*glue.ListSchemasInput, func(*glue.ListSchemasOutput, bool) bool) error ListSchemasPagesWithContext(aws.Context, *glue.ListSchemasInput, func(*glue.ListSchemasOutput, bool) bool, ...request.Option) error + ListSessions(*glue.ListSessionsInput) (*glue.ListSessionsOutput, error) + ListSessionsWithContext(aws.Context, *glue.ListSessionsInput, ...request.Option) (*glue.ListSessionsOutput, error) + ListSessionsRequest(*glue.ListSessionsInput) (*request.Request, *glue.ListSessionsOutput) + + ListSessionsPages(*glue.ListSessionsInput, func(*glue.ListSessionsOutput, bool) bool) error + ListSessionsPagesWithContext(aws.Context, *glue.ListSessionsInput, func(*glue.ListSessionsOutput, bool) bool, ...request.Option) error + + ListStatements(*glue.ListStatementsInput) (*glue.ListStatementsOutput, error) + ListStatementsWithContext(aws.Context, *glue.ListStatementsInput, ...request.Option) (*glue.ListStatementsOutput, error) + ListStatementsRequest(*glue.ListStatementsInput) (*request.Request, *glue.ListStatementsOutput) + ListTriggers(*glue.ListTriggersInput) (*glue.ListTriggersOutput, error) ListTriggersWithContext(aws.Context, *glue.ListTriggersInput, ...request.Option) (*glue.ListTriggersOutput, error) ListTriggersRequest(*glue.ListTriggersInput) (*request.Request, *glue.ListTriggersOutput) @@ -689,6 +720,10 @@ type GlueAPI interface { ResumeWorkflowRunWithContext(aws.Context, *glue.ResumeWorkflowRunInput, ...request.Option) (*glue.ResumeWorkflowRunOutput, error) ResumeWorkflowRunRequest(*glue.ResumeWorkflowRunInput) (*request.Request, *glue.ResumeWorkflowRunOutput) + RunStatement(*glue.RunStatementInput) (*glue.RunStatementOutput, error) + RunStatementWithContext(aws.Context, *glue.RunStatementInput, ...request.Option) (*glue.RunStatementOutput, error) + RunStatementRequest(*glue.RunStatementInput) (*request.Request, *glue.RunStatementOutput) + SearchTables(*glue.SearchTablesInput) (*glue.SearchTablesOutput, error) SearchTablesWithContext(aws.Context, *glue.SearchTablesInput, ...request.Option) (*glue.SearchTablesOutput, error) SearchTablesRequest(*glue.SearchTablesInput) (*request.Request, *glue.SearchTablesOutput) @@ -744,6 +779,10 @@ type GlueAPI interface { StopCrawlerScheduleWithContext(aws.Context, *glue.StopCrawlerScheduleInput, ...request.Option) (*glue.StopCrawlerScheduleOutput, error) StopCrawlerScheduleRequest(*glue.StopCrawlerScheduleInput) (*request.Request, *glue.StopCrawlerScheduleOutput) + StopSession(*glue.StopSessionInput) (*glue.StopSessionOutput, error) + StopSessionWithContext(aws.Context, *glue.StopSessionInput, ...request.Option) (*glue.StopSessionOutput, error) + StopSessionRequest(*glue.StopSessionInput) (*request.Request, *glue.StopSessionOutput) + StopTrigger(*glue.StopTriggerInput) (*glue.StopTriggerOutput, error) StopTriggerWithContext(aws.Context, *glue.StopTriggerInput, ...request.Option) (*glue.StopTriggerOutput, error) StopTriggerRequest(*glue.StopTriggerInput) (*request.Request, *glue.StopTriggerOutput)