lib/aws-sdk-kinesisanalyticsv2/client.rb in aws-sdk-kinesisanalyticsv2-1.29.0 vs lib/aws-sdk-kinesisanalyticsv2/client.rb in aws-sdk-kinesisanalyticsv2-1.30.0

- old
+ new

@@ -343,21 +343,25 @@ # @option params [required, String] :application_name # The Kinesis Data Analytics application name. # # @option params [Integer] :current_application_version_id # The version ID of the Kinesis Data Analytics application. You must - # provide the `ApplicationVersionID` or the `ConditionalToken`.You can - # retrieve the application version ID using DescribeApplication. + # provide the `CurrentApplicationVersionId` or the + # `ConditionalToken`.You can retrieve the application version ID using + # DescribeApplication. For better concurrency support, use the + # `ConditionalToken` parameter instead of `CurrentApplicationVersionId`. # # @option params [required, Types::CloudWatchLoggingOption] :cloud_watch_logging_option # Provides the Amazon CloudWatch log stream Amazon Resource Name (ARN). # # @option params [String] :conditional_token # A value you use to implement strong concurrency for application - # updates. You must provide the `ApplicationVersionID` or the + # updates. You must provide the `CurrentApplicationVersionId` or the # `ConditionalToken`. You get the application's current - # `ConditionalToken` using DescribeApplication. + # `ConditionalToken` using DescribeApplication. For better concurrency + # support, use the `ConditionalToken` parameter instead of + # `CurrentApplicationVersionId`. # # @return [Types::AddApplicationCloudWatchLoggingOptionResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods: # # * {Types::AddApplicationCloudWatchLoggingOptionResponse#application_arn #application_arn} => String # * {Types::AddApplicationCloudWatchLoggingOptionResponse#application_version_id #application_version_id} => Integer @@ -517,12 +521,11 @@ # The name of the application to which you want to add the input # processing configuration. # # @option params [required, Integer] :current_application_version_id # The version of the application to which you want to add the input - # processing configuration. You must provide the `ApplicationVersionID` - # or the `ConditionalToken`. You can use the DescribeApplication + # processing configuration. You can use the DescribeApplication # operation to get the current application version. If the version # specified is not the current version, the # `ConcurrentModificationException` is returned. # # @option params [required, String] :input_id @@ -595,15 +598,13 @@ # The name of the application to which you want to add the output # configuration. # # @option params [required, Integer] :current_application_version_id # The version of the application to which you want to add the output - # configuration. You must provide the `ApplicationVersionID` or the - # `ConditionalToken`. You can use the DescribeApplication operation to - # get the current application version. If the version specified is not - # the current version, the `ConcurrentModificationException` is - # returned. + # configuration. You can use the DescribeApplication operation to get + # the current application version. If the version specified is not the + # current version, the `ConcurrentModificationException` is returned. # # @option params [required, Types::Output] :output # An array of objects, each describing one output configuration. In the # output configuration, you specify the name of an in-application # stream, a destination (that is, a Kinesis data stream, a Kinesis Data @@ -774,24 +775,27 @@ # @option params [required, String] :application_name # The name of an existing application. # # @option params [Integer] :current_application_version_id # The version of the application to which you want to add the VPC - # configuration. You must provide the `ApplicationVersionID` or the - # `ConditionalToken`. You can use the DescribeApplication operation to - # get the current application version. If the version specified is not - # the current version, the `ConcurrentModificationException` is - # returned. + # configuration. You must provide the `CurrentApplicationVersionId` or + # the `ConditionalToken`. You can use the DescribeApplication operation + # to get the current application version. If the version specified is + # not the current version, the `ConcurrentModificationException` is + # returned. For better concurrency support, use the `ConditionalToken` + # parameter instead of `CurrentApplicationVersionId`. # # @option params [required, Types::VpcConfiguration] :vpc_configuration # Description of the VPC to add to the application. # # @option params [String] :conditional_token # A value you use to implement strong concurrency for application # updates. You must provide the `ApplicationVersionID` or the # `ConditionalToken`. You get the application's current - # `ConditionalToken` using DescribeApplication. + # `ConditionalToken` using DescribeApplication. For better concurrency + # support, use the `ConditionalToken` parameter instead of + # `CurrentApplicationVersionId`. # # @return [Types::AddApplicationVpcConfigurationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods: # # * {Types::AddApplicationVpcConfigurationResponse#application_arn #application_arn} => String # * {Types::AddApplicationVpcConfigurationResponse#application_version_id #application_version_id} => Integer @@ -868,20 +872,25 @@ # # # # [1]: https://docs.aws.amazon.com/kinesisanalytics/latest/java/how-tagging.html # + # @option params [String] :application_mode + # Use the `STREAMING` mode to create a Kinesis Data Analytics Studio + # notebook. To create a Kinesis Data Analytics Studio notebook, use the + # `INTERACTIVE` mode. + # # @return [Types::CreateApplicationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods: # # * {Types::CreateApplicationResponse#application_detail #application_detail} => Types::ApplicationDetail # # @example Request syntax with placeholder values # # resp = client.create_application({ # application_name: "ApplicationName", # required # application_description: "ApplicationDescription", - # runtime_environment: "SQL-1_0", # required, accepts SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11 + # runtime_environment: "SQL-1_0", # required, accepts SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, ZEPPELIN-FLINK-1_0 # service_execution_role: "RoleARN", # required # application_configuration: { # sql_application_configuration: { # inputs: [ # { @@ -1000,11 +1009,11 @@ # "PropertyKey" => "PropertyValue", # }, # }, # ], # }, - # application_code_configuration: { # required + # application_code_configuration: { # code_content: { # text_content: "TextContent", # zip_file_content: "data", # s3_content_location: { # bucket_arn: "BucketARN", # required @@ -1021,10 +1030,41 @@ # { # subnet_ids: ["SubnetId"], # required # security_group_ids: ["SecurityGroupId"], # required # }, # ], + # zeppelin_application_configuration: { + # monitoring_configuration: { + # log_level: "INFO", # required, accepts INFO, WARN, ERROR, DEBUG + # }, + # catalog_configuration: { + # glue_data_catalog_configuration: { # required + # database_arn: "DatabaseARN", # required + # }, + # }, + # deploy_as_application_configuration: { + # s3_content_location: { # required + # bucket_arn: "BucketARN", # required + # base_path: "BasePath", + # }, + # }, + # custom_artifacts_configuration: [ + # { + # artifact_type: "UDF", # required, accepts UDF, DEPENDENCY_JAR + # s3_content_location: { + # bucket_arn: "BucketARN", # required + # file_key: "FileKey", # required + # object_version: "ObjectVersion", + # }, + # maven_reference: { + # group_id: "MavenGroupId", # required + # artifact_id: "MavenArtifactId", # required + # version: "MavenVersion", # required + # }, + # }, + # ], + # }, # }, # cloud_watch_logging_options: [ # { # log_stream_arn: "LogStreamARN", # required # }, @@ -1033,18 +1073,19 @@ # { # key: "TagKey", # required # value: "TagValue", # }, # ], + # application_mode: "STREAMING", # accepts STREAMING, INTERACTIVE # }) # # @example Response structure # # resp.application_detail.application_arn #=> String # resp.application_detail.application_description #=> String # resp.application_detail.application_name #=> String - # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11" + # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11", "ZEPPELIN-FLINK-1_0" # resp.application_detail.service_execution_role #=> String # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING", "MAINTENANCE", "ROLLING_BACK", "ROLLED_BACK" # resp.application_detail.application_version_id #=> Integer # resp.application_detail.create_timestamp #=> Time # resp.application_detail.last_update_timestamp #=> Time @@ -1128,20 +1169,33 @@ # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].vpc_id #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids[0] #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids[0] #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.monitoring_configuration_description.log_level #=> String, one of "INFO", "WARN", "ERROR", "DEBUG" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.catalog_configuration_description.glue_data_catalog_configuration_description.database_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.base_path #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description #=> Array + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].artifact_type #=> String, one of "UDF", "DEPENDENCY_JAR" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.file_key #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.object_version #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.group_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.artifact_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.version #=> String # resp.application_detail.cloud_watch_logging_option_descriptions #=> Array # resp.application_detail.cloud_watch_logging_option_descriptions[0].cloud_watch_logging_option_id #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].log_stream_arn #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].role_arn #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_start_time #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_end_time #=> String # resp.application_detail.application_version_updated_from #=> Integer # resp.application_detail.application_version_rolled_back_from #=> Integer # resp.application_detail.conditional_token #=> String # resp.application_detail.application_version_rolled_back_to #=> Integer + # resp.application_detail.application_mode #=> String, one of "STREAMING", "INTERACTIVE" # # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/CreateApplication AWS API Documentation # # @overload create_application(params = {}) # @param [Hash] params ({}) @@ -1187,11 +1241,11 @@ # # @example Request syntax with placeholder values # # resp = client.create_application_presigned_url({ # application_name: "ApplicationName", # required - # url_type: "FLINK_DASHBOARD_URL", # required, accepts FLINK_DASHBOARD_URL + # url_type: "FLINK_DASHBOARD_URL", # required, accepts FLINK_DASHBOARD_URL, ZEPPELIN_UI_URL # session_expiration_duration_in_seconds: 1, # }) # # @example Response structure # @@ -1265,23 +1319,27 @@ # @option params [required, String] :application_name # The application name. # # @option params [Integer] :current_application_version_id # The version ID of the application. You must provide the - # `ApplicationVersionID` or the `ConditionalToken`. You can retrieve the - # application version ID using DescribeApplication. + # `CurrentApplicationVersionId` or the `ConditionalToken`. You can + # retrieve the application version ID using DescribeApplication. For + # better concurrency support, use the `ConditionalToken` parameter + # instead of `CurrentApplicationVersionId`. # # @option params [required, String] :cloud_watch_logging_option_id # The `CloudWatchLoggingOptionId` of the Amazon CloudWatch logging # option to delete. You can get the `CloudWatchLoggingOptionId` by using # the DescribeApplication operation. # # @option params [String] :conditional_token # A value you use to implement strong concurrency for application - # updates. You must provide the `ApplicationVersionID` or the + # updates. You must provide the `CurrentApplicationVersionId` or the # `ConditionalToken`. You get the application's current - # `ConditionalToken` using DescribeApplication. + # `ConditionalToken` using DescribeApplication. For better concurrency + # support, use the `ConditionalToken` parameter instead of + # `CurrentApplicationVersionId`. # # @return [Types::DeleteApplicationCloudWatchLoggingOptionResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods: # # * {Types::DeleteApplicationCloudWatchLoggingOptionResponse#application_arn #application_arn} => String # * {Types::DeleteApplicationCloudWatchLoggingOptionResponse#application_version_id #application_version_id} => Integer @@ -1492,21 +1550,25 @@ # @option params [required, String] :application_name # The name of an existing application. # # @option params [Integer] :current_application_version_id # The current application version ID. You must provide the - # `ApplicationVersionID` or the `ConditionalToken`.You can retrieve the - # application version ID using DescribeApplication. + # `CurrentApplicationVersionId` or the `ConditionalToken`. You can + # retrieve the application version ID using DescribeApplication. For + # better concurrency support, use the `ConditionalToken` parameter + # instead of `CurrentApplicationVersionId`. # # @option params [required, String] :vpc_configuration_id # The ID of the VPC configuration to delete. # # @option params [String] :conditional_token # A value you use to implement strong concurrency for application - # updates. You must provide the `ApplicationVersionID` or the + # updates. You must provide the `CurrentApplicationVersionId` or the # `ConditionalToken`. You get the application's current - # `ConditionalToken` using DescribeApplication. + # `ConditionalToken` using DescribeApplication. For better concurrency + # support, use the `ConditionalToken` parameter instead of + # `CurrentApplicationVersionId`. # # @return [Types::DeleteApplicationVpcConfigurationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods: # # * {Types::DeleteApplicationVpcConfigurationResponse#application_arn #application_arn} => String # * {Types::DeleteApplicationVpcConfigurationResponse#application_version_id #application_version_id} => Integer @@ -1561,11 +1623,11 @@ # @example Response structure # # resp.application_detail.application_arn #=> String # resp.application_detail.application_description #=> String # resp.application_detail.application_name #=> String - # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11" + # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11", "ZEPPELIN-FLINK-1_0" # resp.application_detail.service_execution_role #=> String # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING", "MAINTENANCE", "ROLLING_BACK", "ROLLED_BACK" # resp.application_detail.application_version_id #=> Integer # resp.application_detail.create_timestamp #=> Time # resp.application_detail.last_update_timestamp #=> Time @@ -1649,20 +1711,33 @@ # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].vpc_id #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids[0] #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids[0] #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.monitoring_configuration_description.log_level #=> String, one of "INFO", "WARN", "ERROR", "DEBUG" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.catalog_configuration_description.glue_data_catalog_configuration_description.database_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.base_path #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description #=> Array + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].artifact_type #=> String, one of "UDF", "DEPENDENCY_JAR" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.file_key #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.object_version #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.group_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.artifact_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.version #=> String # resp.application_detail.cloud_watch_logging_option_descriptions #=> Array # resp.application_detail.cloud_watch_logging_option_descriptions[0].cloud_watch_logging_option_id #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].log_stream_arn #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].role_arn #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_start_time #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_end_time #=> String # resp.application_detail.application_version_updated_from #=> Integer # resp.application_detail.application_version_rolled_back_from #=> Integer # resp.application_detail.conditional_token #=> String # resp.application_detail.application_version_rolled_back_to #=> Integer + # resp.application_detail.application_mode #=> String, one of "STREAMING", "INTERACTIVE" # # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DescribeApplication AWS API Documentation # # @overload describe_application(params = {}) # @param [Hash] params ({}) @@ -1738,11 +1813,11 @@ # @example Response structure # # resp.application_version_detail.application_arn #=> String # resp.application_version_detail.application_description #=> String # resp.application_version_detail.application_name #=> String - # resp.application_version_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11" + # resp.application_version_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11", "ZEPPELIN-FLINK-1_0" # resp.application_version_detail.service_execution_role #=> String # resp.application_version_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING", "MAINTENANCE", "ROLLING_BACK", "ROLLED_BACK" # resp.application_version_detail.application_version_id #=> Integer # resp.application_version_detail.create_timestamp #=> Time # resp.application_version_detail.last_update_timestamp #=> Time @@ -1826,20 +1901,33 @@ # resp.application_version_detail.application_configuration_description.vpc_configuration_descriptions[0].vpc_id #=> String # resp.application_version_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids #=> Array # resp.application_version_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids[0] #=> String # resp.application_version_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids #=> Array # resp.application_version_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids[0] #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.monitoring_configuration_description.log_level #=> String, one of "INFO", "WARN", "ERROR", "DEBUG" + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.catalog_configuration_description.glue_data_catalog_configuration_description.database_arn #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.bucket_arn #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.base_path #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description #=> Array + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].artifact_type #=> String, one of "UDF", "DEPENDENCY_JAR" + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.bucket_arn #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.file_key #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.object_version #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.group_id #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.artifact_id #=> String + # resp.application_version_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.version #=> String # resp.application_version_detail.cloud_watch_logging_option_descriptions #=> Array # resp.application_version_detail.cloud_watch_logging_option_descriptions[0].cloud_watch_logging_option_id #=> String # resp.application_version_detail.cloud_watch_logging_option_descriptions[0].log_stream_arn #=> String # resp.application_version_detail.cloud_watch_logging_option_descriptions[0].role_arn #=> String # resp.application_version_detail.application_maintenance_configuration_description.application_maintenance_window_start_time #=> String # resp.application_version_detail.application_maintenance_configuration_description.application_maintenance_window_end_time #=> String # resp.application_version_detail.application_version_updated_from #=> Integer # resp.application_version_detail.application_version_rolled_back_from #=> Integer # resp.application_version_detail.conditional_token #=> String # resp.application_version_detail.application_version_rolled_back_to #=> Integer + # resp.application_version_detail.application_mode #=> String, one of "STREAMING", "INTERACTIVE" # # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DescribeApplicationVersion AWS API Documentation # # @overload describe_application_version(params = {}) # @param [Hash] params ({}) @@ -2071,11 +2159,12 @@ # resp.application_summaries #=> Array # resp.application_summaries[0].application_name #=> String # resp.application_summaries[0].application_arn #=> String # resp.application_summaries[0].application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING", "MAINTENANCE", "ROLLING_BACK", "ROLLED_BACK" # resp.application_summaries[0].application_version_id #=> Integer - # resp.application_summaries[0].runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11" + # resp.application_summaries[0].runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11", "ZEPPELIN-FLINK-1_0" + # resp.application_summaries[0].application_mode #=> String, one of "STREAMING", "INTERACTIVE" # resp.next_token #=> String # # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListApplications AWS API Documentation # # @overload list_applications(params = {}) @@ -2154,11 +2243,11 @@ # @example Response structure # # resp.application_detail.application_arn #=> String # resp.application_detail.application_description #=> String # resp.application_detail.application_name #=> String - # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11" + # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11", "ZEPPELIN-FLINK-1_0" # resp.application_detail.service_execution_role #=> String # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING", "MAINTENANCE", "ROLLING_BACK", "ROLLED_BACK" # resp.application_detail.application_version_id #=> Integer # resp.application_detail.create_timestamp #=> Time # resp.application_detail.last_update_timestamp #=> Time @@ -2242,20 +2331,33 @@ # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].vpc_id #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids[0] #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids[0] #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.monitoring_configuration_description.log_level #=> String, one of "INFO", "WARN", "ERROR", "DEBUG" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.catalog_configuration_description.glue_data_catalog_configuration_description.database_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.base_path #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description #=> Array + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].artifact_type #=> String, one of "UDF", "DEPENDENCY_JAR" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.file_key #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.object_version #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.group_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.artifact_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.version #=> String # resp.application_detail.cloud_watch_logging_option_descriptions #=> Array # resp.application_detail.cloud_watch_logging_option_descriptions[0].cloud_watch_logging_option_id #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].log_stream_arn #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].role_arn #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_start_time #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_end_time #=> String # resp.application_detail.application_version_updated_from #=> Integer # resp.application_detail.application_version_rolled_back_from #=> Integer # resp.application_detail.conditional_token #=> String # resp.application_detail.application_version_rolled_back_to #=> Integer + # resp.application_detail.application_mode #=> String, one of "STREAMING", "INTERACTIVE" # # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/RollbackApplication AWS API Documentation # # @overload rollback_application(params = {}) # @param [Hash] params ({}) @@ -2269,21 +2371,21 @@ # start your application. # # @option params [required, String] :application_name # The name of the application. # - # @option params [required, Types::RunConfiguration] :run_configuration + # @option params [Types::RunConfiguration] :run_configuration # Identifies the run configuration (start parameters) of a Kinesis Data # Analytics application. # # @return [Struct] Returns an empty {Seahorse::Client::Response response}. # # @example Request syntax with placeholder values # # resp = client.start_application({ # application_name: "ApplicationName", # required - # run_configuration: { # required + # run_configuration: { # flink_run_configuration: { # allow_non_restored_state: false, # }, # sql_run_configurations: [ # { @@ -2445,12 +2547,14 @@ # @option params [required, String] :application_name # The name of the application to update. # # @option params [Integer] :current_application_version_id # The current application version ID. You must provide the - # `ApplicationVersionID` or the `ConditionalToken`.You can retrieve the - # application version ID using DescribeApplication. + # `CurrentApplicationVersionId` or the `ConditionalToken`.You can + # retrieve the application version ID using DescribeApplication. For + # better concurrency support, use the `ConditionalToken` parameter + # instead of `CurrentApplicationVersionId`. # # @option params [Types::ApplicationConfigurationUpdate] :application_configuration_update # Describes application configuration updates. # # @option params [String] :service_execution_role_update @@ -2465,13 +2569,15 @@ # To add a new CloudWatch logging option, use # AddApplicationCloudWatchLoggingOption. # # @option params [String] :conditional_token # A value you use to implement strong concurrency for application - # updates. You must provide the `ApplicationVersionID` or the + # updates. You must provide the `CurrentApplicationVersionId` or the # `ConditionalToken`. You get the application's current - # `ConditionalToken` using DescribeApplication. + # `ConditionalToken` using DescribeApplication. For better concurrency + # support, use the `ConditionalToken` parameter instead of + # `CurrentApplicationVersionId`. # # @return [Types::UpdateApplicationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods: # # * {Types::UpdateApplicationResponse#application_detail #application_detail} => Types::ApplicationDetail # @@ -2624,10 +2730,41 @@ # vpc_configuration_id: "Id", # required # subnet_id_updates: ["SubnetId"], # security_group_id_updates: ["SecurityGroupId"], # }, # ], + # zeppelin_application_configuration_update: { + # monitoring_configuration_update: { + # log_level_update: "INFO", # required, accepts INFO, WARN, ERROR, DEBUG + # }, + # catalog_configuration_update: { + # glue_data_catalog_configuration_update: { # required + # database_arn_update: "DatabaseARN", + # }, + # }, + # deploy_as_application_configuration_update: { + # s3_content_location_update: { # required + # bucket_arn_update: "BucketARN", # required + # base_path_update: "BasePath", + # }, + # }, + # custom_artifacts_configuration_update: [ + # { + # artifact_type: "UDF", # required, accepts UDF, DEPENDENCY_JAR + # s3_content_location: { + # bucket_arn: "BucketARN", # required + # file_key: "FileKey", # required + # object_version: "ObjectVersion", + # }, + # maven_reference: { + # group_id: "MavenGroupId", # required + # artifact_id: "MavenArtifactId", # required + # version: "MavenVersion", # required + # }, + # }, + # ], + # }, # }, # service_execution_role_update: "RoleARN", # run_configuration_update: { # flink_run_configuration: { # allow_non_restored_state: false, @@ -2649,11 +2786,11 @@ # @example Response structure # # resp.application_detail.application_arn #=> String # resp.application_detail.application_description #=> String # resp.application_detail.application_name #=> String - # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11" + # resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8", "FLINK-1_11", "ZEPPELIN-FLINK-1_0" # resp.application_detail.service_execution_role #=> String # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING", "MAINTENANCE", "ROLLING_BACK", "ROLLED_BACK" # resp.application_detail.application_version_id #=> Integer # resp.application_detail.create_timestamp #=> Time # resp.application_detail.last_update_timestamp #=> Time @@ -2737,20 +2874,33 @@ # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].vpc_id #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].subnet_ids[0] #=> String # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids #=> Array # resp.application_detail.application_configuration_description.vpc_configuration_descriptions[0].security_group_ids[0] #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.monitoring_configuration_description.log_level #=> String, one of "INFO", "WARN", "ERROR", "DEBUG" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.catalog_configuration_description.glue_data_catalog_configuration_description.database_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.deploy_as_application_configuration_description.s3_content_location_description.base_path #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description #=> Array + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].artifact_type #=> String, one of "UDF", "DEPENDENCY_JAR" + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.bucket_arn #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.file_key #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].s3_content_location_description.object_version #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.group_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.artifact_id #=> String + # resp.application_detail.application_configuration_description.zeppelin_application_configuration_description.custom_artifacts_configuration_description[0].maven_reference_description.version #=> String # resp.application_detail.cloud_watch_logging_option_descriptions #=> Array # resp.application_detail.cloud_watch_logging_option_descriptions[0].cloud_watch_logging_option_id #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].log_stream_arn #=> String # resp.application_detail.cloud_watch_logging_option_descriptions[0].role_arn #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_start_time #=> String # resp.application_detail.application_maintenance_configuration_description.application_maintenance_window_end_time #=> String # resp.application_detail.application_version_updated_from #=> Integer # resp.application_detail.application_version_rolled_back_from #=> Integer # resp.application_detail.conditional_token #=> String # resp.application_detail.application_version_rolled_back_to #=> Integer + # resp.application_detail.application_mode #=> String, one of "STREAMING", "INTERACTIVE" # # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/UpdateApplication AWS API Documentation # # @overload update_application(params = {}) # @param [Hash] params ({}) @@ -2836,10 +2986,10 @@ operation: config.api.operation(operation_name), client: self, params: params, config: config) context[:gem_name] = 'aws-sdk-kinesisanalyticsv2' - context[:gem_version] = '1.29.0' + context[:gem_version] = '1.30.0' Seahorse::Client::Request.new(handlers, context) end # @api private # @deprecated