R/kinesisanalyticsv2_interfaces.R

In paws.analytics: 'Amazon Web Services' Analytics Services

# This file is generated by make.paws. Please do not edit here.
#' @importFrom paws.common populate
#' @include kinesisanalyticsv2_service.R
NULL

.kinesisanalyticsv2$add_application_cloud_watch_logging_option_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), CloudWatchLoggingOption = structure(list(LogStreamARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ConditionalToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_cloud_watch_logging_option_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), CloudWatchLoggingOptionDescriptions = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_input_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), Input = structure(list(NamePrefix = structure(logical(0), tags = list(type = "string")), InputProcessingConfiguration = structure(list(InputLambdaProcessor = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_input_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), InputDescriptions = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), NamePrefix = structure(logical(0), tags = list(type = "string")), InAppStreamNames = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), InputProcessingConfigurationDescription = structure(list(InputLambdaProcessorDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_input_processing_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), InputId = structure(logical(0), tags = list(type = "string")), InputProcessingConfiguration = structure(list(InputLambdaProcessor = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_input_processing_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), InputId = structure(logical(0), tags = list(type = "string")), InputProcessingConfigurationDescription = structure(list(InputLambdaProcessorDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_output_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), Output = structure(list(Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_output_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), OutputDescriptions = structure(list(structure(list(OutputId = structure(logical(0), tags = list(type = "string")), Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_reference_data_source_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), ReferenceDataSource = structure(list(TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSource = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_reference_data_source_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), ReferenceDataSourceDescriptions = structure(list(structure(list(ReferenceId = structure(logical(0), tags = list(type = "string")), TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSourceDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ReferenceRoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_vpc_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), VpcConfiguration = structure(list(SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure")), ConditionalToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$add_application_vpc_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), VpcConfigurationDescription = structure(list(VpcConfigurationId = structure(logical(0), tags = list(type = "string")), VpcId = structure(logical(0), tags = list(type = "string")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$create_application_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), ApplicationDescription = structure(logical(0), tags = list(type = "string")), RuntimeEnvironment = structure(logical(0), tags = list(type = "string")), ServiceExecutionRole = structure(logical(0), tags = list(type = "string")), ApplicationConfiguration = structure(list(SqlApplicationConfiguration = structure(list(Inputs = structure(list(structure(list(NamePrefix = structure(logical(0), tags = list(type = "string")), InputProcessingConfiguration = structure(list(InputLambdaProcessor = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), Outputs = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutput = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ReferenceDataSources = structure(list(structure(list(TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSource = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), FlinkApplicationConfiguration = structure(list(CheckpointConfiguration = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), CheckpointingEnabled = structure(logical(0), tags = list(type = "boolean")), CheckpointInterval = structure(logical(0), tags = list(type = "long")), MinPauseBetweenCheckpoints = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), MonitoringConfiguration = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), MetricsLevel = structure(logical(0), tags = list(type = "string")), LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ParallelismConfiguration = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), Parallelism = structure(logical(0), tags = list(type = "integer")), ParallelismPerKPU = structure(logical(0), tags = list(type = "integer")), AutoScalingEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))), tags = list(type = "structure")), EnvironmentProperties = structure(list(PropertyGroups = structure(list(structure(list(PropertyGroupId = structure(logical(0), tags = list(type = "string")), PropertyMap = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationCodeConfiguration = structure(list(CodeContent = structure(list(TextContent = structure(logical(0), tags = list(type = "string")), ZipFileContent = structure(logical(0), tags = list(type = "blob")), S3ContentLocation = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CodeContentType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ApplicationSnapshotConfiguration = structure(list(SnapshotsEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), VpcConfigurations = structure(list(structure(list(SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), ZeppelinApplicationConfiguration = structure(list(MonitoringConfiguration = structure(list(LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CatalogConfiguration = structure(list(GlueDataCatalogConfiguration = structure(list(DatabaseARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), DeployAsApplicationConfiguration = structure(list(S3ContentLocation = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), BasePath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CustomArtifactsConfiguration = structure(list(structure(list(ArtifactType = structure(logical(0), tags = list(type = "string")), S3ContentLocation = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), MavenReference = structure(list(GroupId = structure(logical(0), tags = list(type = "string")), ArtifactId = structure(logical(0), tags = list(type = "string")), Version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure")), CloudWatchLoggingOptions = structure(list(structure(list(LogStreamARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), Tags = structure(list(structure(list(Key = structure(logical(0), tags = list(type = "string")), Value = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), ApplicationMode = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$create_application_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationDetail = structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationDescription = structure(logical(0), tags = list(type = "string")), ApplicationName = structure(logical(0), tags = list(type = "string")), RuntimeEnvironment = structure(logical(0), tags = list(type = "string")), ServiceExecutionRole = structure(logical(0), tags = list(type = "string")), ApplicationStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), CreateTimestamp = structure(logical(0), tags = list(type = "timestamp")), LastUpdateTimestamp = structure(logical(0), tags = list(type = "timestamp")), ApplicationConfigurationDescription = structure(list(SqlApplicationConfigurationDescription = structure(list(InputDescriptions = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), NamePrefix = structure(logical(0), tags = list(type = "string")), InAppStreamNames = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), InputProcessingConfigurationDescription = structure(list(InputLambdaProcessorDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), OutputDescriptions = structure(list(structure(list(OutputId = structure(logical(0), tags = list(type = "string")), Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ReferenceDataSourceDescriptions = structure(list(structure(list(ReferenceId = structure(logical(0), tags = list(type = "string")), TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSourceDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ReferenceRoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationCodeConfigurationDescription = structure(list(CodeContentType = structure(logical(0), tags = list(type = "string")), CodeContentDescription = structure(list(TextContent = structure(logical(0), tags = list(type = "string")), CodeMD5 = structure(logical(0), tags = list(type = "string")), CodeSize = structure(logical(0), tags = list(type = "long")), S3ApplicationCodeLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RunConfigurationDescription = structure(list(ApplicationRestoreConfigurationDescription = structure(list(ApplicationRestoreType = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), FlinkRunConfigurationDescription = structure(list(AllowNonRestoredState = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))), tags = list(type = "structure")), FlinkApplicationConfigurationDescription = structure(list(CheckpointConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), CheckpointingEnabled = structure(logical(0), tags = list(type = "boolean")), CheckpointInterval = structure(logical(0), tags = list(type = "long")), MinPauseBetweenCheckpoints = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), MonitoringConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), MetricsLevel = structure(logical(0), tags = list(type = "string")), LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ParallelismConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), Parallelism = structure(logical(0), tags = list(type = "integer")), ParallelismPerKPU = structure(logical(0), tags = list(type = "integer")), CurrentParallelism = structure(logical(0), tags = list(type = "integer")), AutoScalingEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), JobPlanDescription = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), EnvironmentPropertyDescriptions = structure(list(PropertyGroupDescriptions = structure(list(structure(list(PropertyGroupId = structure(logical(0), tags = list(type = "string")), PropertyMap = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationSnapshotConfigurationDescription = structure(list(SnapshotsEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), VpcConfigurationDescriptions = structure(list(structure(list(VpcConfigurationId = structure(logical(0), tags = list(type = "string")), VpcId = structure(logical(0), tags = list(type = "string")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), ZeppelinApplicationConfigurationDescription = structure(list(MonitoringConfigurationDescription = structure(list(LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CatalogConfigurationDescription = structure(list(GlueDataCatalogConfigurationDescription = structure(list(DatabaseARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), DeployAsApplicationConfigurationDescription = structure(list(S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), BasePath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CustomArtifactsConfigurationDescription = structure(list(structure(list(ArtifactType = structure(logical(0), tags = list(type = "string")), S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), MavenReferenceDescription = structure(list(GroupId = structure(logical(0), tags = list(type = "string")), ArtifactId = structure(logical(0), tags = list(type = "string")), Version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure")), CloudWatchLoggingOptionDescriptions = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), ApplicationMaintenanceConfigurationDescription = structure(list(ApplicationMaintenanceWindowStartTime = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceWindowEndTime = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ApplicationVersionUpdatedFrom = structure(logical(0), tags = list(type = "long")), ApplicationVersionRolledBackFrom = structure(logical(0), tags = list(type = "long")), ConditionalToken = structure(logical(0), tags = list(type = "string")), ApplicationVersionRolledBackTo = structure(logical(0), tags = list(type = "long")), ApplicationMode = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$create_application_presigned_url_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), UrlType = structure(logical(0), tags = list(type = "string")), SessionExpirationDurationInSeconds = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$create_application_presigned_url_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(AuthorizedUrl = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$create_application_snapshot_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$create_application_snapshot_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CreateTimestamp = structure(logical(0), tags = list(type = "timestamp"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_cloud_watch_logging_option_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), ConditionalToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_cloud_watch_logging_option_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), CloudWatchLoggingOptionDescriptions = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_input_processing_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), InputId = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_input_processing_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_output_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), OutputId = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_output_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_reference_data_source_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), ReferenceId = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_reference_data_source_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_snapshot_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string")), SnapshotCreationTimestamp = structure(logical(0), tags = list(type = "timestamp"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_snapshot_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_vpc_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), VpcConfigurationId = structure(logical(0), tags = list(type = "string")), ConditionalToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$delete_application_vpc_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$describe_application_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), IncludeAdditionalDetails = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$describe_application_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationDetail = structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationDescription = structure(logical(0), tags = list(type = "string")), ApplicationName = structure(logical(0), tags = list(type = "string")), RuntimeEnvironment = structure(logical(0), tags = list(type = "string")), ServiceExecutionRole = structure(logical(0), tags = list(type = "string")), ApplicationStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), CreateTimestamp = structure(logical(0), tags = list(type = "timestamp")), LastUpdateTimestamp = structure(logical(0), tags = list(type = "timestamp")), ApplicationConfigurationDescription = structure(list(SqlApplicationConfigurationDescription = structure(list(InputDescriptions = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), NamePrefix = structure(logical(0), tags = list(type = "string")), InAppStreamNames = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), InputProcessingConfigurationDescription = structure(list(InputLambdaProcessorDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), OutputDescriptions = structure(list(structure(list(OutputId = structure(logical(0), tags = list(type = "string")), Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ReferenceDataSourceDescriptions = structure(list(structure(list(ReferenceId = structure(logical(0), tags = list(type = "string")), TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSourceDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ReferenceRoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationCodeConfigurationDescription = structure(list(CodeContentType = structure(logical(0), tags = list(type = "string")), CodeContentDescription = structure(list(TextContent = structure(logical(0), tags = list(type = "string")), CodeMD5 = structure(logical(0), tags = list(type = "string")), CodeSize = structure(logical(0), tags = list(type = "long")), S3ApplicationCodeLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RunConfigurationDescription = structure(list(ApplicationRestoreConfigurationDescription = structure(list(ApplicationRestoreType = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), FlinkRunConfigurationDescription = structure(list(AllowNonRestoredState = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))), tags = list(type = "structure")), FlinkApplicationConfigurationDescription = structure(list(CheckpointConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), CheckpointingEnabled = structure(logical(0), tags = list(type = "boolean")), CheckpointInterval = structure(logical(0), tags = list(type = "long")), MinPauseBetweenCheckpoints = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), MonitoringConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), MetricsLevel = structure(logical(0), tags = list(type = "string")), LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ParallelismConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), Parallelism = structure(logical(0), tags = list(type = "integer")), ParallelismPerKPU = structure(logical(0), tags = list(type = "integer")), CurrentParallelism = structure(logical(0), tags = list(type = "integer")), AutoScalingEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), JobPlanDescription = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), EnvironmentPropertyDescriptions = structure(list(PropertyGroupDescriptions = structure(list(structure(list(PropertyGroupId = structure(logical(0), tags = list(type = "string")), PropertyMap = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationSnapshotConfigurationDescription = structure(list(SnapshotsEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), VpcConfigurationDescriptions = structure(list(structure(list(VpcConfigurationId = structure(logical(0), tags = list(type = "string")), VpcId = structure(logical(0), tags = list(type = "string")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), ZeppelinApplicationConfigurationDescription = structure(list(MonitoringConfigurationDescription = structure(list(LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CatalogConfigurationDescription = structure(list(GlueDataCatalogConfigurationDescription = structure(list(DatabaseARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), DeployAsApplicationConfigurationDescription = structure(list(S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), BasePath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CustomArtifactsConfigurationDescription = structure(list(structure(list(ArtifactType = structure(logical(0), tags = list(type = "string")), S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), MavenReferenceDescription = structure(list(GroupId = structure(logical(0), tags = list(type = "string")), ArtifactId = structure(logical(0), tags = list(type = "string")), Version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure")), CloudWatchLoggingOptionDescriptions = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), ApplicationMaintenanceConfigurationDescription = structure(list(ApplicationMaintenanceWindowStartTime = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceWindowEndTime = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ApplicationVersionUpdatedFrom = structure(logical(0), tags = list(type = "long")), ApplicationVersionRolledBackFrom = structure(logical(0), tags = list(type = "long")), ConditionalToken = structure(logical(0), tags = list(type = "string")), ApplicationVersionRolledBackTo = structure(logical(0), tags = list(type = "long")), ApplicationMode = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$describe_application_snapshot_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$describe_application_snapshot_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(SnapshotDetails = structure(list(SnapshotName = structure(logical(0), tags = list(type = "string")), SnapshotStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), SnapshotCreationTimestamp = structure(logical(0), tags = list(type = "timestamp"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$describe_application_version_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$describe_application_version_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationVersionDetail = structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationDescription = structure(logical(0), tags = list(type = "string")), ApplicationName = structure(logical(0), tags = list(type = "string")), RuntimeEnvironment = structure(logical(0), tags = list(type = "string")), ServiceExecutionRole = structure(logical(0), tags = list(type = "string")), ApplicationStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), CreateTimestamp = structure(logical(0), tags = list(type = "timestamp")), LastUpdateTimestamp = structure(logical(0), tags = list(type = "timestamp")), ApplicationConfigurationDescription = structure(list(SqlApplicationConfigurationDescription = structure(list(InputDescriptions = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), NamePrefix = structure(logical(0), tags = list(type = "string")), InAppStreamNames = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), InputProcessingConfigurationDescription = structure(list(InputLambdaProcessorDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), OutputDescriptions = structure(list(structure(list(OutputId = structure(logical(0), tags = list(type = "string")), Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ReferenceDataSourceDescriptions = structure(list(structure(list(ReferenceId = structure(logical(0), tags = list(type = "string")), TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSourceDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ReferenceRoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationCodeConfigurationDescription = structure(list(CodeContentType = structure(logical(0), tags = list(type = "string")), CodeContentDescription = structure(list(TextContent = structure(logical(0), tags = list(type = "string")), CodeMD5 = structure(logical(0), tags = list(type = "string")), CodeSize = structure(logical(0), tags = list(type = "long")), S3ApplicationCodeLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RunConfigurationDescription = structure(list(ApplicationRestoreConfigurationDescription = structure(list(ApplicationRestoreType = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), FlinkRunConfigurationDescription = structure(list(AllowNonRestoredState = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))), tags = list(type = "structure")), FlinkApplicationConfigurationDescription = structure(list(CheckpointConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), CheckpointingEnabled = structure(logical(0), tags = list(type = "boolean")), CheckpointInterval = structure(logical(0), tags = list(type = "long")), MinPauseBetweenCheckpoints = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), MonitoringConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), MetricsLevel = structure(logical(0), tags = list(type = "string")), LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ParallelismConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), Parallelism = structure(logical(0), tags = list(type = "integer")), ParallelismPerKPU = structure(logical(0), tags = list(type = "integer")), CurrentParallelism = structure(logical(0), tags = list(type = "integer")), AutoScalingEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), JobPlanDescription = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), EnvironmentPropertyDescriptions = structure(list(PropertyGroupDescriptions = structure(list(structure(list(PropertyGroupId = structure(logical(0), tags = list(type = "string")), PropertyMap = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationSnapshotConfigurationDescription = structure(list(SnapshotsEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), VpcConfigurationDescriptions = structure(list(structure(list(VpcConfigurationId = structure(logical(0), tags = list(type = "string")), VpcId = structure(logical(0), tags = list(type = "string")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), ZeppelinApplicationConfigurationDescription = structure(list(MonitoringConfigurationDescription = structure(list(LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CatalogConfigurationDescription = structure(list(GlueDataCatalogConfigurationDescription = structure(list(DatabaseARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), DeployAsApplicationConfigurationDescription = structure(list(S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), BasePath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CustomArtifactsConfigurationDescription = structure(list(structure(list(ArtifactType = structure(logical(0), tags = list(type = "string")), S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), MavenReferenceDescription = structure(list(GroupId = structure(logical(0), tags = list(type = "string")), ArtifactId = structure(logical(0), tags = list(type = "string")), Version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure")), CloudWatchLoggingOptionDescriptions = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), ApplicationMaintenanceConfigurationDescription = structure(list(ApplicationMaintenanceWindowStartTime = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceWindowEndTime = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ApplicationVersionUpdatedFrom = structure(logical(0), tags = list(type = "long")), ApplicationVersionRolledBackFrom = structure(logical(0), tags = list(type = "long")), ConditionalToken = structure(logical(0), tags = list(type = "string")), ApplicationVersionRolledBackTo = structure(logical(0), tags = list(type = "long")), ApplicationMode = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$discover_input_schema_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), ServiceExecutionRole = structure(logical(0), tags = list(type = "string")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), S3Configuration = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputProcessingConfiguration = structure(list(InputLambdaProcessor = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$discover_input_schema_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ParsedInputRecords = structure(list(structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "list")), ProcessedInputRecords = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), RawInputRecords = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_application_snapshots_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), Limit = structure(logical(0), tags = list(type = "integer")), NextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_application_snapshots_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(SnapshotSummaries = structure(list(structure(list(SnapshotName = structure(logical(0), tags = list(type = "string")), SnapshotStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), SnapshotCreationTimestamp = structure(logical(0), tags = list(type = "timestamp"))), tags = list(type = "structure"))), tags = list(type = "list")), NextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_application_versions_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), Limit = structure(logical(0), tags = list(type = "integer")), NextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_application_versions_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationVersionSummaries = structure(list(structure(list(ApplicationVersionId = structure(logical(0), tags = list(type = "long")), ApplicationStatus = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), NextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_applications_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Limit = structure(logical(0), tags = list(type = "integer")), NextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_applications_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationSummaries = structure(list(structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), RuntimeEnvironment = structure(logical(0), tags = list(type = "string")), ApplicationMode = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), NextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_tags_for_resource_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ResourceARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$list_tags_for_resource_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Tags = structure(list(structure(list(Key = structure(logical(0), tags = list(type = "string")), Value = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$rollback_application_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$rollback_application_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationDetail = structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationDescription = structure(logical(0), tags = list(type = "string")), ApplicationName = structure(logical(0), tags = list(type = "string")), RuntimeEnvironment = structure(logical(0), tags = list(type = "string")), ServiceExecutionRole = structure(logical(0), tags = list(type = "string")), ApplicationStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), CreateTimestamp = structure(logical(0), tags = list(type = "timestamp")), LastUpdateTimestamp = structure(logical(0), tags = list(type = "timestamp")), ApplicationConfigurationDescription = structure(list(SqlApplicationConfigurationDescription = structure(list(InputDescriptions = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), NamePrefix = structure(logical(0), tags = list(type = "string")), InAppStreamNames = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), InputProcessingConfigurationDescription = structure(list(InputLambdaProcessorDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), OutputDescriptions = structure(list(structure(list(OutputId = structure(logical(0), tags = list(type = "string")), Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ReferenceDataSourceDescriptions = structure(list(structure(list(ReferenceId = structure(logical(0), tags = list(type = "string")), TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSourceDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ReferenceRoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationCodeConfigurationDescription = structure(list(CodeContentType = structure(logical(0), tags = list(type = "string")), CodeContentDescription = structure(list(TextContent = structure(logical(0), tags = list(type = "string")), CodeMD5 = structure(logical(0), tags = list(type = "string")), CodeSize = structure(logical(0), tags = list(type = "long")), S3ApplicationCodeLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RunConfigurationDescription = structure(list(ApplicationRestoreConfigurationDescription = structure(list(ApplicationRestoreType = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), FlinkRunConfigurationDescription = structure(list(AllowNonRestoredState = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))), tags = list(type = "structure")), FlinkApplicationConfigurationDescription = structure(list(CheckpointConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), CheckpointingEnabled = structure(logical(0), tags = list(type = "boolean")), CheckpointInterval = structure(logical(0), tags = list(type = "long")), MinPauseBetweenCheckpoints = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), MonitoringConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), MetricsLevel = structure(logical(0), tags = list(type = "string")), LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ParallelismConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), Parallelism = structure(logical(0), tags = list(type = "integer")), ParallelismPerKPU = structure(logical(0), tags = list(type = "integer")), CurrentParallelism = structure(logical(0), tags = list(type = "integer")), AutoScalingEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), JobPlanDescription = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), EnvironmentPropertyDescriptions = structure(list(PropertyGroupDescriptions = structure(list(structure(list(PropertyGroupId = structure(logical(0), tags = list(type = "string")), PropertyMap = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationSnapshotConfigurationDescription = structure(list(SnapshotsEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), VpcConfigurationDescriptions = structure(list(structure(list(VpcConfigurationId = structure(logical(0), tags = list(type = "string")), VpcId = structure(logical(0), tags = list(type = "string")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), ZeppelinApplicationConfigurationDescription = structure(list(MonitoringConfigurationDescription = structure(list(LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CatalogConfigurationDescription = structure(list(GlueDataCatalogConfigurationDescription = structure(list(DatabaseARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), DeployAsApplicationConfigurationDescription = structure(list(S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), BasePath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CustomArtifactsConfigurationDescription = structure(list(structure(list(ArtifactType = structure(logical(0), tags = list(type = "string")), S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), MavenReferenceDescription = structure(list(GroupId = structure(logical(0), tags = list(type = "string")), ArtifactId = structure(logical(0), tags = list(type = "string")), Version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure")), CloudWatchLoggingOptionDescriptions = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), ApplicationMaintenanceConfigurationDescription = structure(list(ApplicationMaintenanceWindowStartTime = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceWindowEndTime = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ApplicationVersionUpdatedFrom = structure(logical(0), tags = list(type = "long")), ApplicationVersionRolledBackFrom = structure(logical(0), tags = list(type = "long")), ConditionalToken = structure(logical(0), tags = list(type = "string")), ApplicationVersionRolledBackTo = structure(logical(0), tags = list(type = "long")), ApplicationMode = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$start_application_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), RunConfiguration = structure(list(FlinkRunConfiguration = structure(list(AllowNonRestoredState = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), SqlRunConfigurations = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ApplicationRestoreConfiguration = structure(list(ApplicationRestoreType = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$start_application_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$stop_application_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), Force = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$stop_application_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$tag_resource_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), Tags = structure(list(structure(list(Key = structure(logical(0), tags = list(type = "string")), Value = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$tag_resource_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$untag_resource_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), TagKeys = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$untag_resource_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$update_application_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), CurrentApplicationVersionId = structure(logical(0), tags = list(type = "long")), ApplicationConfigurationUpdate = structure(list(SqlApplicationConfigurationUpdate = structure(list(InputUpdates = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), NamePrefixUpdate = structure(logical(0), tags = list(type = "string")), InputProcessingConfigurationUpdate = structure(list(InputLambdaProcessorUpdate = structure(list(ResourceARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInputUpdate = structure(list(ResourceARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInputUpdate = structure(list(ResourceARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputSchemaUpdate = structure(list(RecordFormatUpdate = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncodingUpdate = structure(logical(0), tags = list(type = "string")), RecordColumnUpdates = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), InputParallelismUpdate = structure(list(CountUpdate = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), OutputUpdates = structure(list(structure(list(OutputId = structure(logical(0), tags = list(type = "string")), NameUpdate = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutputUpdate = structure(list(ResourceARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutputUpdate = structure(list(ResourceARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutputUpdate = structure(list(ResourceARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchemaUpdate = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ReferenceDataSourceUpdates = structure(list(structure(list(ReferenceId = structure(logical(0), tags = list(type = "string")), TableNameUpdate = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSourceUpdate = structure(list(BucketARNUpdate = structure(logical(0), tags = list(type = "string")), FileKeyUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchemaUpdate = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationCodeConfigurationUpdate = structure(list(CodeContentTypeUpdate = structure(logical(0), tags = list(type = "string")), CodeContentUpdate = structure(list(TextContentUpdate = structure(logical(0), tags = list(type = "string")), ZipFileContentUpdate = structure(logical(0), tags = list(type = "blob")), S3ContentLocationUpdate = structure(list(BucketARNUpdate = structure(logical(0), tags = list(type = "string")), FileKeyUpdate = structure(logical(0), tags = list(type = "string")), ObjectVersionUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), FlinkApplicationConfigurationUpdate = structure(list(CheckpointConfigurationUpdate = structure(list(ConfigurationTypeUpdate = structure(logical(0), tags = list(type = "string")), CheckpointingEnabledUpdate = structure(logical(0), tags = list(type = "boolean")), CheckpointIntervalUpdate = structure(logical(0), tags = list(type = "long")), MinPauseBetweenCheckpointsUpdate = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), MonitoringConfigurationUpdate = structure(list(ConfigurationTypeUpdate = structure(logical(0), tags = list(type = "string")), MetricsLevelUpdate = structure(logical(0), tags = list(type = "string")), LogLevelUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ParallelismConfigurationUpdate = structure(list(ConfigurationTypeUpdate = structure(logical(0), tags = list(type = "string")), ParallelismUpdate = structure(logical(0), tags = list(type = "integer")), ParallelismPerKPUUpdate = structure(logical(0), tags = list(type = "integer")), AutoScalingEnabledUpdate = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))), tags = list(type = "structure")), EnvironmentPropertyUpdates = structure(list(PropertyGroups = structure(list(structure(list(PropertyGroupId = structure(logical(0), tags = list(type = "string")), PropertyMap = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationSnapshotConfigurationUpdate = structure(list(SnapshotsEnabledUpdate = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), VpcConfigurationUpdates = structure(list(structure(list(VpcConfigurationId = structure(logical(0), tags = list(type = "string")), SubnetIdUpdates = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIdUpdates = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), ZeppelinApplicationConfigurationUpdate = structure(list(MonitoringConfigurationUpdate = structure(list(LogLevelUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CatalogConfigurationUpdate = structure(list(GlueDataCatalogConfigurationUpdate = structure(list(DatabaseARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), DeployAsApplicationConfigurationUpdate = structure(list(S3ContentLocationUpdate = structure(list(BucketARNUpdate = structure(logical(0), tags = list(type = "string")), BasePathUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CustomArtifactsConfigurationUpdate = structure(list(structure(list(ArtifactType = structure(logical(0), tags = list(type = "string")), S3ContentLocation = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), MavenReference = structure(list(GroupId = structure(logical(0), tags = list(type = "string")), ArtifactId = structure(logical(0), tags = list(type = "string")), Version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure")), ServiceExecutionRoleUpdate = structure(logical(0), tags = list(type = "string")), RunConfigurationUpdate = structure(list(FlinkRunConfiguration = structure(list(AllowNonRestoredState = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), ApplicationRestoreConfiguration = structure(list(ApplicationRestoreType = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CloudWatchLoggingOptionUpdates = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARNUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), ConditionalToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$update_application_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationDetail = structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationDescription = structure(logical(0), tags = list(type = "string")), ApplicationName = structure(logical(0), tags = list(type = "string")), RuntimeEnvironment = structure(logical(0), tags = list(type = "string")), ServiceExecutionRole = structure(logical(0), tags = list(type = "string")), ApplicationStatus = structure(logical(0), tags = list(type = "string")), ApplicationVersionId = structure(logical(0), tags = list(type = "long")), CreateTimestamp = structure(logical(0), tags = list(type = "timestamp")), LastUpdateTimestamp = structure(logical(0), tags = list(type = "timestamp")), ApplicationConfigurationDescription = structure(list(SqlApplicationConfigurationDescription = structure(list(InputDescriptions = structure(list(structure(list(InputId = structure(logical(0), tags = list(type = "string")), NamePrefix = structure(logical(0), tags = list(type = "string")), InAppStreamNames = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), InputProcessingConfigurationDescription = structure(list(InputLambdaProcessorDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), KinesisStreamsInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseInputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), InputSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), InputParallelism = structure(list(Count = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), InputStartingPositionConfiguration = structure(list(InputStartingPosition = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), OutputDescriptions = structure(list(structure(list(OutputId = structure(logical(0), tags = list(type = "string")), Name = structure(logical(0), tags = list(type = "string")), KinesisStreamsOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), KinesisFirehoseOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), LambdaOutputDescription = structure(list(ResourceARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), DestinationSchema = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), ReferenceDataSourceDescriptions = structure(list(structure(list(ReferenceId = structure(logical(0), tags = list(type = "string")), TableName = structure(logical(0), tags = list(type = "string")), S3ReferenceDataSourceDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ReferenceRoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ReferenceSchema = structure(list(RecordFormat = structure(list(RecordFormatType = structure(logical(0), tags = list(type = "string")), MappingParameters = structure(list(JSONMappingParameters = structure(list(RecordRowPath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CSVMappingParameters = structure(list(RecordRowDelimiter = structure(logical(0), tags = list(type = "string")), RecordColumnDelimiter = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RecordEncoding = structure(logical(0), tags = list(type = "string")), RecordColumns = structure(list(structure(list(Name = structure(logical(0), tags = list(type = "string")), Mapping = structure(logical(0), tags = list(type = "string")), SqlType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationCodeConfigurationDescription = structure(list(CodeContentType = structure(logical(0), tags = list(type = "string")), CodeContentDescription = structure(list(TextContent = structure(logical(0), tags = list(type = "string")), CodeMD5 = structure(logical(0), tags = list(type = "string")), CodeSize = structure(logical(0), tags = list(type = "long")), S3ApplicationCodeLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), RunConfigurationDescription = structure(list(ApplicationRestoreConfigurationDescription = structure(list(ApplicationRestoreType = structure(logical(0), tags = list(type = "string")), SnapshotName = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), FlinkRunConfigurationDescription = structure(list(AllowNonRestoredState = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))), tags = list(type = "structure")), FlinkApplicationConfigurationDescription = structure(list(CheckpointConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), CheckpointingEnabled = structure(logical(0), tags = list(type = "boolean")), CheckpointInterval = structure(logical(0), tags = list(type = "long")), MinPauseBetweenCheckpoints = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), MonitoringConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), MetricsLevel = structure(logical(0), tags = list(type = "string")), LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ParallelismConfigurationDescription = structure(list(ConfigurationType = structure(logical(0), tags = list(type = "string")), Parallelism = structure(logical(0), tags = list(type = "integer")), ParallelismPerKPU = structure(logical(0), tags = list(type = "integer")), CurrentParallelism = structure(logical(0), tags = list(type = "integer")), AutoScalingEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), JobPlanDescription = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), EnvironmentPropertyDescriptions = structure(list(PropertyGroupDescriptions = structure(list(structure(list(PropertyGroupId = structure(logical(0), tags = list(type = "string")), PropertyMap = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), ApplicationSnapshotConfigurationDescription = structure(list(SnapshotsEnabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), VpcConfigurationDescriptions = structure(list(structure(list(VpcConfigurationId = structure(logical(0), tags = list(type = "string")), VpcId = structure(logical(0), tags = list(type = "string")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), ZeppelinApplicationConfigurationDescription = structure(list(MonitoringConfigurationDescription = structure(list(LogLevel = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), CatalogConfigurationDescription = structure(list(GlueDataCatalogConfigurationDescription = structure(list(DatabaseARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), DeployAsApplicationConfigurationDescription = structure(list(S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), BasePath = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), CustomArtifactsConfigurationDescription = structure(list(structure(list(ArtifactType = structure(logical(0), tags = list(type = "string")), S3ContentLocationDescription = structure(list(BucketARN = structure(logical(0), tags = list(type = "string")), FileKey = structure(logical(0), tags = list(type = "string")), ObjectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), MavenReferenceDescription = structure(list(GroupId = structure(logical(0), tags = list(type = "string")), ArtifactId = structure(logical(0), tags = list(type = "string")), Version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure")), CloudWatchLoggingOptionDescriptions = structure(list(structure(list(CloudWatchLoggingOptionId = structure(logical(0), tags = list(type = "string")), LogStreamARN = structure(logical(0), tags = list(type = "string")), RoleARN = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), ApplicationMaintenanceConfigurationDescription = structure(list(ApplicationMaintenanceWindowStartTime = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceWindowEndTime = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), ApplicationVersionUpdatedFrom = structure(logical(0), tags = list(type = "long")), ApplicationVersionRolledBackFrom = structure(logical(0), tags = list(type = "long")), ConditionalToken = structure(logical(0), tags = list(type = "string")), ApplicationVersionRolledBackTo = structure(logical(0), tags = list(type = "long")), ApplicationMode = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$update_application_maintenance_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationName = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceConfigurationUpdate = structure(list(ApplicationMaintenanceWindowStartTimeUpdate = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kinesisanalyticsv2$update_application_maintenance_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ApplicationARN = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceConfigurationDescription = structure(list(ApplicationMaintenanceWindowStartTime = structure(logical(0), tags = list(type = "string")), ApplicationMaintenanceWindowEndTime = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}