diff --git a/clients/client-kinesis-analytics-v2/README.md b/clients/client-kinesis-analytics-v2/README.md
index 05b29970e52d..cff616e23202 100644
--- a/clients/client-kinesis-analytics-v2/README.md
+++ b/clients/client-kinesis-analytics-v2/README.md
@@ -343,6 +343,14 @@ DescribeApplication
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/DescribeApplicationCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationCommandOutput/)
+
+ Creates and returns a URL that you can use to connect to
* an application's extension. The IAM role or user used to call this API defines the permissions to access the
+ * The IAM role or user used to call this API defines the permissions to access the
* extension. After the presigned URL is created, no additional permission is required to access
* this URL. IAM authorization policies for this API are also enforced for every HTTP request
* that attempts to connect to the extension. You control the amount of time that the URL will be valid using the You control the amount of time that the URL will be valid using the The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes
* to be valid.
* If you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error. The specified input parameter value is not valid. Specified application can't be found. The request was rejected because a specified parameter is not supported or a specified resource is not valid for this
+ * operation. Base exception class for all service exceptions from KinesisAnalyticsV2 service. The specified input parameter value is not valid. Specified application can't be found. The request was rejected because a specified parameter is not supported or a specified resource is not valid for this
+ * operation. Base exception class for all service exceptions from KinesisAnalyticsV2 service. Lists all the versions for the specified application, including versions that were rolled back. The response also includes a summary of the configuration
* associated with each version. To get the complete description of a specific application version, invoke the DescribeApplicationVersion operation. This operation is supported only for Managed Service for Apache Flink. Reverts the application to the previous running version. You can
- * roll back an application if you suspect it is stuck in a transient status. You can roll back an application only if it is in the When you rollback an application, it loads state data from the last successful snapshot.
+ * Reverts the application to the previous running version. You can roll back an
+ * application if you suspect it is stuck in a transient status or in the running status. You can roll back an application only if it is in the When you rollback an application, it loads state data from the last successful snapshot.
* If the application has no snapshots, Managed Service for Apache Flink rejects the rollback request. This action is not supported for Managed Service for Apache Flink for SQL applications.
+DescribeApplicationOperation
+
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/DescribeApplicationOperationCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationOperationCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DescribeApplicationOperationCommandOutput/)
+
@@ -367,6 +375,14 @@ DiscoverInputSchema
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/DiscoverInputSchemaCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DiscoverInputSchemaCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/DiscoverInputSchemaCommandOutput/)
+
+ListApplicationOperations
+
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis-analytics-v2/command/ListApplicationOperationsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/ListApplicationOperationsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-kinesis-analytics-v2/Interface/ListApplicationOperationsCommandOutput/)
+
diff --git a/clients/client-kinesis-analytics-v2/src/KinesisAnalyticsV2.ts b/clients/client-kinesis-analytics-v2/src/KinesisAnalyticsV2.ts
index c8646fcedcd3..e9a06127556b 100644
--- a/clients/client-kinesis-analytics-v2/src/KinesisAnalyticsV2.ts
+++ b/clients/client-kinesis-analytics-v2/src/KinesisAnalyticsV2.ts
@@ -87,6 +87,11 @@ import {
DescribeApplicationCommandInput,
DescribeApplicationCommandOutput,
} from "./commands/DescribeApplicationCommand";
+import {
+ DescribeApplicationOperationCommand,
+ DescribeApplicationOperationCommandInput,
+ DescribeApplicationOperationCommandOutput,
+} from "./commands/DescribeApplicationOperationCommand";
import {
DescribeApplicationSnapshotCommand,
DescribeApplicationSnapshotCommandInput,
@@ -102,6 +107,11 @@ import {
DiscoverInputSchemaCommandInput,
DiscoverInputSchemaCommandOutput,
} from "./commands/DiscoverInputSchemaCommand";
+import {
+ ListApplicationOperationsCommand,
+ ListApplicationOperationsCommandInput,
+ ListApplicationOperationsCommandOutput,
+} from "./commands/ListApplicationOperationsCommand";
import {
ListApplicationsCommand,
ListApplicationsCommandInput,
@@ -173,9 +183,11 @@ const commands = {
DeleteApplicationSnapshotCommand,
DeleteApplicationVpcConfigurationCommand,
DescribeApplicationCommand,
+ DescribeApplicationOperationCommand,
DescribeApplicationSnapshotCommand,
DescribeApplicationVersionCommand,
DiscoverInputSchemaCommand,
+ ListApplicationOperationsCommand,
ListApplicationsCommand,
ListApplicationSnapshotsCommand,
ListApplicationVersionsCommand,
@@ -479,6 +491,23 @@ export interface KinesisAnalyticsV2 {
cb: (err: any, data?: DescribeApplicationCommandOutput) => void
): void;
+ /**
+ * @see {@link DescribeApplicationOperationCommand}
+ */
+ describeApplicationOperation(
+ args: DescribeApplicationOperationCommandInput,
+ options?: __HttpHandlerOptions
+ ): Promise
SessionExpirationDurationInSeconds
+ * SessionExpirationDurationInSeconds
* parameter. If you do not provide this parameter, the returned URL is valid for twelve hours.UPDATING
- * or AUTOSCALING
status.UPDATING
,
+ * AUTOSCALING
, or RUNNING
statuses.
* "name1", "address1"
*
* NOW
- Start reading just after the most recent record in the stream, and
* start at the request timestamp that the customer issued.
@@ -926,7 +929,6 @@ export interface LambdaOutput { * in which you identify an in-application stream and a destination where you want the * in-application stream data to be written. The destination can be a Kinesis data stream or a * Kinesis Data Firehose delivery stream.
- * * * @public */ @@ -1147,7 +1149,6 @@ export interface AddApplicationOutputResponse { /** *For a SQL-based Kinesis Data Analytics application, identifies the Amazon S3 * bucket and object that contains the reference data.
- * *A SQL-based Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication * operation to trigger reloading of data into your application.
* @public @@ -1429,6 +1430,12 @@ export interface AddApplicationVpcConfigurationResponse { * @public */ VpcConfigurationDescription?: VpcConfigurationDescription; + + /** + * Operation ID for tracking AddApplicationVpcConfiguration request + * @public + */ + OperationId?: string; } /** @@ -1666,6 +1673,18 @@ export interface ApplicationSnapshotConfiguration { SnapshotsEnabled: boolean | undefined; } +/** + * Describes system rollback configuration for a Managed Service for Apache Flink application + * @public + */ +export interface ApplicationSystemRollbackConfiguration { + /** + * Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application + * @public + */ + RollbackEnabled: boolean | undefined; +} + /** *Property key-value pairs passed into an application.
* @public @@ -2140,6 +2159,12 @@ export interface ApplicationConfiguration { */ ApplicationSnapshotConfiguration?: ApplicationSnapshotConfiguration; + /** + * Describes system rollback configuration for a Managed Service for Apache Flink application + * @public + */ + ApplicationSystemRollbackConfiguration?: ApplicationSystemRollbackConfiguration; + /** *The array of descriptions of VPC configurations available to the application.
* @public @@ -2165,6 +2190,18 @@ export interface ApplicationSnapshotConfigurationDescription { SnapshotsEnabled: boolean | undefined; } +/** + * Describes system rollback configuration for a Managed Service for Apache Flink application + * @public + */ +export interface ApplicationSystemRollbackConfigurationDescription { + /** + * Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application + * @public + */ + RollbackEnabled: boolean | undefined; +} + /** *Describes the execution properties for an Apache Flink runtime.
* @public @@ -2614,6 +2651,12 @@ export interface ApplicationConfigurationDescription { */ ApplicationSnapshotConfigurationDescription?: ApplicationSnapshotConfigurationDescription; + /** + * Describes system rollback configuration for a Managed Service for Apache Flink application + * @public + */ + ApplicationSystemRollbackConfigurationDescription?: ApplicationSystemRollbackConfigurationDescription; + /** *The array of descriptions of VPC configurations available to the application.
* @public @@ -2639,6 +2682,18 @@ export interface ApplicationSnapshotConfigurationUpdate { SnapshotsEnabledUpdate: boolean | undefined; } +/** + * Describes system rollback configuration for a Managed Service for Apache Flink application + * @public + */ +export interface ApplicationSystemRollbackConfigurationUpdate { + /** + * Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application + * @public + */ + RollbackEnabledUpdate: boolean | undefined; +} + /** *Describes updates to the execution property groups for a Managed Service for Apache Flink application or a Studio notebook.
* @public @@ -3296,6 +3351,12 @@ export interface ApplicationConfigurationUpdate { */ ApplicationSnapshotConfigurationUpdate?: ApplicationSnapshotConfigurationUpdate; + /** + * Describes system rollback configuration for a Managed Service for Apache Flink application + * @public + */ + ApplicationSystemRollbackConfigurationUpdate?: ApplicationSystemRollbackConfigurationUpdate; + /** *Updates to the array of descriptions of VPC configurations available to the application.
* @public @@ -3479,6 +3540,12 @@ export interface ApplicationDetail { */ ApplicationVersionRolledBackFrom?: number; + /** + * The current timestamp when the application version was created. + * @public + */ + ApplicationVersionCreateTimestamp?: Date; + /** *A value you use to implement strong concurrency for application updates.
* @public @@ -3510,6 +3577,148 @@ export interface ApplicationMaintenanceConfigurationUpdate { ApplicationMaintenanceWindowStartTimeUpdate: string | undefined; } +/** + * @public + * @enum + */ +export const OperationStatus = { + CANCELLED: "CANCELLED", + FAILED: "FAILED", + IN_PROGRESS: "IN_PROGRESS", + SUCCESSFUL: "SUCCESSFUL", +} as const; + +/** + * @public + */ +export type OperationStatus = (typeof OperationStatus)[keyof typeof OperationStatus]; + +/** + * Provides a description of the operation, such as the type and status of operation + * @public + */ +export interface ApplicationOperationInfo { + /** + * Type of operation performed on an application + * @public + */ + Operation?: string; + + /** + * Identifier of the Operation + * @public + */ + OperationId?: string; + + /** + * The timestamp at which the operation was created + * @public + */ + StartTime?: Date; + + /** + * The timestamp at which the operation finished for the application + * @public + */ + EndTime?: Date; + + /** + * Status of the operation performed on an application + * @public + */ + OperationStatus?: OperationStatus; +} + +/** + * Contains information about the application version changes due to an operation + * @public + */ +export interface ApplicationVersionChangeDetails { + /** + * The operation was performed on this version of the application + * @public + */ + ApplicationVersionUpdatedFrom: number | undefined; + + /** + * The operation execution resulted in the transition to the following version of the application + * @public + */ + ApplicationVersionUpdatedTo: number | undefined; +} + +/** + * Provides a description of the operation failure error + * @public + */ +export interface ErrorInfo { + /** + * Error message resulting in failure of the operation + * @public + */ + ErrorString?: string; +} + +/** + * Provides a description of the operation failure + * @public + */ +export interface OperationFailureDetails { + /** + * Provides the operation ID of a system-rollback operation executed due to failure in the current operation + * @public + */ + RollbackOperationId?: string; + + /** + * Provides a description of the operation failure error + * @public + */ + ErrorInfo?: ErrorInfo; +} + +/** + * Provides a description of the operation, such as the operation-type and status + * @public + */ +export interface ApplicationOperationInfoDetails { + /** + * Type of operation performed on an application + * @public + */ + Operation: string | undefined; + + /** + * The timestamp at which the operation was created + * @public + */ + StartTime: Date | undefined; + + /** + * The timestamp at which the operation finished for the application + * @public + */ + EndTime: Date | undefined; + + /** + * Status of the operation performed on an application + * @public + */ + OperationStatus: OperationStatus | undefined; + + /** + * Contains information about the application version changes due to an operation + * @public + */ + ApplicationVersionChangeDetails?: ApplicationVersionChangeDetails; + + /** + * Provides a description of the operation failure + * @public + */ + OperationFailureDetails?: OperationFailureDetails; +} + /** *Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.
* @public @@ -3905,6 +4114,12 @@ export interface DeleteApplicationCloudWatchLoggingOptionResponse { * @public */ CloudWatchLoggingOptionDescriptions?: CloudWatchLoggingOptionDescription[]; + + /** + * Operation ID for tracking DeleteApplicationCloudWatchLoggingOption request + * @public + */ + OperationId?: string; } /** @@ -4127,6 +4342,12 @@ export interface DeleteApplicationVpcConfigurationResponse { * @public */ ApplicationVersionId?: number; + + /** + * Operation ID for tracking DeleteApplicationVpcConfiguration request + * @public + */ + OperationId?: string; } /** @@ -4158,6 +4379,36 @@ export interface DescribeApplicationResponse { ApplicationDetail: ApplicationDetail | undefined; } +/** + * Request for information about a specific operation performed on a Managed Service for Apache Flink application + * @public + */ +export interface DescribeApplicationOperationRequest { + /** + * The name of the application + * @public + */ + ApplicationName: string | undefined; + + /** + * Identifier of the Operation + * @public + */ + OperationId: string | undefined; +} + +/** + * Provides details of the operation corresponding to the operation-ID on a Managed Service for Apache Flink application + * @public + */ +export interface DescribeApplicationOperationResponse { + /** + * Provides a description of the operation, such as the operation-type and status + * @public + */ + ApplicationOperationInfoDetails?: ApplicationOperationInfoDetails; +} + /** * @public */ @@ -4440,6 +4691,60 @@ export class UnableToDetectSchemaException extends __BaseException { } } +/** + * Request to list operations performed on an application + * @public + */ +export interface ListApplicationOperationsRequest { + /** + * The name of the application + * @public + */ + ApplicationName: string | undefined; + + /** + * Limit on the number of records returned in the response + * @public + */ + Limit?: number; + + /** + * If a previous command returned a pagination token, pass it into this value to retrieve the next set of results + * @public + */ + NextToken?: string; + + /** + * Type of operation performed on an application + * @public + */ + Operation?: string; + + /** + * Status of the operation performed on an application + * @public + */ + OperationStatus?: OperationStatus; +} + +/** + * Response with the list of operations for an application + * @public + */ +export interface ListApplicationOperationsResponse { + /** + * List of ApplicationOperationInfo for an application + * @public + */ + ApplicationOperationInfoList?: ApplicationOperationInfo[]; + + /** + * If a previous command returned a pagination token, pass it into this value to retrieve the next set of results + * @public + */ + NextToken?: string; +} + /** * @public */ @@ -4616,6 +4921,12 @@ export interface RollbackApplicationResponse { * @public */ ApplicationDetail: ApplicationDetail | undefined; + + /** + * Operation ID for tracking RollbackApplication request + * @public + */ + OperationId?: string; } /** @@ -4682,7 +4993,13 @@ export interface StartApplicationRequest { /** * @public */ -export interface StartApplicationResponse {} +export interface StartApplicationResponse { + /** + * Operation ID for tracking StartApplication request + * @public + */ + OperationId?: string; +} /** * @public @@ -4698,7 +5015,7 @@ export interface StopApplicationRequest { *Set to true
to force the application to stop. If you set Force
* to true
, Managed Service for Apache Flink stops the application without taking a snapshot.
*
Force-stopping your application may lead to data loss or duplication. * To prevent data loss or duplicate processing of data during application restarts, * we recommend you to take frequent snapshots of your application.
@@ -4715,7 +5032,13 @@ export interface StopApplicationRequest { /** * @public */ -export interface StopApplicationResponse {} +export interface StopApplicationResponse { + /** + * Operation ID for tracking StopApplication request + * @public + */ + OperationId?: string; +} /** * @public @@ -4837,7 +5160,7 @@ export interface UpdateApplicationRequest { /** *Updates the Managed Service for Apache Flink runtime environment used to run your code. To avoid issues you must:
- *Ensure your new jar and dependencies are compatible with the new runtime selected.
*The descriptions of the current CloudWatch logging options for the SQL-based Kinesis Data Analytics application.
" } + }, + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Operation ID for tracking AddApplicationCloudWatchLoggingOption request" + } } }, "traits": { @@ -415,7 +421,7 @@ } ], "traits": { - "smithy.api#documentation": "Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.
\nKinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an\n in-application table within your application. In the request, you provide the source (S3\n bucket name and object key name), name of the in-application table to create, and the\n necessary mapping information that describes how data in an Amazon S3 object maps to columns\n in the resulting in-application table.
" + "smithy.api#documentation": "Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.
\nKinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an\n in-application table within your application. In the request, you provide the source (S3\n bucket name and object key name), name of the in-application table to create, and the\n necessary mapping information that describes how data in an Amazon S3 object maps to columns\n in the resulting in-application table.
" } }, "com.amazonaws.kinesisanalyticsv2#AddApplicationReferenceDataSourceRequest": { @@ -556,6 +562,12 @@ "traits": { "smithy.api#documentation": "The parameters of the new VPC configuration.
" } + }, + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Operation ID for tracking AddApplicationVpcConfiguration request" + } } }, "traits": { @@ -657,6 +669,9 @@ "smithy.api#documentation": "Describes whether snapshots are enabled for a Managed Service for Apache Flink application.
" } }, + "ApplicationSystemRollbackConfiguration": { + "target": "com.amazonaws.kinesisanalyticsv2#ApplicationSystemRollbackConfiguration" + }, "VpcConfigurations": { "target": "com.amazonaws.kinesisanalyticsv2#VpcConfigurations", "traits": { @@ -713,6 +728,9 @@ "smithy.api#documentation": "Describes whether snapshots are enabled for a Managed Service for Apache Flink application.
" } }, + "ApplicationSystemRollbackConfigurationDescription": { + "target": "com.amazonaws.kinesisanalyticsv2#ApplicationSystemRollbackConfigurationDescription" + }, "VpcConfigurationDescriptions": { "target": "com.amazonaws.kinesisanalyticsv2#VpcConfigurationDescriptions", "traits": { @@ -763,6 +781,9 @@ "smithy.api#documentation": "Describes whether snapshots are enabled for a Managed Service for Apache Flink application.
" } }, + "ApplicationSystemRollbackConfigurationUpdate": { + "target": "com.amazonaws.kinesisanalyticsv2#ApplicationSystemRollbackConfigurationUpdate" + }, "VpcConfigurationUpdates": { "target": "com.amazonaws.kinesisanalyticsv2#VpcConfigurationUpdates", "traits": { @@ -881,6 +902,12 @@ "smithy.api#documentation": "If you reverted the application using RollbackApplication,\n the application version when RollbackApplication
was called.
Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.
" } }, + "com.amazonaws.kinesisanalyticsv2#ApplicationSystemRollbackConfiguration": { + "type": "structure", + "members": { + "RollbackEnabled": { + "target": "com.amazonaws.kinesisanalyticsv2#BooleanObject", + "traits": { + "smithy.api#documentation": "Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application", + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#documentation": "Describes system rollback configuration for a Managed Service for Apache Flink application" + } + }, + "com.amazonaws.kinesisanalyticsv2#ApplicationSystemRollbackConfigurationDescription": { + "type": "structure", + "members": { + "RollbackEnabled": { + "target": "com.amazonaws.kinesisanalyticsv2#BooleanObject", + "traits": { + "smithy.api#documentation": "Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application", + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#documentation": "Describes system rollback configuration for a Managed Service for Apache Flink application" + } + }, + "com.amazonaws.kinesisanalyticsv2#ApplicationSystemRollbackConfigurationUpdate": { + "type": "structure", + "members": { + "RollbackEnabledUpdate": { + "target": "com.amazonaws.kinesisanalyticsv2#BooleanObject", + "traits": { + "smithy.api#documentation": "Describes whether system rollbacks are enabled for a Managed Service for Apache Flink application", + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#documentation": "Describes system rollback configuration for a Managed Service for Apache Flink application" + } + }, + "com.amazonaws.kinesisanalyticsv2#ApplicationVersionChangeDetails": { + "type": "structure", + "members": { + "ApplicationVersionUpdatedFrom": { + "target": "com.amazonaws.kinesisanalyticsv2#ApplicationVersionId", + "traits": { + "smithy.api#documentation": "The operation was performed on this version of the application", + "smithy.api#required": {} + } + }, + "ApplicationVersionUpdatedTo": { + "target": "com.amazonaws.kinesisanalyticsv2#ApplicationVersionId", + "traits": { + "smithy.api#documentation": "The operation execution resulted in the transition to the following version of the application", + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#documentation": "Contains information about the application version changes due to an operation" + } + }, "com.amazonaws.kinesisanalyticsv2#ApplicationVersionId": { "type": "long", "traits": { @@ -1308,7 +1481,7 @@ } }, "traits": { - "smithy.api#documentation": "For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record\n format uses delimiters, such as CSV. For example, the following sample records use CSV format,\n where the records use the '\\n' as the row delimiter and a comma (\",\") as\n the column delimiter:
\n \n\n \"name1\", \"address1\"
\n
\n \"name2\", \"address2\"
\n
For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record\n format uses delimiters, such as CSV. For example, the following sample records use CSV format,\n where the records use the '\\n' as the row delimiter and a comma (\",\") as\n the column delimiter:
\n\n \"name1\", \"address1\"
\n
\n \"name2\", \"address2\"
\n
Creates and returns a URL that you can use to connect to \n an application's extension.
\nThe IAM role or user used to call this API defines the permissions to access the\n extension. After the presigned URL is created, no additional permission is required to access\n this URL. IAM authorization policies for this API are also enforced for every HTTP request\n that attempts to connect to the extension.
\nYou control the amount of time that the URL will be valid using the SessionExpirationDurationInSeconds
\n parameter. If you do not provide this parameter, the returned URL is valid for twelve hours.
The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes\n to be valid. \n If you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error.
\nCreates and returns a URL that you can use to connect to \n an application's extension.
\nThe IAM role or user used to call this API defines the permissions to access the\n extension. After the presigned URL is created, no additional permission is required to access\n this URL. IAM authorization policies for this API are also enforced for every HTTP request\n that attempts to connect to the extension.
\nYou control the amount of time that the URL will be valid using the SessionExpirationDurationInSeconds
\n parameter. If you do not provide this parameter, the returned URL is valid for twelve hours.
The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes\n to be valid. \n If you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error.
\nThe descriptions of the remaining CloudWatch logging options for the application.
" } + }, + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Operation ID for tracking DeleteApplicationCloudWatchLoggingOption request" + } } }, "traits": { @@ -2567,6 +2746,12 @@ "traits": { "smithy.api#documentation": "The updated version ID of the application.
" } + }, + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Operation ID for tracking DeleteApplicationVpcConfiguration request" + } } }, "traits": { @@ -2640,6 +2825,62 @@ "smithy.api#documentation": "Returns information about a specific Managed Service for Apache Flink application.
\nIf you want to retrieve a list of all applications in your account,\n use the ListApplications operation.
" } }, + "com.amazonaws.kinesisanalyticsv2#DescribeApplicationOperation": { + "type": "operation", + "input": { + "target": "com.amazonaws.kinesisanalyticsv2#DescribeApplicationOperationRequest" + }, + "output": { + "target": "com.amazonaws.kinesisanalyticsv2#DescribeApplicationOperationResponse" + }, + "errors": [ + { + "target": "com.amazonaws.kinesisanalyticsv2#InvalidArgumentException" + }, + { + "target": "com.amazonaws.kinesisanalyticsv2#ResourceNotFoundException" + }, + { + "target": "com.amazonaws.kinesisanalyticsv2#UnsupportedOperationException" + } + ], + "traits": { + "smithy.api#documentation": "Returns information about a specific operation performed on a Managed Service for Apache Flink application" + } + }, + "com.amazonaws.kinesisanalyticsv2#DescribeApplicationOperationRequest": { + "type": "structure", + "members": { + "ApplicationName": { + "target": "com.amazonaws.kinesisanalyticsv2#ApplicationName", + "traits": { + "smithy.api#required": {} + } + }, + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#documentation": "Request for information about a specific operation performed on a Managed Service for Apache Flink application", + "smithy.api#input": {} + } + }, + "com.amazonaws.kinesisanalyticsv2#DescribeApplicationOperationResponse": { + "type": "structure", + "members": { + "ApplicationOperationInfoDetails": { + "target": "com.amazonaws.kinesisanalyticsv2#ApplicationOperationInfoDetails" + } + }, + "traits": { + "smithy.api#documentation": "Provides details of the operation corresponding to the operation-ID on a Managed Service for Apache Flink application", + "smithy.api#output": {} + } + }, "com.amazonaws.kinesisanalyticsv2#DescribeApplicationRequest": { "type": "structure", "members": { @@ -2954,9 +3195,30 @@ "smithy.api#documentation": "Describes updates to the execution property groups for a Managed Service for Apache Flink application or a Studio notebook.
" } }, + "com.amazonaws.kinesisanalyticsv2#ErrorInfo": { + "type": "structure", + "members": { + "ErrorString": { + "target": "com.amazonaws.kinesisanalyticsv2#ErrorString" + } + }, + "traits": { + "smithy.api#documentation": "Provides a description of the operation failure error" + } + }, "com.amazonaws.kinesisanalyticsv2#ErrorMessage": { "type": "string" }, + "com.amazonaws.kinesisanalyticsv2#ErrorString": { + "type": "string", + "traits": { + "smithy.api#documentation": "Error message resulting in failure of the operation", + "smithy.api#length": { + "min": 1, + "max": 512 + } + } + }, "com.amazonaws.kinesisanalyticsv2#FileKey": { "type": "string", "traits": { @@ -3446,7 +3708,7 @@ "InputStartingPosition": { "target": "com.amazonaws.kinesisanalyticsv2#InputStartingPosition", "traits": { - "smithy.api#documentation": "The starting position on the stream.
\n\n NOW
- Start reading just after the most recent record in the stream, and\n start at the request timestamp that the customer issued.
\n TRIM_HORIZON
- Start reading at the last untrimmed record in the stream, \n which is the oldest record available in the stream. This option is not available \n for an Amazon Kinesis Data Firehose delivery stream.
\n LAST_STOPPED_POINT
- Resume reading from where the application last stopped reading.
The starting position on the stream.
\n\n NOW
- Start reading just after the most recent record in the stream, and\n start at the request timestamp that the customer issued.
\n TRIM_HORIZON
- Start reading at the last untrimmed record in the stream, \n which is the oldest record available in the stream. This option is not available \n for an Amazon Kinesis Data Firehose delivery stream.
\n LAST_STOPPED_POINT
- Resume reading from where the application last stopped reading.
Lists information about the current application snapshots.
" + "smithy.api#documentation": "Lists information about the current application snapshots.
", + "smithy.api#paginated": { + "inputToken": "NextToken", + "outputToken": "NextToken", + "items": "SnapshotSummaries", + "pageSize": "Limit" + } } }, "com.amazonaws.kinesisanalyticsv2#ListApplicationSnapshotsRequest": { @@ -4967,7 +5322,13 @@ } ], "traits": { - "smithy.api#documentation": "Lists all the versions for the specified application, including versions that were rolled back. The response also includes a summary of the configuration \n associated with each version.
\n \nTo get the complete description of a specific application version, invoke the DescribeApplicationVersion operation.
\nThis operation is supported only for Managed Service for Apache Flink.
\nLists all the versions for the specified application, including versions that were rolled back. The response also includes a summary of the configuration \n associated with each version.
\nTo get the complete description of a specific application version, invoke the DescribeApplicationVersion operation.
\nThis operation is supported only for Managed Service for Apache Flink.
\nReturns a list of Managed Service for Apache Flink applications in your account. For each\n application, the response includes the application name, Amazon Resource Name (ARN), and\n status.
\nIf you want detailed information about a specific application, use \n DescribeApplication.
" + "smithy.api#documentation": "Returns a list of Managed Service for Apache Flink applications in your account. For each\n application, the response includes the application name, Amazon Resource Name (ARN), and\n status.
\nIf you want detailed information about a specific application, use \n DescribeApplication.
", + "smithy.api#paginated": { + "inputToken": "NextToken", + "outputToken": "NextToken", + "items": "ApplicationSummaries", + "pageSize": "Limit" + } } }, "com.amazonaws.kinesisanalyticsv2#ListApplicationsInputLimit": { @@ -5391,6 +5758,7 @@ "com.amazonaws.kinesisanalyticsv2#NextToken": { "type": "string", "traits": { + "smithy.api#documentation": "If a previous command returned a pagination token, pass it into this value to retrieve the next set of results", "smithy.api#length": { "min": 1, "max": 512 @@ -5406,6 +5774,75 @@ } } }, + "com.amazonaws.kinesisanalyticsv2#Operation": { + "type": "string", + "traits": { + "smithy.api#documentation": "Type of operation performed on an application", + "smithy.api#length": { + "min": 1, + "max": 64 + } + } + }, + "com.amazonaws.kinesisanalyticsv2#OperationFailureDetails": { + "type": "structure", + "members": { + "RollbackOperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Provides the operation ID of a system-rollback operation executed due to failure in the current operation" + } + }, + "ErrorInfo": { + "target": "com.amazonaws.kinesisanalyticsv2#ErrorInfo" + } + }, + "traits": { + "smithy.api#documentation": "Provides a description of the operation failure" + } + }, + "com.amazonaws.kinesisanalyticsv2#OperationId": { + "type": "string", + "traits": { + "smithy.api#documentation": "Identifier of the Operation", + "smithy.api#length": { + "min": 1, + "max": 64 + } + } + }, + "com.amazonaws.kinesisanalyticsv2#OperationStatus": { + "type": "enum", + "members": { + "IN_PROGRESS": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "IN_PROGRESS" + } + }, + "CANCELLED": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "CANCELLED" + } + }, + "SUCCESSFUL": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "SUCCESSFUL" + } + }, + "FAILED": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "FAILED" + } + } + }, + "traits": { + "smithy.api#documentation": "Status of the operation performed on an application" + } + }, "com.amazonaws.kinesisanalyticsv2#Output": { "type": "structure", "members": { @@ -5443,7 +5880,7 @@ } }, "traits": { - "smithy.api#documentation": "Describes a SQL-based Kinesis Data Analytics application's output configuration,\n in which you identify an in-application stream and a destination where you want the\n in-application stream data to be written. The destination can be a Kinesis data stream or a\n Kinesis Data Firehose delivery stream.
\n \n " + "smithy.api#documentation": "Describes a SQL-based Kinesis Data Analytics application's output configuration,\n in which you identify an in-application stream and a destination where you want the\n in-application stream data to be written. The destination can be a Kinesis data stream or a\n Kinesis Data Firehose delivery stream.
\n " } }, "com.amazonaws.kinesisanalyticsv2#OutputDescription": { @@ -6115,7 +6552,7 @@ } ], "traits": { - "smithy.api#documentation": "Reverts the application to the previous running version. You can\n roll back an application if you suspect it is stuck in a transient status.
\nYou can roll back an application only if it is in the UPDATING
\n or AUTOSCALING
status.
When you rollback an application, it loads state data from the last successful snapshot.\n If the application has no snapshots, Managed Service for Apache Flink rejects the rollback request.
\nThis action is not supported for Managed Service for Apache Flink for SQL applications.
" + "smithy.api#documentation": "Reverts the application to the previous running version. You can roll back an\n application if you suspect it is stuck in a transient status or in the running status.
\nYou can roll back an application only if it is in the UPDATING
,\n AUTOSCALING
, or RUNNING
statuses.
When you rollback an application, it loads state data from the last successful snapshot.\n If the application has no snapshots, Managed Service for Apache Flink rejects the rollback request.
" } }, "com.amazonaws.kinesisanalyticsv2#RollbackApplicationRequest": { @@ -6148,6 +6585,12 @@ "traits": { "smithy.api#required": {} } + }, + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Operation ID for tracking RollbackApplication request" + } } }, "traits": { @@ -6465,7 +6908,7 @@ } }, "traits": { - "smithy.api#documentation": "For a SQL-based Kinesis Data Analytics application, identifies the Amazon S3\n bucket and object that contains the reference data.
\n \nA SQL-based Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication\n operation to trigger reloading of data into your application.
" + "smithy.api#documentation": "For a SQL-based Kinesis Data Analytics application, identifies the Amazon S3\n bucket and object that contains the reference data.
\nA SQL-based Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication\n operation to trigger reloading of data into your application.
" } }, "com.amazonaws.kinesisanalyticsv2#S3ReferenceDataSourceDescription": { @@ -6825,7 +7268,14 @@ }, "com.amazonaws.kinesisanalyticsv2#StartApplicationResponse": { "type": "structure", - "members": {}, + "members": { + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Operation ID for tracking StartApplication request" + } + } + }, "traits": { "smithy.api#output": {} } @@ -6859,7 +7309,7 @@ } ], "traits": { - "smithy.api#documentation": "Stops the application from processing data. You can stop\n an application only if it is in the running status, unless you set the Force
\n parameter to true
.
You can use the DescribeApplication operation to find the application status.\n
\nManaged Service for Apache Flink takes a snapshot when the application is stopped, unless Force
is set \n to true
.
Stops the application from processing data. You can stop\n an application only if it is in the running status, unless you set the Force
\n parameter to true
.
You can use the DescribeApplication operation to find the application status.\n
\nManaged Service for Apache Flink takes a snapshot when the application is stopped, unless Force
is set \n to true
.
Set to true
to force the application to stop. If you set Force
\n to true
, Managed Service for Apache Flink stops the application without taking a snapshot. \n
Force-stopping your application may lead to data loss or duplication.\n To prevent data loss or duplicate processing of data during application restarts, \n we recommend you to take frequent snapshots of your application.
\nYou can only force stop a Managed Service for Apache Flink application. You can't force stop a SQL-based Kinesis Data Analytics application.
\nThe application must be in the\n STARTING
, UPDATING
, STOPPING
, AUTOSCALING
, or\n RUNNING
status.
Set to true
to force the application to stop. If you set Force
\n to true
, Managed Service for Apache Flink stops the application without taking a snapshot. \n
Force-stopping your application may lead to data loss or duplication.\n To prevent data loss or duplicate processing of data during application restarts, \n we recommend you to take frequent snapshots of your application.
\nYou can only force stop a Managed Service for Apache Flink application. You can't force stop a SQL-based Kinesis Data Analytics application.
\nThe application must be in the\n STARTING
, UPDATING
, STOPPING
, AUTOSCALING
, or\n RUNNING
status.
Updates the Managed Service for Apache Flink runtime environment used to run your code. To avoid issues you must:
\nEnsure your new jar and dependencies are compatible with the new runtime selected.
\nEnsure your new code's state is compatible with the snapshot from which your application will start
\nUpdates the Managed Service for Apache Flink runtime environment used to run your code. To avoid issues you must:
\nEnsure your new jar and dependencies are compatible with the new runtime selected.
\nEnsure your new code's state is compatible with the snapshot from which your application will start
\nDescribes application updates.
", "smithy.api#required": {} } + }, + "OperationId": { + "target": "com.amazonaws.kinesisanalyticsv2#OperationId", + "traits": { + "smithy.api#documentation": "Operation ID for tracking UpdateApplication request" + } } }, "traits": {