{-# LANGUAGE DisambiguateRecordFields #-} {-# LANGUAGE OverloadedStrings #-} {-# LANGUAGE StrictData #-} {-# LANGUAGE NoImplicitPrelude #-} {-# OPTIONS_GHC -fno-warn-unused-matches #-} -- Derived from AWS service descriptions, licensed under Apache 2.0. -- | -- Module : Amazonka.KinesisAnalyticsV2.Types -- Copyright : (c) 2013-2023 Brendan Hay -- License : Mozilla Public License, v. 2.0. -- Maintainer : Brendan Hay -- Stability : auto-generated -- Portability : non-portable (GHC extensions) module Amazonka.KinesisAnalyticsV2.Types ( -- * Service Configuration defaultService, -- * Errors _CodeValidationException, _ConcurrentModificationException, _InvalidApplicationConfigurationException, _InvalidArgumentException, _InvalidRequestException, _LimitExceededException, _ResourceInUseException, _ResourceNotFoundException, _ResourceProvisionedThroughputExceededException, _ServiceUnavailableException, _TooManyTagsException, _UnableToDetectSchemaException, _UnsupportedOperationException, -- * ApplicationMode ApplicationMode (..), -- * ApplicationRestoreType ApplicationRestoreType (..), -- * ApplicationStatus ApplicationStatus (..), -- * ArtifactType ArtifactType (..), -- * CodeContentType CodeContentType (..), -- * ConfigurationType ConfigurationType (..), -- * InputStartingPosition InputStartingPosition (..), -- * LogLevel LogLevel (..), -- * MetricsLevel MetricsLevel (..), -- * RecordFormatType RecordFormatType (..), -- * RuntimeEnvironment RuntimeEnvironment (..), -- * SnapshotStatus SnapshotStatus (..), -- * UrlType UrlType (..), -- * ApplicationCodeConfiguration ApplicationCodeConfiguration (..), newApplicationCodeConfiguration, applicationCodeConfiguration_codeContent, applicationCodeConfiguration_codeContentType, -- * ApplicationCodeConfigurationDescription ApplicationCodeConfigurationDescription (..), newApplicationCodeConfigurationDescription, applicationCodeConfigurationDescription_codeContentDescription, applicationCodeConfigurationDescription_codeContentType, -- * ApplicationCodeConfigurationUpdate ApplicationCodeConfigurationUpdate (..), newApplicationCodeConfigurationUpdate, applicationCodeConfigurationUpdate_codeContentTypeUpdate, applicationCodeConfigurationUpdate_codeContentUpdate, -- * ApplicationConfiguration ApplicationConfiguration (..), newApplicationConfiguration, applicationConfiguration_applicationCodeConfiguration, applicationConfiguration_applicationSnapshotConfiguration, applicationConfiguration_environmentProperties, applicationConfiguration_flinkApplicationConfiguration, applicationConfiguration_sqlApplicationConfiguration, applicationConfiguration_vpcConfigurations, applicationConfiguration_zeppelinApplicationConfiguration, -- * ApplicationConfigurationDescription ApplicationConfigurationDescription (..), newApplicationConfigurationDescription, applicationConfigurationDescription_applicationCodeConfigurationDescription, applicationConfigurationDescription_applicationSnapshotConfigurationDescription, applicationConfigurationDescription_environmentPropertyDescriptions, applicationConfigurationDescription_flinkApplicationConfigurationDescription, applicationConfigurationDescription_runConfigurationDescription, applicationConfigurationDescription_sqlApplicationConfigurationDescription, applicationConfigurationDescription_vpcConfigurationDescriptions, applicationConfigurationDescription_zeppelinApplicationConfigurationDescription, -- * ApplicationConfigurationUpdate ApplicationConfigurationUpdate (..), newApplicationConfigurationUpdate, applicationConfigurationUpdate_applicationCodeConfigurationUpdate, applicationConfigurationUpdate_applicationSnapshotConfigurationUpdate, applicationConfigurationUpdate_environmentPropertyUpdates, applicationConfigurationUpdate_flinkApplicationConfigurationUpdate, applicationConfigurationUpdate_sqlApplicationConfigurationUpdate, applicationConfigurationUpdate_vpcConfigurationUpdates, applicationConfigurationUpdate_zeppelinApplicationConfigurationUpdate, -- * ApplicationDetail ApplicationDetail (..), newApplicationDetail, applicationDetail_applicationConfigurationDescription, applicationDetail_applicationDescription, applicationDetail_applicationMaintenanceConfigurationDescription, applicationDetail_applicationMode, applicationDetail_applicationVersionRolledBackFrom, applicationDetail_applicationVersionRolledBackTo, applicationDetail_applicationVersionUpdatedFrom, applicationDetail_cloudWatchLoggingOptionDescriptions, applicationDetail_conditionalToken, applicationDetail_createTimestamp, applicationDetail_lastUpdateTimestamp, applicationDetail_serviceExecutionRole, applicationDetail_applicationARN, applicationDetail_applicationName, applicationDetail_runtimeEnvironment, applicationDetail_applicationStatus, applicationDetail_applicationVersionId, -- * ApplicationMaintenanceConfigurationDescription ApplicationMaintenanceConfigurationDescription (..), newApplicationMaintenanceConfigurationDescription, applicationMaintenanceConfigurationDescription_applicationMaintenanceWindowStartTime, applicationMaintenanceConfigurationDescription_applicationMaintenanceWindowEndTime, -- * ApplicationMaintenanceConfigurationUpdate ApplicationMaintenanceConfigurationUpdate (..), newApplicationMaintenanceConfigurationUpdate, applicationMaintenanceConfigurationUpdate_applicationMaintenanceWindowStartTimeUpdate, -- * ApplicationRestoreConfiguration ApplicationRestoreConfiguration (..), newApplicationRestoreConfiguration, applicationRestoreConfiguration_snapshotName, applicationRestoreConfiguration_applicationRestoreType, -- * ApplicationSnapshotConfiguration ApplicationSnapshotConfiguration (..), newApplicationSnapshotConfiguration, applicationSnapshotConfiguration_snapshotsEnabled, -- * ApplicationSnapshotConfigurationDescription ApplicationSnapshotConfigurationDescription (..), newApplicationSnapshotConfigurationDescription, applicationSnapshotConfigurationDescription_snapshotsEnabled, -- * ApplicationSnapshotConfigurationUpdate ApplicationSnapshotConfigurationUpdate (..), newApplicationSnapshotConfigurationUpdate, applicationSnapshotConfigurationUpdate_snapshotsEnabledUpdate, -- * ApplicationSummary ApplicationSummary (..), newApplicationSummary, applicationSummary_applicationMode, applicationSummary_applicationName, applicationSummary_applicationARN, applicationSummary_applicationStatus, applicationSummary_applicationVersionId, applicationSummary_runtimeEnvironment, -- * ApplicationVersionSummary ApplicationVersionSummary (..), newApplicationVersionSummary, applicationVersionSummary_applicationVersionId, applicationVersionSummary_applicationStatus, -- * CSVMappingParameters CSVMappingParameters (..), newCSVMappingParameters, cSVMappingParameters_recordRowDelimiter, cSVMappingParameters_recordColumnDelimiter, -- * CatalogConfiguration CatalogConfiguration (..), newCatalogConfiguration, catalogConfiguration_glueDataCatalogConfiguration, -- * CatalogConfigurationDescription CatalogConfigurationDescription (..), newCatalogConfigurationDescription, catalogConfigurationDescription_glueDataCatalogConfigurationDescription, -- * CatalogConfigurationUpdate CatalogConfigurationUpdate (..), newCatalogConfigurationUpdate, catalogConfigurationUpdate_glueDataCatalogConfigurationUpdate, -- * CheckpointConfiguration CheckpointConfiguration (..), newCheckpointConfiguration, checkpointConfiguration_checkpointInterval, checkpointConfiguration_checkpointingEnabled, checkpointConfiguration_minPauseBetweenCheckpoints, checkpointConfiguration_configurationType, -- * CheckpointConfigurationDescription CheckpointConfigurationDescription (..), newCheckpointConfigurationDescription, checkpointConfigurationDescription_checkpointInterval, checkpointConfigurationDescription_checkpointingEnabled, checkpointConfigurationDescription_configurationType, checkpointConfigurationDescription_minPauseBetweenCheckpoints, -- * CheckpointConfigurationUpdate CheckpointConfigurationUpdate (..), newCheckpointConfigurationUpdate, checkpointConfigurationUpdate_checkpointIntervalUpdate, checkpointConfigurationUpdate_checkpointingEnabledUpdate, checkpointConfigurationUpdate_configurationTypeUpdate, checkpointConfigurationUpdate_minPauseBetweenCheckpointsUpdate, -- * CloudWatchLoggingOption CloudWatchLoggingOption (..), newCloudWatchLoggingOption, cloudWatchLoggingOption_logStreamARN, -- * CloudWatchLoggingOptionDescription CloudWatchLoggingOptionDescription (..), newCloudWatchLoggingOptionDescription, cloudWatchLoggingOptionDescription_cloudWatchLoggingOptionId, cloudWatchLoggingOptionDescription_roleARN, cloudWatchLoggingOptionDescription_logStreamARN, -- * CloudWatchLoggingOptionUpdate CloudWatchLoggingOptionUpdate (..), newCloudWatchLoggingOptionUpdate, cloudWatchLoggingOptionUpdate_logStreamARNUpdate, cloudWatchLoggingOptionUpdate_cloudWatchLoggingOptionId, -- * CodeContent CodeContent (..), newCodeContent, codeContent_s3ContentLocation, codeContent_textContent, codeContent_zipFileContent, -- * CodeContentDescription CodeContentDescription (..), newCodeContentDescription, codeContentDescription_codeMD5, codeContentDescription_codeSize, codeContentDescription_s3ApplicationCodeLocationDescription, codeContentDescription_textContent, -- * CodeContentUpdate CodeContentUpdate (..), newCodeContentUpdate, codeContentUpdate_s3ContentLocationUpdate, codeContentUpdate_textContentUpdate, codeContentUpdate_zipFileContentUpdate, -- * CustomArtifactConfiguration CustomArtifactConfiguration (..), newCustomArtifactConfiguration, customArtifactConfiguration_mavenReference, customArtifactConfiguration_s3ContentLocation, customArtifactConfiguration_artifactType, -- * CustomArtifactConfigurationDescription CustomArtifactConfigurationDescription (..), newCustomArtifactConfigurationDescription, customArtifactConfigurationDescription_artifactType, customArtifactConfigurationDescription_mavenReferenceDescription, customArtifactConfigurationDescription_s3ContentLocationDescription, -- * DeployAsApplicationConfiguration DeployAsApplicationConfiguration (..), newDeployAsApplicationConfiguration, deployAsApplicationConfiguration_s3ContentLocation, -- * DeployAsApplicationConfigurationDescription DeployAsApplicationConfigurationDescription (..), newDeployAsApplicationConfigurationDescription, deployAsApplicationConfigurationDescription_s3ContentLocationDescription, -- * DeployAsApplicationConfigurationUpdate DeployAsApplicationConfigurationUpdate (..), newDeployAsApplicationConfigurationUpdate, deployAsApplicationConfigurationUpdate_s3ContentLocationUpdate, -- * DestinationSchema DestinationSchema (..), newDestinationSchema, destinationSchema_recordFormatType, -- * EnvironmentProperties EnvironmentProperties (..), newEnvironmentProperties, environmentProperties_propertyGroups, -- * EnvironmentPropertyDescriptions EnvironmentPropertyDescriptions (..), newEnvironmentPropertyDescriptions, environmentPropertyDescriptions_propertyGroupDescriptions, -- * EnvironmentPropertyUpdates EnvironmentPropertyUpdates (..), newEnvironmentPropertyUpdates, environmentPropertyUpdates_propertyGroups, -- * FlinkApplicationConfiguration FlinkApplicationConfiguration (..), newFlinkApplicationConfiguration, flinkApplicationConfiguration_checkpointConfiguration, flinkApplicationConfiguration_monitoringConfiguration, flinkApplicationConfiguration_parallelismConfiguration, -- * FlinkApplicationConfigurationDescription FlinkApplicationConfigurationDescription (..), newFlinkApplicationConfigurationDescription, flinkApplicationConfigurationDescription_checkpointConfigurationDescription, flinkApplicationConfigurationDescription_jobPlanDescription, flinkApplicationConfigurationDescription_monitoringConfigurationDescription, flinkApplicationConfigurationDescription_parallelismConfigurationDescription, -- * FlinkApplicationConfigurationUpdate FlinkApplicationConfigurationUpdate (..), newFlinkApplicationConfigurationUpdate, flinkApplicationConfigurationUpdate_checkpointConfigurationUpdate, flinkApplicationConfigurationUpdate_monitoringConfigurationUpdate, flinkApplicationConfigurationUpdate_parallelismConfigurationUpdate, -- * FlinkRunConfiguration FlinkRunConfiguration (..), newFlinkRunConfiguration, flinkRunConfiguration_allowNonRestoredState, -- * GlueDataCatalogConfiguration GlueDataCatalogConfiguration (..), newGlueDataCatalogConfiguration, glueDataCatalogConfiguration_databaseARN, -- * GlueDataCatalogConfigurationDescription GlueDataCatalogConfigurationDescription (..), newGlueDataCatalogConfigurationDescription, glueDataCatalogConfigurationDescription_databaseARN, -- * GlueDataCatalogConfigurationUpdate GlueDataCatalogConfigurationUpdate (..), newGlueDataCatalogConfigurationUpdate, glueDataCatalogConfigurationUpdate_databaseARNUpdate, -- * Input Input (..), newInput, input_inputParallelism, input_inputProcessingConfiguration, input_kinesisFirehoseInput, input_kinesisStreamsInput, input_namePrefix, input_inputSchema, -- * InputDescription InputDescription (..), newInputDescription, inputDescription_inAppStreamNames, inputDescription_inputId, inputDescription_inputParallelism, inputDescription_inputProcessingConfigurationDescription, inputDescription_inputSchema, inputDescription_inputStartingPositionConfiguration, inputDescription_kinesisFirehoseInputDescription, inputDescription_kinesisStreamsInputDescription, inputDescription_namePrefix, -- * InputLambdaProcessor InputLambdaProcessor (..), newInputLambdaProcessor, inputLambdaProcessor_resourceARN, -- * InputLambdaProcessorDescription InputLambdaProcessorDescription (..), newInputLambdaProcessorDescription, inputLambdaProcessorDescription_roleARN, inputLambdaProcessorDescription_resourceARN, -- * InputLambdaProcessorUpdate InputLambdaProcessorUpdate (..), newInputLambdaProcessorUpdate, inputLambdaProcessorUpdate_resourceARNUpdate, -- * InputParallelism InputParallelism (..), newInputParallelism, inputParallelism_count, -- * InputParallelismUpdate InputParallelismUpdate (..), newInputParallelismUpdate, inputParallelismUpdate_countUpdate, -- * InputProcessingConfiguration InputProcessingConfiguration (..), newInputProcessingConfiguration, inputProcessingConfiguration_inputLambdaProcessor, -- * InputProcessingConfigurationDescription InputProcessingConfigurationDescription (..), newInputProcessingConfigurationDescription, inputProcessingConfigurationDescription_inputLambdaProcessorDescription, -- * InputProcessingConfigurationUpdate InputProcessingConfigurationUpdate (..), newInputProcessingConfigurationUpdate, inputProcessingConfigurationUpdate_inputLambdaProcessorUpdate, -- * InputSchemaUpdate InputSchemaUpdate (..), newInputSchemaUpdate, inputSchemaUpdate_recordColumnUpdates, inputSchemaUpdate_recordEncodingUpdate, inputSchemaUpdate_recordFormatUpdate, -- * InputStartingPositionConfiguration InputStartingPositionConfiguration (..), newInputStartingPositionConfiguration, inputStartingPositionConfiguration_inputStartingPosition, -- * InputUpdate InputUpdate (..), newInputUpdate, inputUpdate_inputParallelismUpdate, inputUpdate_inputProcessingConfigurationUpdate, inputUpdate_inputSchemaUpdate, inputUpdate_kinesisFirehoseInputUpdate, inputUpdate_kinesisStreamsInputUpdate, inputUpdate_namePrefixUpdate, inputUpdate_inputId, -- * JSONMappingParameters JSONMappingParameters (..), newJSONMappingParameters, jSONMappingParameters_recordRowPath, -- * KinesisFirehoseInput KinesisFirehoseInput (..), newKinesisFirehoseInput, kinesisFirehoseInput_resourceARN, -- * KinesisFirehoseInputDescription KinesisFirehoseInputDescription (..), newKinesisFirehoseInputDescription, kinesisFirehoseInputDescription_roleARN, kinesisFirehoseInputDescription_resourceARN, -- * KinesisFirehoseInputUpdate KinesisFirehoseInputUpdate (..), newKinesisFirehoseInputUpdate, kinesisFirehoseInputUpdate_resourceARNUpdate, -- * KinesisFirehoseOutput KinesisFirehoseOutput (..), newKinesisFirehoseOutput, kinesisFirehoseOutput_resourceARN, -- * KinesisFirehoseOutputDescription KinesisFirehoseOutputDescription (..), newKinesisFirehoseOutputDescription, kinesisFirehoseOutputDescription_roleARN, kinesisFirehoseOutputDescription_resourceARN, -- * KinesisFirehoseOutputUpdate KinesisFirehoseOutputUpdate (..), newKinesisFirehoseOutputUpdate, kinesisFirehoseOutputUpdate_resourceARNUpdate, -- * KinesisStreamsInput KinesisStreamsInput (..), newKinesisStreamsInput, kinesisStreamsInput_resourceARN, -- * KinesisStreamsInputDescription KinesisStreamsInputDescription (..), newKinesisStreamsInputDescription, kinesisStreamsInputDescription_roleARN, kinesisStreamsInputDescription_resourceARN, -- * KinesisStreamsInputUpdate KinesisStreamsInputUpdate (..), newKinesisStreamsInputUpdate, kinesisStreamsInputUpdate_resourceARNUpdate, -- * KinesisStreamsOutput KinesisStreamsOutput (..), newKinesisStreamsOutput, kinesisStreamsOutput_resourceARN, -- * KinesisStreamsOutputDescription KinesisStreamsOutputDescription (..), newKinesisStreamsOutputDescription, kinesisStreamsOutputDescription_roleARN, kinesisStreamsOutputDescription_resourceARN, -- * KinesisStreamsOutputUpdate KinesisStreamsOutputUpdate (..), newKinesisStreamsOutputUpdate, kinesisStreamsOutputUpdate_resourceARNUpdate, -- * LambdaOutput LambdaOutput (..), newLambdaOutput, lambdaOutput_resourceARN, -- * LambdaOutputDescription LambdaOutputDescription (..), newLambdaOutputDescription, lambdaOutputDescription_roleARN, lambdaOutputDescription_resourceARN, -- * LambdaOutputUpdate LambdaOutputUpdate (..), newLambdaOutputUpdate, lambdaOutputUpdate_resourceARNUpdate, -- * MappingParameters MappingParameters (..), newMappingParameters, mappingParameters_cSVMappingParameters, mappingParameters_jSONMappingParameters, -- * MavenReference MavenReference (..), newMavenReference, mavenReference_groupId, mavenReference_artifactId, mavenReference_version, -- * MonitoringConfiguration MonitoringConfiguration (..), newMonitoringConfiguration, monitoringConfiguration_logLevel, monitoringConfiguration_metricsLevel, monitoringConfiguration_configurationType, -- * MonitoringConfigurationDescription MonitoringConfigurationDescription (..), newMonitoringConfigurationDescription, monitoringConfigurationDescription_configurationType, monitoringConfigurationDescription_logLevel, monitoringConfigurationDescription_metricsLevel, -- * MonitoringConfigurationUpdate MonitoringConfigurationUpdate (..), newMonitoringConfigurationUpdate, monitoringConfigurationUpdate_configurationTypeUpdate, monitoringConfigurationUpdate_logLevelUpdate, monitoringConfigurationUpdate_metricsLevelUpdate, -- * Output Output (..), newOutput, output_kinesisFirehoseOutput, output_kinesisStreamsOutput, output_lambdaOutput, output_name, output_destinationSchema, -- * OutputDescription OutputDescription (..), newOutputDescription, outputDescription_destinationSchema, outputDescription_kinesisFirehoseOutputDescription, outputDescription_kinesisStreamsOutputDescription, outputDescription_lambdaOutputDescription, outputDescription_name, outputDescription_outputId, -- * OutputUpdate OutputUpdate (..), newOutputUpdate, outputUpdate_destinationSchemaUpdate, outputUpdate_kinesisFirehoseOutputUpdate, outputUpdate_kinesisStreamsOutputUpdate, outputUpdate_lambdaOutputUpdate, outputUpdate_nameUpdate, outputUpdate_outputId, -- * ParallelismConfiguration ParallelismConfiguration (..), newParallelismConfiguration, parallelismConfiguration_autoScalingEnabled, parallelismConfiguration_parallelism, parallelismConfiguration_parallelismPerKPU, parallelismConfiguration_configurationType, -- * ParallelismConfigurationDescription ParallelismConfigurationDescription (..), newParallelismConfigurationDescription, parallelismConfigurationDescription_autoScalingEnabled, parallelismConfigurationDescription_configurationType, parallelismConfigurationDescription_currentParallelism, parallelismConfigurationDescription_parallelism, parallelismConfigurationDescription_parallelismPerKPU, -- * ParallelismConfigurationUpdate ParallelismConfigurationUpdate (..), newParallelismConfigurationUpdate, parallelismConfigurationUpdate_autoScalingEnabledUpdate, parallelismConfigurationUpdate_configurationTypeUpdate, parallelismConfigurationUpdate_parallelismPerKPUUpdate, parallelismConfigurationUpdate_parallelismUpdate, -- * PropertyGroup PropertyGroup (..), newPropertyGroup, propertyGroup_propertyGroupId, propertyGroup_propertyMap, -- * RecordColumn RecordColumn (..), newRecordColumn, recordColumn_mapping, recordColumn_name, recordColumn_sqlType, -- * RecordFormat RecordFormat (..), newRecordFormat, recordFormat_mappingParameters, recordFormat_recordFormatType, -- * ReferenceDataSource ReferenceDataSource (..), newReferenceDataSource, referenceDataSource_s3ReferenceDataSource, referenceDataSource_tableName, referenceDataSource_referenceSchema, -- * ReferenceDataSourceDescription ReferenceDataSourceDescription (..), newReferenceDataSourceDescription, referenceDataSourceDescription_referenceSchema, referenceDataSourceDescription_referenceId, referenceDataSourceDescription_tableName, referenceDataSourceDescription_s3ReferenceDataSourceDescription, -- * ReferenceDataSourceUpdate ReferenceDataSourceUpdate (..), newReferenceDataSourceUpdate, referenceDataSourceUpdate_referenceSchemaUpdate, referenceDataSourceUpdate_s3ReferenceDataSourceUpdate, referenceDataSourceUpdate_tableNameUpdate, referenceDataSourceUpdate_referenceId, -- * RunConfiguration RunConfiguration (..), newRunConfiguration, runConfiguration_applicationRestoreConfiguration, runConfiguration_flinkRunConfiguration, runConfiguration_sqlRunConfigurations, -- * RunConfigurationDescription RunConfigurationDescription (..), newRunConfigurationDescription, runConfigurationDescription_applicationRestoreConfigurationDescription, runConfigurationDescription_flinkRunConfigurationDescription, -- * RunConfigurationUpdate RunConfigurationUpdate (..), newRunConfigurationUpdate, runConfigurationUpdate_applicationRestoreConfiguration, runConfigurationUpdate_flinkRunConfiguration, -- * S3ApplicationCodeLocationDescription S3ApplicationCodeLocationDescription (..), newS3ApplicationCodeLocationDescription, s3ApplicationCodeLocationDescription_objectVersion, s3ApplicationCodeLocationDescription_bucketARN, s3ApplicationCodeLocationDescription_fileKey, -- * S3Configuration S3Configuration (..), newS3Configuration, s3Configuration_bucketARN, s3Configuration_fileKey, -- * S3ContentBaseLocation S3ContentBaseLocation (..), newS3ContentBaseLocation, s3ContentBaseLocation_basePath, s3ContentBaseLocation_bucketARN, -- * S3ContentBaseLocationDescription S3ContentBaseLocationDescription (..), newS3ContentBaseLocationDescription, s3ContentBaseLocationDescription_basePath, s3ContentBaseLocationDescription_bucketARN, -- * S3ContentBaseLocationUpdate S3ContentBaseLocationUpdate (..), newS3ContentBaseLocationUpdate, s3ContentBaseLocationUpdate_basePathUpdate, s3ContentBaseLocationUpdate_bucketARNUpdate, -- * S3ContentLocation S3ContentLocation (..), newS3ContentLocation, s3ContentLocation_objectVersion, s3ContentLocation_bucketARN, s3ContentLocation_fileKey, -- * S3ContentLocationUpdate S3ContentLocationUpdate (..), newS3ContentLocationUpdate, s3ContentLocationUpdate_bucketARNUpdate, s3ContentLocationUpdate_fileKeyUpdate, s3ContentLocationUpdate_objectVersionUpdate, -- * S3ReferenceDataSource S3ReferenceDataSource (..), newS3ReferenceDataSource, s3ReferenceDataSource_bucketARN, s3ReferenceDataSource_fileKey, -- * S3ReferenceDataSourceDescription S3ReferenceDataSourceDescription (..), newS3ReferenceDataSourceDescription, s3ReferenceDataSourceDescription_referenceRoleARN, s3ReferenceDataSourceDescription_bucketARN, s3ReferenceDataSourceDescription_fileKey, -- * S3ReferenceDataSourceUpdate S3ReferenceDataSourceUpdate (..), newS3ReferenceDataSourceUpdate, s3ReferenceDataSourceUpdate_bucketARNUpdate, s3ReferenceDataSourceUpdate_fileKeyUpdate, -- * SnapshotDetails SnapshotDetails (..), newSnapshotDetails, snapshotDetails_snapshotCreationTimestamp, snapshotDetails_snapshotName, snapshotDetails_snapshotStatus, snapshotDetails_applicationVersionId, -- * SourceSchema SourceSchema (..), newSourceSchema, sourceSchema_recordEncoding, sourceSchema_recordFormat, sourceSchema_recordColumns, -- * SqlApplicationConfiguration SqlApplicationConfiguration (..), newSqlApplicationConfiguration, sqlApplicationConfiguration_inputs, sqlApplicationConfiguration_outputs, sqlApplicationConfiguration_referenceDataSources, -- * SqlApplicationConfigurationDescription SqlApplicationConfigurationDescription (..), newSqlApplicationConfigurationDescription, sqlApplicationConfigurationDescription_inputDescriptions, sqlApplicationConfigurationDescription_outputDescriptions, sqlApplicationConfigurationDescription_referenceDataSourceDescriptions, -- * SqlApplicationConfigurationUpdate SqlApplicationConfigurationUpdate (..), newSqlApplicationConfigurationUpdate, sqlApplicationConfigurationUpdate_inputUpdates, sqlApplicationConfigurationUpdate_outputUpdates, sqlApplicationConfigurationUpdate_referenceDataSourceUpdates, -- * SqlRunConfiguration SqlRunConfiguration (..), newSqlRunConfiguration, sqlRunConfiguration_inputId, sqlRunConfiguration_inputStartingPositionConfiguration, -- * Tag Tag (..), newTag, tag_value, tag_key, -- * VpcConfiguration VpcConfiguration (..), newVpcConfiguration, vpcConfiguration_subnetIds, vpcConfiguration_securityGroupIds, -- * VpcConfigurationDescription VpcConfigurationDescription (..), newVpcConfigurationDescription, vpcConfigurationDescription_vpcConfigurationId, vpcConfigurationDescription_vpcId, vpcConfigurationDescription_subnetIds, vpcConfigurationDescription_securityGroupIds, -- * VpcConfigurationUpdate VpcConfigurationUpdate (..), newVpcConfigurationUpdate, vpcConfigurationUpdate_securityGroupIdUpdates, vpcConfigurationUpdate_subnetIdUpdates, vpcConfigurationUpdate_vpcConfigurationId, -- * ZeppelinApplicationConfiguration ZeppelinApplicationConfiguration (..), newZeppelinApplicationConfiguration, zeppelinApplicationConfiguration_catalogConfiguration, zeppelinApplicationConfiguration_customArtifactsConfiguration, zeppelinApplicationConfiguration_deployAsApplicationConfiguration, zeppelinApplicationConfiguration_monitoringConfiguration, -- * ZeppelinApplicationConfigurationDescription ZeppelinApplicationConfigurationDescription (..), newZeppelinApplicationConfigurationDescription, zeppelinApplicationConfigurationDescription_catalogConfigurationDescription, zeppelinApplicationConfigurationDescription_customArtifactsConfigurationDescription, zeppelinApplicationConfigurationDescription_deployAsApplicationConfigurationDescription, zeppelinApplicationConfigurationDescription_monitoringConfigurationDescription, -- * ZeppelinApplicationConfigurationUpdate ZeppelinApplicationConfigurationUpdate (..), newZeppelinApplicationConfigurationUpdate, zeppelinApplicationConfigurationUpdate_catalogConfigurationUpdate, zeppelinApplicationConfigurationUpdate_customArtifactsConfigurationUpdate, zeppelinApplicationConfigurationUpdate_deployAsApplicationConfigurationUpdate, zeppelinApplicationConfigurationUpdate_monitoringConfigurationUpdate, -- * ZeppelinMonitoringConfiguration ZeppelinMonitoringConfiguration (..), newZeppelinMonitoringConfiguration, zeppelinMonitoringConfiguration_logLevel, -- * ZeppelinMonitoringConfigurationDescription ZeppelinMonitoringConfigurationDescription (..), newZeppelinMonitoringConfigurationDescription, zeppelinMonitoringConfigurationDescription_logLevel, -- * ZeppelinMonitoringConfigurationUpdate ZeppelinMonitoringConfigurationUpdate (..), newZeppelinMonitoringConfigurationUpdate, zeppelinMonitoringConfigurationUpdate_logLevelUpdate, ) where import qualified Amazonka.Core as Core import qualified Amazonka.Core.Lens.Internal as Lens import Amazonka.KinesisAnalyticsV2.Types.ApplicationCodeConfiguration import Amazonka.KinesisAnalyticsV2.Types.ApplicationCodeConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.ApplicationCodeConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.ApplicationConfiguration import Amazonka.KinesisAnalyticsV2.Types.ApplicationConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.ApplicationConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.ApplicationDetail import Amazonka.KinesisAnalyticsV2.Types.ApplicationMaintenanceConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.ApplicationMaintenanceConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.ApplicationMode import Amazonka.KinesisAnalyticsV2.Types.ApplicationRestoreConfiguration import Amazonka.KinesisAnalyticsV2.Types.ApplicationRestoreType import Amazonka.KinesisAnalyticsV2.Types.ApplicationSnapshotConfiguration import Amazonka.KinesisAnalyticsV2.Types.ApplicationSnapshotConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.ApplicationSnapshotConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.ApplicationStatus import Amazonka.KinesisAnalyticsV2.Types.ApplicationSummary import Amazonka.KinesisAnalyticsV2.Types.ApplicationVersionSummary import Amazonka.KinesisAnalyticsV2.Types.ArtifactType import Amazonka.KinesisAnalyticsV2.Types.CSVMappingParameters import Amazonka.KinesisAnalyticsV2.Types.CatalogConfiguration import Amazonka.KinesisAnalyticsV2.Types.CatalogConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.CatalogConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.CheckpointConfiguration import Amazonka.KinesisAnalyticsV2.Types.CheckpointConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.CheckpointConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.CloudWatchLoggingOption import Amazonka.KinesisAnalyticsV2.Types.CloudWatchLoggingOptionDescription import Amazonka.KinesisAnalyticsV2.Types.CloudWatchLoggingOptionUpdate import Amazonka.KinesisAnalyticsV2.Types.CodeContent import Amazonka.KinesisAnalyticsV2.Types.CodeContentDescription import Amazonka.KinesisAnalyticsV2.Types.CodeContentType import Amazonka.KinesisAnalyticsV2.Types.CodeContentUpdate import Amazonka.KinesisAnalyticsV2.Types.ConfigurationType import Amazonka.KinesisAnalyticsV2.Types.CustomArtifactConfiguration import Amazonka.KinesisAnalyticsV2.Types.CustomArtifactConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.DeployAsApplicationConfiguration import Amazonka.KinesisAnalyticsV2.Types.DeployAsApplicationConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.DeployAsApplicationConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.DestinationSchema import Amazonka.KinesisAnalyticsV2.Types.EnvironmentProperties import Amazonka.KinesisAnalyticsV2.Types.EnvironmentPropertyDescriptions import Amazonka.KinesisAnalyticsV2.Types.EnvironmentPropertyUpdates import Amazonka.KinesisAnalyticsV2.Types.FlinkApplicationConfiguration import Amazonka.KinesisAnalyticsV2.Types.FlinkApplicationConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.FlinkApplicationConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.FlinkRunConfiguration import Amazonka.KinesisAnalyticsV2.Types.GlueDataCatalogConfiguration import Amazonka.KinesisAnalyticsV2.Types.GlueDataCatalogConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.GlueDataCatalogConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.Input import Amazonka.KinesisAnalyticsV2.Types.InputDescription import Amazonka.KinesisAnalyticsV2.Types.InputLambdaProcessor import Amazonka.KinesisAnalyticsV2.Types.InputLambdaProcessorDescription import Amazonka.KinesisAnalyticsV2.Types.InputLambdaProcessorUpdate import Amazonka.KinesisAnalyticsV2.Types.InputParallelism import Amazonka.KinesisAnalyticsV2.Types.InputParallelismUpdate import Amazonka.KinesisAnalyticsV2.Types.InputProcessingConfiguration import Amazonka.KinesisAnalyticsV2.Types.InputProcessingConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.InputProcessingConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.InputSchemaUpdate import Amazonka.KinesisAnalyticsV2.Types.InputStartingPosition import Amazonka.KinesisAnalyticsV2.Types.InputStartingPositionConfiguration import Amazonka.KinesisAnalyticsV2.Types.InputUpdate import Amazonka.KinesisAnalyticsV2.Types.JSONMappingParameters import Amazonka.KinesisAnalyticsV2.Types.KinesisFirehoseInput import Amazonka.KinesisAnalyticsV2.Types.KinesisFirehoseInputDescription import Amazonka.KinesisAnalyticsV2.Types.KinesisFirehoseInputUpdate import Amazonka.KinesisAnalyticsV2.Types.KinesisFirehoseOutput import Amazonka.KinesisAnalyticsV2.Types.KinesisFirehoseOutputDescription import Amazonka.KinesisAnalyticsV2.Types.KinesisFirehoseOutputUpdate import Amazonka.KinesisAnalyticsV2.Types.KinesisStreamsInput import Amazonka.KinesisAnalyticsV2.Types.KinesisStreamsInputDescription import Amazonka.KinesisAnalyticsV2.Types.KinesisStreamsInputUpdate import Amazonka.KinesisAnalyticsV2.Types.KinesisStreamsOutput import Amazonka.KinesisAnalyticsV2.Types.KinesisStreamsOutputDescription import Amazonka.KinesisAnalyticsV2.Types.KinesisStreamsOutputUpdate import Amazonka.KinesisAnalyticsV2.Types.LambdaOutput import Amazonka.KinesisAnalyticsV2.Types.LambdaOutputDescription import Amazonka.KinesisAnalyticsV2.Types.LambdaOutputUpdate import Amazonka.KinesisAnalyticsV2.Types.LogLevel import Amazonka.KinesisAnalyticsV2.Types.MappingParameters import Amazonka.KinesisAnalyticsV2.Types.MavenReference import Amazonka.KinesisAnalyticsV2.Types.MetricsLevel import Amazonka.KinesisAnalyticsV2.Types.MonitoringConfiguration import Amazonka.KinesisAnalyticsV2.Types.MonitoringConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.MonitoringConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.Output import Amazonka.KinesisAnalyticsV2.Types.OutputDescription import Amazonka.KinesisAnalyticsV2.Types.OutputUpdate import Amazonka.KinesisAnalyticsV2.Types.ParallelismConfiguration import Amazonka.KinesisAnalyticsV2.Types.ParallelismConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.ParallelismConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.PropertyGroup import Amazonka.KinesisAnalyticsV2.Types.RecordColumn import Amazonka.KinesisAnalyticsV2.Types.RecordFormat import Amazonka.KinesisAnalyticsV2.Types.RecordFormatType import Amazonka.KinesisAnalyticsV2.Types.ReferenceDataSource import Amazonka.KinesisAnalyticsV2.Types.ReferenceDataSourceDescription import Amazonka.KinesisAnalyticsV2.Types.ReferenceDataSourceUpdate import Amazonka.KinesisAnalyticsV2.Types.RunConfiguration import Amazonka.KinesisAnalyticsV2.Types.RunConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.RunConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.RuntimeEnvironment import Amazonka.KinesisAnalyticsV2.Types.S3ApplicationCodeLocationDescription import Amazonka.KinesisAnalyticsV2.Types.S3Configuration import Amazonka.KinesisAnalyticsV2.Types.S3ContentBaseLocation import Amazonka.KinesisAnalyticsV2.Types.S3ContentBaseLocationDescription import Amazonka.KinesisAnalyticsV2.Types.S3ContentBaseLocationUpdate import Amazonka.KinesisAnalyticsV2.Types.S3ContentLocation import Amazonka.KinesisAnalyticsV2.Types.S3ContentLocationUpdate import Amazonka.KinesisAnalyticsV2.Types.S3ReferenceDataSource import Amazonka.KinesisAnalyticsV2.Types.S3ReferenceDataSourceDescription import Amazonka.KinesisAnalyticsV2.Types.S3ReferenceDataSourceUpdate import Amazonka.KinesisAnalyticsV2.Types.SnapshotDetails import Amazonka.KinesisAnalyticsV2.Types.SnapshotStatus import Amazonka.KinesisAnalyticsV2.Types.SourceSchema import Amazonka.KinesisAnalyticsV2.Types.SqlApplicationConfiguration import Amazonka.KinesisAnalyticsV2.Types.SqlApplicationConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.SqlApplicationConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.SqlRunConfiguration import Amazonka.KinesisAnalyticsV2.Types.Tag import Amazonka.KinesisAnalyticsV2.Types.UrlType import Amazonka.KinesisAnalyticsV2.Types.VpcConfiguration import Amazonka.KinesisAnalyticsV2.Types.VpcConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.VpcConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.ZeppelinApplicationConfiguration import Amazonka.KinesisAnalyticsV2.Types.ZeppelinApplicationConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.ZeppelinApplicationConfigurationUpdate import Amazonka.KinesisAnalyticsV2.Types.ZeppelinMonitoringConfiguration import Amazonka.KinesisAnalyticsV2.Types.ZeppelinMonitoringConfigurationDescription import Amazonka.KinesisAnalyticsV2.Types.ZeppelinMonitoringConfigurationUpdate import qualified Amazonka.Prelude as Prelude import qualified Amazonka.Sign.V4 as Sign -- | API version @2018-05-23@ of the Amazon Kinesis Analytics SDK configuration. defaultService :: Core.Service defaultService = Core.Service { Core.abbrev = "KinesisAnalyticsV2", Core.signer = Sign.v4, Core.endpointPrefix = "kinesisanalytics", Core.signingName = "kinesisanalytics", Core.version = "2018-05-23", Core.s3AddressingStyle = Core.S3AddressingStyleAuto, Core.endpoint = Core.defaultEndpoint defaultService, Core.timeout = Prelude.Just 70, Core.check = Core.statusSuccess, Core.error = Core.parseJSONError "KinesisAnalyticsV2", Core.retry = retry } where retry = Core.Exponential { Core.base = 5.0e-2, Core.growth = 2, Core.attempts = 5, Core.check = check } check e | Lens.has (Core.hasStatus 502) e = Prelude.Just "bad_gateway" | Lens.has (Core.hasStatus 504) e = Prelude.Just "gateway_timeout" | Lens.has (Core.hasStatus 500) e = Prelude.Just "general_server_error" | Lens.has (Core.hasStatus 509) e = Prelude.Just "limit_exceeded" | Lens.has ( Core.hasCode "RequestThrottledException" Prelude.. Core.hasStatus 400 ) e = Prelude.Just "request_throttled_exception" | Lens.has (Core.hasStatus 503) e = Prelude.Just "service_unavailable" | Lens.has ( Core.hasCode "ThrottledException" Prelude.. Core.hasStatus 400 ) e = Prelude.Just "throttled_exception" | Lens.has ( Core.hasCode "Throttling" Prelude.. Core.hasStatus 400 ) e = Prelude.Just "throttling" | Lens.has ( Core.hasCode "ThrottlingException" Prelude.. Core.hasStatus 400 ) e = Prelude.Just "throttling_exception" | Lens.has ( Core.hasCode "ProvisionedThroughputExceededException" Prelude.. Core.hasStatus 400 ) e = Prelude.Just "throughput_exceeded" | Lens.has (Core.hasStatus 429) e = Prelude.Just "too_many_requests" | Prelude.otherwise = Prelude.Nothing -- | The user-provided application code (query) is not valid. This can be a -- simple syntax error. _CodeValidationException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _CodeValidationException = Core._MatchServiceError defaultService "CodeValidationException" -- | Exception thrown as a result of concurrent modifications to an -- application. This error can be the result of attempting to modify an -- application without using the current application ID. _ConcurrentModificationException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _ConcurrentModificationException = Core._MatchServiceError defaultService "ConcurrentModificationException" -- | The user-provided application configuration is not valid. _InvalidApplicationConfigurationException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _InvalidApplicationConfigurationException = Core._MatchServiceError defaultService "InvalidApplicationConfigurationException" -- | The specified input parameter value is not valid. _InvalidArgumentException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _InvalidArgumentException = Core._MatchServiceError defaultService "InvalidArgumentException" -- | The request JSON is not valid for the operation. _InvalidRequestException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _InvalidRequestException = Core._MatchServiceError defaultService "InvalidRequestException" -- | The number of allowed resources has been exceeded. _LimitExceededException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _LimitExceededException = Core._MatchServiceError defaultService "LimitExceededException" -- | The application is not available for this operation. _ResourceInUseException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _ResourceInUseException = Core._MatchServiceError defaultService "ResourceInUseException" -- | Specified application can\'t be found. _ResourceNotFoundException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _ResourceNotFoundException = Core._MatchServiceError defaultService "ResourceNotFoundException" -- | Discovery failed to get a record from the streaming source because of -- the Kinesis Streams @ProvisionedThroughputExceededException@. For more -- information, see -- -- in the Amazon Kinesis Streams API Reference. _ResourceProvisionedThroughputExceededException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _ResourceProvisionedThroughputExceededException = Core._MatchServiceError defaultService "ResourceProvisionedThroughputExceededException" -- | The service cannot complete the request. _ServiceUnavailableException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _ServiceUnavailableException = Core._MatchServiceError defaultService "ServiceUnavailableException" -- | Application created with too many tags, or too many tags added to an -- application. Note that the maximum number of application tags includes -- system tags. The maximum number of user-defined application tags is 50. _TooManyTagsException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _TooManyTagsException = Core._MatchServiceError defaultService "TooManyTagsException" -- | The data format is not valid. Kinesis Data Analytics cannot detect the -- schema for the given streaming source. _UnableToDetectSchemaException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _UnableToDetectSchemaException = Core._MatchServiceError defaultService "UnableToDetectSchemaException" -- | The request was rejected because a specified parameter is not supported -- or a specified resource is not valid for this operation. _UnsupportedOperationException :: (Core.AsError a) => Lens.Fold a Core.ServiceError _UnsupportedOperationException = Core._MatchServiceError defaultService "UnsupportedOperationException"