{-# 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
-- <http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html GetRecords>
-- 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"