| Copyright | (c) 2013-2023 Brendan Hay |
|---|---|
| License | Mozilla Public License, v. 2.0. |
| Maintainer | Brendan Hay |
| Stability | auto-generated |
| Portability | non-portable (GHC extensions) |
| Safe Haskell | Safe-Inferred |
| Language | Haskell2010 |
Amazonka.KinesisAnalytics.Types
Contents
- Service Configuration
- Errors
- ApplicationStatus
- InputStartingPosition
- RecordFormatType
- ApplicationDetail
- ApplicationSummary
- ApplicationUpdate
- CSVMappingParameters
- CloudWatchLoggingOption
- CloudWatchLoggingOptionDescription
- CloudWatchLoggingOptionUpdate
- DestinationSchema
- Input
- InputConfiguration
- InputDescription
- InputLambdaProcessor
- InputLambdaProcessorDescription
- InputLambdaProcessorUpdate
- InputParallelism
- InputParallelismUpdate
- InputProcessingConfiguration
- InputProcessingConfigurationDescription
- InputProcessingConfigurationUpdate
- InputSchemaUpdate
- InputStartingPositionConfiguration
- InputUpdate
- JSONMappingParameters
- KinesisFirehoseInput
- KinesisFirehoseInputDescription
- KinesisFirehoseInputUpdate
- KinesisFirehoseOutput
- KinesisFirehoseOutputDescription
- KinesisFirehoseOutputUpdate
- KinesisStreamsInput
- KinesisStreamsInputDescription
- KinesisStreamsInputUpdate
- KinesisStreamsOutput
- KinesisStreamsOutputDescription
- KinesisStreamsOutputUpdate
- LambdaOutput
- LambdaOutputDescription
- LambdaOutputUpdate
- MappingParameters
- Output
- OutputDescription
- OutputUpdate
- RecordColumn
- RecordFormat
- ReferenceDataSource
- ReferenceDataSourceDescription
- ReferenceDataSourceUpdate
- S3Configuration
- S3ReferenceDataSource
- S3ReferenceDataSourceDescription
- S3ReferenceDataSourceUpdate
- SourceSchema
- Tag
Description
Synopsis
- defaultService :: Service
- _CodeValidationException :: AsError a => Fold a ServiceError
- _ConcurrentModificationException :: AsError a => Fold a ServiceError
- _InvalidApplicationConfigurationException :: AsError a => Fold a ServiceError
- _InvalidArgumentException :: AsError a => Fold a ServiceError
- _LimitExceededException :: AsError a => Fold a ServiceError
- _ResourceInUseException :: AsError a => Fold a ServiceError
- _ResourceNotFoundException :: AsError a => Fold a ServiceError
- _ResourceProvisionedThroughputExceededException :: AsError a => Fold a ServiceError
- _ServiceUnavailableException :: AsError a => Fold a ServiceError
- _TooManyTagsException :: AsError a => Fold a ServiceError
- _UnableToDetectSchemaException :: AsError a => Fold a ServiceError
- _UnsupportedOperationException :: AsError a => Fold a ServiceError
- newtype ApplicationStatus where
- ApplicationStatus' { }
- pattern ApplicationStatus_DELETING :: ApplicationStatus
- pattern ApplicationStatus_READY :: ApplicationStatus
- pattern ApplicationStatus_RUNNING :: ApplicationStatus
- pattern ApplicationStatus_STARTING :: ApplicationStatus
- pattern ApplicationStatus_STOPPING :: ApplicationStatus
- pattern ApplicationStatus_UPDATING :: ApplicationStatus
- newtype InputStartingPosition where
- newtype RecordFormatType where
- RecordFormatType' { }
- pattern RecordFormatType_CSV :: RecordFormatType
- pattern RecordFormatType_JSON :: RecordFormatType
- data ApplicationDetail = ApplicationDetail' {
- applicationCode :: Maybe Text
- applicationDescription :: Maybe Text
- cloudWatchLoggingOptionDescriptions :: Maybe [CloudWatchLoggingOptionDescription]
- createTimestamp :: Maybe POSIX
- inputDescriptions :: Maybe [InputDescription]
- lastUpdateTimestamp :: Maybe POSIX
- outputDescriptions :: Maybe [OutputDescription]
- referenceDataSourceDescriptions :: Maybe [ReferenceDataSourceDescription]
- applicationName :: Text
- applicationARN :: Text
- applicationStatus :: ApplicationStatus
- applicationVersionId :: Natural
- newApplicationDetail :: Text -> Text -> ApplicationStatus -> Natural -> ApplicationDetail
- applicationDetail_applicationCode :: Lens' ApplicationDetail (Maybe Text)
- applicationDetail_applicationDescription :: Lens' ApplicationDetail (Maybe Text)
- applicationDetail_cloudWatchLoggingOptionDescriptions :: Lens' ApplicationDetail (Maybe [CloudWatchLoggingOptionDescription])
- applicationDetail_createTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)
- applicationDetail_inputDescriptions :: Lens' ApplicationDetail (Maybe [InputDescription])
- applicationDetail_lastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)
- applicationDetail_outputDescriptions :: Lens' ApplicationDetail (Maybe [OutputDescription])
- applicationDetail_referenceDataSourceDescriptions :: Lens' ApplicationDetail (Maybe [ReferenceDataSourceDescription])
- applicationDetail_applicationName :: Lens' ApplicationDetail Text
- applicationDetail_applicationARN :: Lens' ApplicationDetail Text
- applicationDetail_applicationStatus :: Lens' ApplicationDetail ApplicationStatus
- applicationDetail_applicationVersionId :: Lens' ApplicationDetail Natural
- data ApplicationSummary = ApplicationSummary' {}
- newApplicationSummary :: Text -> Text -> ApplicationStatus -> ApplicationSummary
- applicationSummary_applicationName :: Lens' ApplicationSummary Text
- applicationSummary_applicationARN :: Lens' ApplicationSummary Text
- applicationSummary_applicationStatus :: Lens' ApplicationSummary ApplicationStatus
- data ApplicationUpdate = ApplicationUpdate' {}
- newApplicationUpdate :: ApplicationUpdate
- applicationUpdate_applicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text)
- applicationUpdate_cloudWatchLoggingOptionUpdates :: Lens' ApplicationUpdate (Maybe [CloudWatchLoggingOptionUpdate])
- applicationUpdate_inputUpdates :: Lens' ApplicationUpdate (Maybe [InputUpdate])
- applicationUpdate_outputUpdates :: Lens' ApplicationUpdate (Maybe [OutputUpdate])
- applicationUpdate_referenceDataSourceUpdates :: Lens' ApplicationUpdate (Maybe [ReferenceDataSourceUpdate])
- data CSVMappingParameters = CSVMappingParameters' {}
- newCSVMappingParameters :: Text -> Text -> CSVMappingParameters
- cSVMappingParameters_recordRowDelimiter :: Lens' CSVMappingParameters Text
- cSVMappingParameters_recordColumnDelimiter :: Lens' CSVMappingParameters Text
- data CloudWatchLoggingOption = CloudWatchLoggingOption' {
- logStreamARN :: Text
- roleARN :: Text
- newCloudWatchLoggingOption :: Text -> Text -> CloudWatchLoggingOption
- cloudWatchLoggingOption_logStreamARN :: Lens' CloudWatchLoggingOption Text
- cloudWatchLoggingOption_roleARN :: Lens' CloudWatchLoggingOption Text
- data CloudWatchLoggingOptionDescription = CloudWatchLoggingOptionDescription' {}
- newCloudWatchLoggingOptionDescription :: Text -> Text -> CloudWatchLoggingOptionDescription
- cloudWatchLoggingOptionDescription_cloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionDescription (Maybe Text)
- cloudWatchLoggingOptionDescription_logStreamARN :: Lens' CloudWatchLoggingOptionDescription Text
- cloudWatchLoggingOptionDescription_roleARN :: Lens' CloudWatchLoggingOptionDescription Text
- data CloudWatchLoggingOptionUpdate = CloudWatchLoggingOptionUpdate' {}
- newCloudWatchLoggingOptionUpdate :: Text -> CloudWatchLoggingOptionUpdate
- cloudWatchLoggingOptionUpdate_logStreamARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text)
- cloudWatchLoggingOptionUpdate_roleARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text)
- cloudWatchLoggingOptionUpdate_cloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionUpdate Text
- data DestinationSchema = DestinationSchema' {}
- newDestinationSchema :: RecordFormatType -> DestinationSchema
- destinationSchema_recordFormatType :: Lens' DestinationSchema RecordFormatType
- data Input = Input' {}
- newInput :: Text -> SourceSchema -> Input
- input_inputParallelism :: Lens' Input (Maybe InputParallelism)
- input_inputProcessingConfiguration :: Lens' Input (Maybe InputProcessingConfiguration)
- input_kinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput)
- input_kinesisStreamsInput :: Lens' Input (Maybe KinesisStreamsInput)
- input_namePrefix :: Lens' Input Text
- input_inputSchema :: Lens' Input SourceSchema
- data InputConfiguration = InputConfiguration' {}
- newInputConfiguration :: Text -> InputStartingPositionConfiguration -> InputConfiguration
- inputConfiguration_id :: Lens' InputConfiguration Text
- inputConfiguration_inputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration
- data InputDescription = InputDescription' {
- inAppStreamNames :: Maybe [Text]
- inputId :: Maybe Text
- inputParallelism :: Maybe InputParallelism
- inputProcessingConfigurationDescription :: Maybe InputProcessingConfigurationDescription
- inputSchema :: Maybe SourceSchema
- inputStartingPositionConfiguration :: Maybe InputStartingPositionConfiguration
- kinesisFirehoseInputDescription :: Maybe KinesisFirehoseInputDescription
- kinesisStreamsInputDescription :: Maybe KinesisStreamsInputDescription
- namePrefix :: Maybe Text
- newInputDescription :: InputDescription
- inputDescription_inAppStreamNames :: Lens' InputDescription (Maybe [Text])
- inputDescription_inputId :: Lens' InputDescription (Maybe Text)
- inputDescription_inputParallelism :: Lens' InputDescription (Maybe InputParallelism)
- inputDescription_inputProcessingConfigurationDescription :: Lens' InputDescription (Maybe InputProcessingConfigurationDescription)
- inputDescription_inputSchema :: Lens' InputDescription (Maybe SourceSchema)
- inputDescription_inputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration)
- inputDescription_kinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription)
- inputDescription_kinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription)
- inputDescription_namePrefix :: Lens' InputDescription (Maybe Text)
- data InputLambdaProcessor = InputLambdaProcessor' {
- resourceARN :: Text
- roleARN :: Text
- newInputLambdaProcessor :: Text -> Text -> InputLambdaProcessor
- inputLambdaProcessor_resourceARN :: Lens' InputLambdaProcessor Text
- inputLambdaProcessor_roleARN :: Lens' InputLambdaProcessor Text
- data InputLambdaProcessorDescription = InputLambdaProcessorDescription' {}
- newInputLambdaProcessorDescription :: InputLambdaProcessorDescription
- inputLambdaProcessorDescription_resourceARN :: Lens' InputLambdaProcessorDescription (Maybe Text)
- inputLambdaProcessorDescription_roleARN :: Lens' InputLambdaProcessorDescription (Maybe Text)
- data InputLambdaProcessorUpdate = InputLambdaProcessorUpdate' {}
- newInputLambdaProcessorUpdate :: InputLambdaProcessorUpdate
- inputLambdaProcessorUpdate_resourceARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)
- inputLambdaProcessorUpdate_roleARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)
- data InputParallelism = InputParallelism' {}
- newInputParallelism :: InputParallelism
- inputParallelism_count :: Lens' InputParallelism (Maybe Natural)
- data InputParallelismUpdate = InputParallelismUpdate' {}
- newInputParallelismUpdate :: InputParallelismUpdate
- inputParallelismUpdate_countUpdate :: Lens' InputParallelismUpdate (Maybe Natural)
- data InputProcessingConfiguration = InputProcessingConfiguration' {}
- newInputProcessingConfiguration :: InputLambdaProcessor -> InputProcessingConfiguration
- inputProcessingConfiguration_inputLambdaProcessor :: Lens' InputProcessingConfiguration InputLambdaProcessor
- data InputProcessingConfigurationDescription = InputProcessingConfigurationDescription' {}
- newInputProcessingConfigurationDescription :: InputProcessingConfigurationDescription
- inputProcessingConfigurationDescription_inputLambdaProcessorDescription :: Lens' InputProcessingConfigurationDescription (Maybe InputLambdaProcessorDescription)
- data InputProcessingConfigurationUpdate = InputProcessingConfigurationUpdate' {}
- newInputProcessingConfigurationUpdate :: InputLambdaProcessorUpdate -> InputProcessingConfigurationUpdate
- inputProcessingConfigurationUpdate_inputLambdaProcessorUpdate :: Lens' InputProcessingConfigurationUpdate InputLambdaProcessorUpdate
- data InputSchemaUpdate = InputSchemaUpdate' {}
- newInputSchemaUpdate :: InputSchemaUpdate
- inputSchemaUpdate_recordColumnUpdates :: Lens' InputSchemaUpdate (Maybe (NonEmpty RecordColumn))
- inputSchemaUpdate_recordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text)
- inputSchemaUpdate_recordFormatUpdate :: Lens' InputSchemaUpdate (Maybe RecordFormat)
- data InputStartingPositionConfiguration = InputStartingPositionConfiguration' {}
- newInputStartingPositionConfiguration :: InputStartingPositionConfiguration
- inputStartingPositionConfiguration_inputStartingPosition :: Lens' InputStartingPositionConfiguration (Maybe InputStartingPosition)
- data InputUpdate = InputUpdate' {
- inputParallelismUpdate :: Maybe InputParallelismUpdate
- inputProcessingConfigurationUpdate :: Maybe InputProcessingConfigurationUpdate
- inputSchemaUpdate :: Maybe InputSchemaUpdate
- kinesisFirehoseInputUpdate :: Maybe KinesisFirehoseInputUpdate
- kinesisStreamsInputUpdate :: Maybe KinesisStreamsInputUpdate
- namePrefixUpdate :: Maybe Text
- inputId :: Text
- newInputUpdate :: Text -> InputUpdate
- inputUpdate_inputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate)
- inputUpdate_inputProcessingConfigurationUpdate :: Lens' InputUpdate (Maybe InputProcessingConfigurationUpdate)
- inputUpdate_inputSchemaUpdate :: Lens' InputUpdate (Maybe InputSchemaUpdate)
- inputUpdate_kinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate)
- inputUpdate_kinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate)
- inputUpdate_namePrefixUpdate :: Lens' InputUpdate (Maybe Text)
- inputUpdate_inputId :: Lens' InputUpdate Text
- data JSONMappingParameters = JSONMappingParameters' {}
- newJSONMappingParameters :: Text -> JSONMappingParameters
- jSONMappingParameters_recordRowPath :: Lens' JSONMappingParameters Text
- data KinesisFirehoseInput = KinesisFirehoseInput' {
- resourceARN :: Text
- roleARN :: Text
- newKinesisFirehoseInput :: Text -> Text -> KinesisFirehoseInput
- kinesisFirehoseInput_resourceARN :: Lens' KinesisFirehoseInput Text
- kinesisFirehoseInput_roleARN :: Lens' KinesisFirehoseInput Text
- data KinesisFirehoseInputDescription = KinesisFirehoseInputDescription' {}
- newKinesisFirehoseInputDescription :: KinesisFirehoseInputDescription
- kinesisFirehoseInputDescription_resourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)
- kinesisFirehoseInputDescription_roleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)
- data KinesisFirehoseInputUpdate = KinesisFirehoseInputUpdate' {}
- newKinesisFirehoseInputUpdate :: KinesisFirehoseInputUpdate
- kinesisFirehoseInputUpdate_resourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)
- kinesisFirehoseInputUpdate_roleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)
- data KinesisFirehoseOutput = KinesisFirehoseOutput' {
- resourceARN :: Text
- roleARN :: Text
- newKinesisFirehoseOutput :: Text -> Text -> KinesisFirehoseOutput
- kinesisFirehoseOutput_resourceARN :: Lens' KinesisFirehoseOutput Text
- kinesisFirehoseOutput_roleARN :: Lens' KinesisFirehoseOutput Text
- data KinesisFirehoseOutputDescription = KinesisFirehoseOutputDescription' {}
- newKinesisFirehoseOutputDescription :: KinesisFirehoseOutputDescription
- kinesisFirehoseOutputDescription_resourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)
- kinesisFirehoseOutputDescription_roleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)
- data KinesisFirehoseOutputUpdate = KinesisFirehoseOutputUpdate' {}
- newKinesisFirehoseOutputUpdate :: KinesisFirehoseOutputUpdate
- kinesisFirehoseOutputUpdate_resourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)
- kinesisFirehoseOutputUpdate_roleARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)
- data KinesisStreamsInput = KinesisStreamsInput' {
- resourceARN :: Text
- roleARN :: Text
- newKinesisStreamsInput :: Text -> Text -> KinesisStreamsInput
- kinesisStreamsInput_resourceARN :: Lens' KinesisStreamsInput Text
- kinesisStreamsInput_roleARN :: Lens' KinesisStreamsInput Text
- data KinesisStreamsInputDescription = KinesisStreamsInputDescription' {}
- newKinesisStreamsInputDescription :: KinesisStreamsInputDescription
- kinesisStreamsInputDescription_resourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text)
- kinesisStreamsInputDescription_roleARN :: Lens' KinesisStreamsInputDescription (Maybe Text)
- data KinesisStreamsInputUpdate = KinesisStreamsInputUpdate' {}
- newKinesisStreamsInputUpdate :: KinesisStreamsInputUpdate
- kinesisStreamsInputUpdate_resourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)
- kinesisStreamsInputUpdate_roleARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)
- data KinesisStreamsOutput = KinesisStreamsOutput' {
- resourceARN :: Text
- roleARN :: Text
- newKinesisStreamsOutput :: Text -> Text -> KinesisStreamsOutput
- kinesisStreamsOutput_resourceARN :: Lens' KinesisStreamsOutput Text
- kinesisStreamsOutput_roleARN :: Lens' KinesisStreamsOutput Text
- data KinesisStreamsOutputDescription = KinesisStreamsOutputDescription' {}
- newKinesisStreamsOutputDescription :: KinesisStreamsOutputDescription
- kinesisStreamsOutputDescription_resourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)
- kinesisStreamsOutputDescription_roleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)
- data KinesisStreamsOutputUpdate = KinesisStreamsOutputUpdate' {}
- newKinesisStreamsOutputUpdate :: KinesisStreamsOutputUpdate
- kinesisStreamsOutputUpdate_resourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)
- kinesisStreamsOutputUpdate_roleARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)
- data LambdaOutput = LambdaOutput' {
- resourceARN :: Text
- roleARN :: Text
- newLambdaOutput :: Text -> Text -> LambdaOutput
- lambdaOutput_resourceARN :: Lens' LambdaOutput Text
- lambdaOutput_roleARN :: Lens' LambdaOutput Text
- data LambdaOutputDescription = LambdaOutputDescription' {}
- newLambdaOutputDescription :: LambdaOutputDescription
- lambdaOutputDescription_resourceARN :: Lens' LambdaOutputDescription (Maybe Text)
- lambdaOutputDescription_roleARN :: Lens' LambdaOutputDescription (Maybe Text)
- data LambdaOutputUpdate = LambdaOutputUpdate' {}
- newLambdaOutputUpdate :: LambdaOutputUpdate
- lambdaOutputUpdate_resourceARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text)
- lambdaOutputUpdate_roleARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text)
- data MappingParameters = MappingParameters' {}
- newMappingParameters :: MappingParameters
- mappingParameters_cSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters)
- mappingParameters_jSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters)
- data Output = Output' {}
- newOutput :: Text -> DestinationSchema -> Output
- output_kinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput)
- output_kinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput)
- output_lambdaOutput :: Lens' Output (Maybe LambdaOutput)
- output_name :: Lens' Output Text
- output_destinationSchema :: Lens' Output DestinationSchema
- data OutputDescription = OutputDescription' {}
- newOutputDescription :: OutputDescription
- outputDescription_destinationSchema :: Lens' OutputDescription (Maybe DestinationSchema)
- outputDescription_kinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription)
- outputDescription_kinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription)
- outputDescription_lambdaOutputDescription :: Lens' OutputDescription (Maybe LambdaOutputDescription)
- outputDescription_name :: Lens' OutputDescription (Maybe Text)
- outputDescription_outputId :: Lens' OutputDescription (Maybe Text)
- data OutputUpdate = OutputUpdate' {}
- newOutputUpdate :: Text -> OutputUpdate
- outputUpdate_destinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema)
- outputUpdate_kinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate)
- outputUpdate_kinesisStreamsOutputUpdate :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate)
- outputUpdate_lambdaOutputUpdate :: Lens' OutputUpdate (Maybe LambdaOutputUpdate)
- outputUpdate_nameUpdate :: Lens' OutputUpdate (Maybe Text)
- outputUpdate_outputId :: Lens' OutputUpdate Text
- data RecordColumn = RecordColumn' {}
- newRecordColumn :: Text -> Text -> RecordColumn
- recordColumn_mapping :: Lens' RecordColumn (Maybe Text)
- recordColumn_name :: Lens' RecordColumn Text
- recordColumn_sqlType :: Lens' RecordColumn Text
- data RecordFormat = RecordFormat' {}
- newRecordFormat :: RecordFormatType -> RecordFormat
- recordFormat_mappingParameters :: Lens' RecordFormat (Maybe MappingParameters)
- recordFormat_recordFormatType :: Lens' RecordFormat RecordFormatType
- data ReferenceDataSource = ReferenceDataSource' {}
- newReferenceDataSource :: Text -> SourceSchema -> ReferenceDataSource
- referenceDataSource_s3ReferenceDataSource :: Lens' ReferenceDataSource (Maybe S3ReferenceDataSource)
- referenceDataSource_tableName :: Lens' ReferenceDataSource Text
- referenceDataSource_referenceSchema :: Lens' ReferenceDataSource SourceSchema
- data ReferenceDataSourceDescription = ReferenceDataSourceDescription' {}
- newReferenceDataSourceDescription :: Text -> Text -> S3ReferenceDataSourceDescription -> ReferenceDataSourceDescription
- referenceDataSourceDescription_referenceSchema :: Lens' ReferenceDataSourceDescription (Maybe SourceSchema)
- referenceDataSourceDescription_referenceId :: Lens' ReferenceDataSourceDescription Text
- referenceDataSourceDescription_tableName :: Lens' ReferenceDataSourceDescription Text
- referenceDataSourceDescription_s3ReferenceDataSourceDescription :: Lens' ReferenceDataSourceDescription S3ReferenceDataSourceDescription
- data ReferenceDataSourceUpdate = ReferenceDataSourceUpdate' {}
- newReferenceDataSourceUpdate :: Text -> ReferenceDataSourceUpdate
- referenceDataSourceUpdate_referenceSchemaUpdate :: Lens' ReferenceDataSourceUpdate (Maybe SourceSchema)
- referenceDataSourceUpdate_s3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe S3ReferenceDataSourceUpdate)
- referenceDataSourceUpdate_tableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text)
- referenceDataSourceUpdate_referenceId :: Lens' ReferenceDataSourceUpdate Text
- data S3Configuration = S3Configuration' {}
- newS3Configuration :: Text -> Text -> Text -> S3Configuration
- s3Configuration_roleARN :: Lens' S3Configuration Text
- s3Configuration_bucketARN :: Lens' S3Configuration Text
- s3Configuration_fileKey :: Lens' S3Configuration Text
- data S3ReferenceDataSource = S3ReferenceDataSource' {}
- newS3ReferenceDataSource :: Text -> Text -> Text -> S3ReferenceDataSource
- s3ReferenceDataSource_bucketARN :: Lens' S3ReferenceDataSource Text
- s3ReferenceDataSource_fileKey :: Lens' S3ReferenceDataSource Text
- s3ReferenceDataSource_referenceRoleARN :: Lens' S3ReferenceDataSource Text
- data S3ReferenceDataSourceDescription = S3ReferenceDataSourceDescription' {}
- newS3ReferenceDataSourceDescription :: Text -> Text -> Text -> S3ReferenceDataSourceDescription
- s3ReferenceDataSourceDescription_bucketARN :: Lens' S3ReferenceDataSourceDescription Text
- s3ReferenceDataSourceDescription_fileKey :: Lens' S3ReferenceDataSourceDescription Text
- s3ReferenceDataSourceDescription_referenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text
- data S3ReferenceDataSourceUpdate = S3ReferenceDataSourceUpdate' {}
- newS3ReferenceDataSourceUpdate :: S3ReferenceDataSourceUpdate
- s3ReferenceDataSourceUpdate_bucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)
- s3ReferenceDataSourceUpdate_fileKeyUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)
- s3ReferenceDataSourceUpdate_referenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)
- data SourceSchema = SourceSchema' {}
- newSourceSchema :: RecordFormat -> NonEmpty RecordColumn -> SourceSchema
- sourceSchema_recordEncoding :: Lens' SourceSchema (Maybe Text)
- sourceSchema_recordFormat :: Lens' SourceSchema RecordFormat
- sourceSchema_recordColumns :: Lens' SourceSchema (NonEmpty RecordColumn)
- data Tag = Tag' {}
- newTag :: Text -> Tag
- tag_value :: Lens' Tag (Maybe Text)
- tag_key :: Lens' Tag Text
Service Configuration
defaultService :: Service Source #
API version 2015-08-14 of the Amazon Kinesis Analytics SDK configuration.
Errors
_CodeValidationException :: AsError a => Fold a ServiceError Source #
User-provided application code (query) is invalid. This can be a simple syntax error.
_ConcurrentModificationException :: AsError a => Fold a ServiceError Source #
Exception thrown as a result of concurrent modification to an application. For example, two individuals attempting to edit the same application at the same time.
_InvalidApplicationConfigurationException :: AsError a => Fold a ServiceError Source #
User-provided application configuration is not valid.
_InvalidArgumentException :: AsError a => Fold a ServiceError Source #
Specified input parameter value is invalid.
_LimitExceededException :: AsError a => Fold a ServiceError Source #
Exceeded the number of applications allowed.
_ResourceInUseException :: AsError a => Fold a ServiceError Source #
Application is not available for this operation.
_ResourceNotFoundException :: AsError a => Fold a ServiceError Source #
Specified application can't be found.
_ResourceProvisionedThroughputExceededException :: AsError a => Fold a ServiceError Source #
Discovery failed to get a record from the streaming source because of the Amazon Kinesis Streams ProvisionedThroughputExceededException. For more information, see GetRecords in the Amazon Kinesis Streams API Reference.
_ServiceUnavailableException :: AsError a => Fold a ServiceError Source #
The service is unavailable. Back off and retry the operation.
_TooManyTagsException :: AsError a => Fold a ServiceError Source #
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.
_UnableToDetectSchemaException :: AsError a => Fold a ServiceError Source #
Data format is not valid. Amazon Kinesis Analytics is not able to detect schema for the given streaming source.
_UnsupportedOperationException :: AsError a => Fold a ServiceError Source #
The request was rejected because a specified parameter is not supported or a specified resource is not valid for this operation.
ApplicationStatus
newtype ApplicationStatus Source #
Constructors
| ApplicationStatus' | |
Fields | |
Bundled Patterns
| pattern ApplicationStatus_DELETING :: ApplicationStatus | |
| pattern ApplicationStatus_READY :: ApplicationStatus | |
| pattern ApplicationStatus_RUNNING :: ApplicationStatus | |
| pattern ApplicationStatus_STARTING :: ApplicationStatus | |
| pattern ApplicationStatus_STOPPING :: ApplicationStatus | |
| pattern ApplicationStatus_UPDATING :: ApplicationStatus |
Instances
InputStartingPosition
newtype InputStartingPosition Source #
Constructors
| InputStartingPosition' | |
Fields | |
Bundled Patterns
Instances
RecordFormatType
newtype RecordFormatType Source #
Constructors
| RecordFormatType' | |
Fields | |
Bundled Patterns
| pattern RecordFormatType_CSV :: RecordFormatType | |
| pattern RecordFormatType_JSON :: RecordFormatType |
Instances
ApplicationDetail
data ApplicationDetail Source #
This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which only supports SQL applications. Version 2 of the API supports SQL and Java applications. For more information about version 2, see Amazon Kinesis Data Analytics API V2 Documentation.
Provides a description of the application, including the application Amazon Resource Name (ARN), status, latest version, and input and output configuration.
See: newApplicationDetail smart constructor.
Constructors
| ApplicationDetail' | |
Fields
| |
Instances
Arguments
| :: Text | |
| -> Text | |
| -> ApplicationStatus | |
| -> Natural | |
| -> ApplicationDetail |
Create a value of ApplicationDetail with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:applicationCode:ApplicationDetail', applicationDetail_applicationCode - Returns the application code that you provided to perform data analysis
on any of the in-application streams in your application.
$sel:applicationDescription:ApplicationDetail', applicationDetail_applicationDescription - Description of the application.
$sel:cloudWatchLoggingOptionDescriptions:ApplicationDetail', applicationDetail_cloudWatchLoggingOptionDescriptions - Describes the CloudWatch log streams that are configured to receive
application messages. For more information about using CloudWatch log
streams with Amazon Kinesis Analytics applications, see
Working with Amazon CloudWatch Logs.
$sel:createTimestamp:ApplicationDetail', applicationDetail_createTimestamp - Time stamp when the application version was created.
$sel:inputDescriptions:ApplicationDetail', applicationDetail_inputDescriptions - Describes the application input configuration. For more information, see
Configuring Application Input.
$sel:lastUpdateTimestamp:ApplicationDetail', applicationDetail_lastUpdateTimestamp - Time stamp when the application was last updated.
$sel:outputDescriptions:ApplicationDetail', applicationDetail_outputDescriptions - Describes the application output configuration. For more information,
see
Configuring Application Output.
$sel:referenceDataSourceDescriptions:ApplicationDetail', applicationDetail_referenceDataSourceDescriptions - Describes reference data sources configured for the application. For
more information, see
Configuring Application Input.
$sel:applicationName:ApplicationDetail', applicationDetail_applicationName - Name of the application.
$sel:applicationARN:ApplicationDetail', applicationDetail_applicationARN - ARN of the application.
$sel:applicationStatus:ApplicationDetail', applicationDetail_applicationStatus - Status of the application.
$sel:applicationVersionId:ApplicationDetail', applicationDetail_applicationVersionId - Provides the current application version.
applicationDetail_applicationCode :: Lens' ApplicationDetail (Maybe Text) Source #
Returns the application code that you provided to perform data analysis on any of the in-application streams in your application.
applicationDetail_applicationDescription :: Lens' ApplicationDetail (Maybe Text) Source #
Description of the application.
applicationDetail_cloudWatchLoggingOptionDescriptions :: Lens' ApplicationDetail (Maybe [CloudWatchLoggingOptionDescription]) Source #
Describes the CloudWatch log streams that are configured to receive application messages. For more information about using CloudWatch log streams with Amazon Kinesis Analytics applications, see Working with Amazon CloudWatch Logs.
applicationDetail_createTimestamp :: Lens' ApplicationDetail (Maybe UTCTime) Source #
Time stamp when the application version was created.
applicationDetail_inputDescriptions :: Lens' ApplicationDetail (Maybe [InputDescription]) Source #
Describes the application input configuration. For more information, see Configuring Application Input.
applicationDetail_lastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime) Source #
Time stamp when the application was last updated.
applicationDetail_outputDescriptions :: Lens' ApplicationDetail (Maybe [OutputDescription]) Source #
Describes the application output configuration. For more information, see Configuring Application Output.
applicationDetail_referenceDataSourceDescriptions :: Lens' ApplicationDetail (Maybe [ReferenceDataSourceDescription]) Source #
Describes reference data sources configured for the application. For more information, see Configuring Application Input.
applicationDetail_applicationName :: Lens' ApplicationDetail Text Source #
Name of the application.
applicationDetail_applicationARN :: Lens' ApplicationDetail Text Source #
ARN of the application.
applicationDetail_applicationStatus :: Lens' ApplicationDetail ApplicationStatus Source #
Status of the application.
applicationDetail_applicationVersionId :: Lens' ApplicationDetail Natural Source #
Provides the current application version.
ApplicationSummary
data ApplicationSummary Source #
This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which only supports SQL applications. Version 2 of the API supports SQL and Java applications. For more information about version 2, see Amazon Kinesis Data Analytics API V2 Documentation.
Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.
See: newApplicationSummary smart constructor.
Constructors
| ApplicationSummary' | |
Fields
| |
Instances
newApplicationSummary Source #
Arguments
| :: Text | |
| -> Text | |
| -> ApplicationStatus | |
| -> ApplicationSummary |
Create a value of ApplicationSummary with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:applicationName:ApplicationSummary', applicationSummary_applicationName - Name of the application.
$sel:applicationARN:ApplicationSummary', applicationSummary_applicationARN - ARN of the application.
$sel:applicationStatus:ApplicationSummary', applicationSummary_applicationStatus - Status of the application.
applicationSummary_applicationName :: Lens' ApplicationSummary Text Source #
Name of the application.
applicationSummary_applicationARN :: Lens' ApplicationSummary Text Source #
ARN of the application.
applicationSummary_applicationStatus :: Lens' ApplicationSummary ApplicationStatus Source #
Status of the application.
ApplicationUpdate
data ApplicationUpdate Source #
Describes updates to apply to an existing Amazon Kinesis Analytics application.
See: newApplicationUpdate smart constructor.
Constructors
| ApplicationUpdate' | |
Fields
| |
Instances
newApplicationUpdate :: ApplicationUpdate Source #
Create a value of ApplicationUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:applicationCodeUpdate:ApplicationUpdate', applicationUpdate_applicationCodeUpdate - Describes application code updates.
$sel:cloudWatchLoggingOptionUpdates:ApplicationUpdate', applicationUpdate_cloudWatchLoggingOptionUpdates - Describes application CloudWatch logging option updates.
$sel:inputUpdates:ApplicationUpdate', applicationUpdate_inputUpdates - Describes application input configuration updates.
$sel:outputUpdates:ApplicationUpdate', applicationUpdate_outputUpdates - Describes application output configuration updates.
$sel:referenceDataSourceUpdates:ApplicationUpdate', applicationUpdate_referenceDataSourceUpdates - Describes application reference data source updates.
applicationUpdate_applicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text) Source #
Describes application code updates.
applicationUpdate_cloudWatchLoggingOptionUpdates :: Lens' ApplicationUpdate (Maybe [CloudWatchLoggingOptionUpdate]) Source #
Describes application CloudWatch logging option updates.
applicationUpdate_inputUpdates :: Lens' ApplicationUpdate (Maybe [InputUpdate]) Source #
Describes application input configuration updates.
applicationUpdate_outputUpdates :: Lens' ApplicationUpdate (Maybe [OutputUpdate]) Source #
Describes application output configuration updates.
applicationUpdate_referenceDataSourceUpdates :: Lens' ApplicationUpdate (Maybe [ReferenceDataSourceUpdate]) Source #
Describes application reference data source updates.
CSVMappingParameters
data CSVMappingParameters Source #
Provides additional mapping information when the record format uses delimiters, such as CSV. For example, the following sample records use CSV format, where the records use the '\n' as the row delimiter and a comma (",") as the column delimiter:
"name1", "address1"
"name2", "address2"
See: newCSVMappingParameters smart constructor.
Constructors
| CSVMappingParameters' | |
Fields
| |
Instances
newCSVMappingParameters Source #
Arguments
| :: Text | |
| -> Text | |
| -> CSVMappingParameters |
Create a value of CSVMappingParameters with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:recordRowDelimiter:CSVMappingParameters', cSVMappingParameters_recordRowDelimiter - Row delimiter. For example, in a CSV format, '\n' is the typical
row delimiter.
$sel:recordColumnDelimiter:CSVMappingParameters', cSVMappingParameters_recordColumnDelimiter - Column delimiter. For example, in a CSV format, a comma (",") is the
typical column delimiter.
cSVMappingParameters_recordRowDelimiter :: Lens' CSVMappingParameters Text Source #
Row delimiter. For example, in a CSV format, '\n' is the typical row delimiter.
cSVMappingParameters_recordColumnDelimiter :: Lens' CSVMappingParameters Text Source #
Column delimiter. For example, in a CSV format, a comma (",") is the typical column delimiter.
CloudWatchLoggingOption
data CloudWatchLoggingOption Source #
Provides a description of CloudWatch logging options, including the log stream Amazon Resource Name (ARN) and the role ARN.
See: newCloudWatchLoggingOption smart constructor.
Constructors
| CloudWatchLoggingOption' | |
Fields
| |
Instances
newCloudWatchLoggingOption Source #
Arguments
| :: Text | |
| -> Text | |
| -> CloudWatchLoggingOption |
Create a value of CloudWatchLoggingOption with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:logStreamARN:CloudWatchLoggingOption', cloudWatchLoggingOption_logStreamARN - ARN of the CloudWatch log to receive application messages.
$sel:roleARN:CloudWatchLoggingOption', cloudWatchLoggingOption_roleARN - IAM ARN of the role to use to send application messages. Note: To write
application messages to CloudWatch, the IAM role that is used must have
the PutLogEvents policy action enabled.
cloudWatchLoggingOption_logStreamARN :: Lens' CloudWatchLoggingOption Text Source #
ARN of the CloudWatch log to receive application messages.
cloudWatchLoggingOption_roleARN :: Lens' CloudWatchLoggingOption Text Source #
IAM ARN of the role to use to send application messages. Note: To write
application messages to CloudWatch, the IAM role that is used must have
the PutLogEvents policy action enabled.
CloudWatchLoggingOptionDescription
data CloudWatchLoggingOptionDescription Source #
Description of the CloudWatch logging option.
See: newCloudWatchLoggingOptionDescription smart constructor.
Constructors
| CloudWatchLoggingOptionDescription' | |
Fields
| |
Instances
newCloudWatchLoggingOptionDescription Source #
Arguments
| :: Text | |
| -> Text | |
| -> CloudWatchLoggingOptionDescription |
Create a value of CloudWatchLoggingOptionDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:cloudWatchLoggingOptionId:CloudWatchLoggingOptionDescription', cloudWatchLoggingOptionDescription_cloudWatchLoggingOptionId - ID of the CloudWatch logging option description.
$sel:logStreamARN:CloudWatchLoggingOptionDescription', cloudWatchLoggingOptionDescription_logStreamARN - ARN of the CloudWatch log to receive application messages.
$sel:roleARN:CloudWatchLoggingOptionDescription', cloudWatchLoggingOptionDescription_roleARN - IAM ARN of the role to use to send application messages. Note: To write
application messages to CloudWatch, the IAM role used must have the
PutLogEvents policy action enabled.
cloudWatchLoggingOptionDescription_cloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionDescription (Maybe Text) Source #
ID of the CloudWatch logging option description.
cloudWatchLoggingOptionDescription_logStreamARN :: Lens' CloudWatchLoggingOptionDescription Text Source #
ARN of the CloudWatch log to receive application messages.
cloudWatchLoggingOptionDescription_roleARN :: Lens' CloudWatchLoggingOptionDescription Text Source #
IAM ARN of the role to use to send application messages. Note: To write
application messages to CloudWatch, the IAM role used must have the
PutLogEvents policy action enabled.
CloudWatchLoggingOptionUpdate
data CloudWatchLoggingOptionUpdate Source #
Describes CloudWatch logging option updates.
See: newCloudWatchLoggingOptionUpdate smart constructor.
Constructors
| CloudWatchLoggingOptionUpdate' | |
Fields
| |
Instances
newCloudWatchLoggingOptionUpdate Source #
Arguments
| :: Text |
|
| -> CloudWatchLoggingOptionUpdate |
Create a value of CloudWatchLoggingOptionUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:logStreamARNUpdate:CloudWatchLoggingOptionUpdate', cloudWatchLoggingOptionUpdate_logStreamARNUpdate - ARN of the CloudWatch log to receive application messages.
$sel:roleARNUpdate:CloudWatchLoggingOptionUpdate', cloudWatchLoggingOptionUpdate_roleARNUpdate - IAM ARN of the role to use to send application messages. Note: To write
application messages to CloudWatch, the IAM role used must have the
PutLogEvents policy action enabled.
$sel:cloudWatchLoggingOptionId:CloudWatchLoggingOptionUpdate', cloudWatchLoggingOptionUpdate_cloudWatchLoggingOptionId - ID of the CloudWatch logging option to update
cloudWatchLoggingOptionUpdate_logStreamARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text) Source #
ARN of the CloudWatch log to receive application messages.
cloudWatchLoggingOptionUpdate_roleARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text) Source #
IAM ARN of the role to use to send application messages. Note: To write
application messages to CloudWatch, the IAM role used must have the
PutLogEvents policy action enabled.
cloudWatchLoggingOptionUpdate_cloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionUpdate Text Source #
ID of the CloudWatch logging option to update
DestinationSchema
data DestinationSchema Source #
Describes the data format when records are written to the destination. For more information, see Configuring Application Output.
See: newDestinationSchema smart constructor.
Constructors
| DestinationSchema' | |
Fields
| |
Instances
Create a value of DestinationSchema with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:recordFormatType:DestinationSchema', destinationSchema_recordFormatType - Specifies the format of the records on the output stream.
destinationSchema_recordFormatType :: Lens' DestinationSchema RecordFormatType Source #
Specifies the format of the records on the output stream.
Input
When you configure the application input, you specify the streaming source, the in-application stream name that is created, and the mapping between the two. For more information, see Configuring Application Input.
See: newInput smart constructor.
Constructors
| Input' | |
Fields
| |
Instances
Arguments
| :: Text | |
| -> SourceSchema | |
| -> Input |
Create a value of Input with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:inputParallelism:Input', input_inputParallelism - Describes the number of in-application streams to create.
Data from your source is routed to these in-application input streams.
(see Configuring Application Input.
$sel:inputProcessingConfiguration:Input', input_inputProcessingConfiguration - The
InputProcessingConfiguration
for the input. An input processor transforms records as they are
received from the stream, before the application's SQL code executes.
Currently, the only input processing configuration available is
InputLambdaProcessor.
$sel:kinesisFirehoseInput:Input', input_kinesisFirehoseInput - If the streaming source is an Amazon Kinesis Firehose delivery stream,
identifies the delivery stream's ARN and an IAM role that enables
Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either KinesisStreamsInput or KinesisFirehoseInput is
required.
$sel:kinesisStreamsInput:Input', input_kinesisStreamsInput - If the streaming source is an Amazon Kinesis stream, identifies the
stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon
Kinesis Analytics to access the stream on your behalf.
Note: Either KinesisStreamsInput or KinesisFirehoseInput is
required.
$sel:namePrefix:Input', input_namePrefix - Name prefix to use when creating an in-application stream. Suppose that
you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics
then creates one or more (as per the InputParallelism count you
specified) in-application streams with names
"MyInApplicationStream_001," "MyInApplicationStream_002," and so on.
$sel:inputSchema:Input', input_inputSchema - Describes the format of the data in the streaming source, and how each
data element maps to corresponding columns in the in-application stream
that is being created.
Also used to describe the format of the reference data source.
input_inputParallelism :: Lens' Input (Maybe InputParallelism) Source #
Describes the number of in-application streams to create.
Data from your source is routed to these in-application input streams.
input_inputProcessingConfiguration :: Lens' Input (Maybe InputProcessingConfiguration) Source #
The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor.
input_kinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput) Source #
If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either KinesisStreamsInput or KinesisFirehoseInput is
required.
input_kinesisStreamsInput :: Lens' Input (Maybe KinesisStreamsInput) Source #
If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
Note: Either KinesisStreamsInput or KinesisFirehoseInput is
required.
input_namePrefix :: Lens' Input Text Source #
Name prefix to use when creating an in-application stream. Suppose that
you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics
then creates one or more (as per the InputParallelism count you
specified) in-application streams with names
"MyInApplicationStream_001," "MyInApplicationStream_002," and so on.
input_inputSchema :: Lens' Input SourceSchema Source #
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
Also used to describe the format of the reference data source.
InputConfiguration
data InputConfiguration Source #
When you start your application, you provide this configuration, which identifies the input source and the point in the input source at which you want the application to start processing records.
See: newInputConfiguration smart constructor.
Constructors
| InputConfiguration' | |
Fields
| |
Instances
newInputConfiguration Source #
Arguments
| :: Text | |
| -> InputStartingPositionConfiguration | |
| -> InputConfiguration |
Create a value of InputConfiguration with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:id:InputConfiguration', inputConfiguration_id - Input source ID. You can get this ID by calling the
DescribeApplication
operation.
$sel:inputStartingPositionConfiguration:InputConfiguration', inputConfiguration_inputStartingPositionConfiguration - Point at which you want the application to start processing records from
the streaming source.
inputConfiguration_id :: Lens' InputConfiguration Text Source #
Input source ID. You can get this ID by calling the DescribeApplication operation.
inputConfiguration_inputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration Source #
Point at which you want the application to start processing records from the streaming source.
InputDescription
data InputDescription Source #
Describes the application input configuration. For more information, see Configuring Application Input.
See: newInputDescription smart constructor.
Constructors
| InputDescription' | |
Fields
| |
Instances
newInputDescription :: InputDescription Source #
Create a value of InputDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:inAppStreamNames:InputDescription', inputDescription_inAppStreamNames - Returns the in-application stream names that are mapped to the stream
source.
$sel:inputId:InputDescription', inputDescription_inputId - Input ID associated with the application input. This is the ID that
Amazon Kinesis Analytics assigns to each input configuration you add to
your application.
$sel:inputParallelism:InputDescription', inputDescription_inputParallelism - Describes the configured parallelism (number of in-application streams
mapped to the streaming source).
$sel:inputProcessingConfigurationDescription:InputDescription', inputDescription_inputProcessingConfigurationDescription - The description of the preprocessor that executes on records in this
input before the application's code is run.
$sel:inputSchema:InputDescription', inputDescription_inputSchema - Describes the format of the data in the streaming source, and how each
data element maps to corresponding columns in the in-application stream
that is being created.
$sel:inputStartingPositionConfiguration:InputDescription', inputDescription_inputStartingPositionConfiguration - Point at which the application is configured to read from the input
stream.
$sel:kinesisFirehoseInputDescription:InputDescription', inputDescription_kinesisFirehoseInputDescription - If an Amazon Kinesis Firehose delivery stream is configured as a
streaming source, provides the delivery stream's ARN and an IAM role
that enables Amazon Kinesis Analytics to access the stream on your
behalf.
$sel:kinesisStreamsInputDescription:InputDescription', inputDescription_kinesisStreamsInputDescription - If an Amazon Kinesis stream is configured as streaming source, provides
Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that
enables Amazon Kinesis Analytics to access the stream on your behalf.
$sel:namePrefix:InputDescription', inputDescription_namePrefix - In-application name prefix.
inputDescription_inAppStreamNames :: Lens' InputDescription (Maybe [Text]) Source #
Returns the in-application stream names that are mapped to the stream source.
inputDescription_inputId :: Lens' InputDescription (Maybe Text) Source #
Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.
inputDescription_inputParallelism :: Lens' InputDescription (Maybe InputParallelism) Source #
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
inputDescription_inputProcessingConfigurationDescription :: Lens' InputDescription (Maybe InputProcessingConfigurationDescription) Source #
The description of the preprocessor that executes on records in this input before the application's code is run.
inputDescription_inputSchema :: Lens' InputDescription (Maybe SourceSchema) Source #
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
inputDescription_inputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration) Source #
Point at which the application is configured to read from the input stream.
inputDescription_kinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription) Source #
If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
inputDescription_kinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription) Source #
If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
inputDescription_namePrefix :: Lens' InputDescription (Maybe Text) Source #
In-application name prefix.
InputLambdaProcessor
data InputLambdaProcessor Source #
An object that contains the Amazon Resource Name (ARN) of the AWS Lambda function that is used to preprocess records in the stream, and the ARN of the IAM role that is used to access the AWS Lambda function.
See: newInputLambdaProcessor smart constructor.
Constructors
| InputLambdaProcessor' | |
Fields
| |
Instances
newInputLambdaProcessor Source #
Arguments
| :: Text | |
| -> Text | |
| -> InputLambdaProcessor |
Create a value of InputLambdaProcessor with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:InputLambdaProcessor', inputLambdaProcessor_resourceARN - The ARN of the AWS Lambda function
that operates on records in the stream.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
$sel:roleARN:InputLambdaProcessor', inputLambdaProcessor_roleARN - The ARN of the IAM role that is used to access the AWS Lambda function.
inputLambdaProcessor_resourceARN :: Lens' InputLambdaProcessor Text Source #
The ARN of the AWS Lambda function that operates on records in the stream.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
inputLambdaProcessor_roleARN :: Lens' InputLambdaProcessor Text Source #
The ARN of the IAM role that is used to access the AWS Lambda function.
InputLambdaProcessorDescription
data InputLambdaProcessorDescription Source #
An object that contains the Amazon Resource Name (ARN) of the AWS Lambda function that is used to preprocess records in the stream, and the ARN of the IAM role that is used to access the AWS Lambda expression.
See: newInputLambdaProcessorDescription smart constructor.
Constructors
| InputLambdaProcessorDescription' | |
Fields
| |
Instances
newInputLambdaProcessorDescription :: InputLambdaProcessorDescription Source #
Create a value of InputLambdaProcessorDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:InputLambdaProcessorDescription', inputLambdaProcessorDescription_resourceARN - The ARN of the AWS Lambda function
that is used to preprocess the records in the stream.
$sel:roleARN:InputLambdaProcessorDescription', inputLambdaProcessorDescription_roleARN - The ARN of the IAM role that is used to access the AWS Lambda function.
inputLambdaProcessorDescription_resourceARN :: Lens' InputLambdaProcessorDescription (Maybe Text) Source #
The ARN of the AWS Lambda function that is used to preprocess the records in the stream.
inputLambdaProcessorDescription_roleARN :: Lens' InputLambdaProcessorDescription (Maybe Text) Source #
The ARN of the IAM role that is used to access the AWS Lambda function.
InputLambdaProcessorUpdate
data InputLambdaProcessorUpdate Source #
Represents an update to the InputLambdaProcessor that is used to preprocess the records in the stream.
See: newInputLambdaProcessorUpdate smart constructor.
Constructors
| InputLambdaProcessorUpdate' | |
Fields
| |
Instances
newInputLambdaProcessorUpdate :: InputLambdaProcessorUpdate Source #
Create a value of InputLambdaProcessorUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARNUpdate:InputLambdaProcessorUpdate', inputLambdaProcessorUpdate_resourceARNUpdate - The Amazon Resource Name (ARN) of the new
AWS Lambda function that is used
to preprocess the records in the stream.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
$sel:roleARNUpdate:InputLambdaProcessorUpdate', inputLambdaProcessorUpdate_roleARNUpdate - The ARN of the new IAM role that is used to access the AWS Lambda
function.
inputLambdaProcessorUpdate_resourceARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text) Source #
The Amazon Resource Name (ARN) of the new AWS Lambda function that is used to preprocess the records in the stream.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
inputLambdaProcessorUpdate_roleARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text) Source #
The ARN of the new IAM role that is used to access the AWS Lambda function.
InputParallelism
data InputParallelism Source #
Describes the number of in-application streams to create for a given streaming source. For information about parallelism, see Configuring Application Input.
See: newInputParallelism smart constructor.
Constructors
| InputParallelism' | |
Instances
newInputParallelism :: InputParallelism Source #
Create a value of InputParallelism with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:count:InputParallelism', inputParallelism_count - Number of in-application streams to create. For more information, see
Limits.
inputParallelism_count :: Lens' InputParallelism (Maybe Natural) Source #
Number of in-application streams to create. For more information, see Limits.
InputParallelismUpdate
data InputParallelismUpdate Source #
Provides updates to the parallelism count.
See: newInputParallelismUpdate smart constructor.
Constructors
| InputParallelismUpdate' | |
Fields
| |
Instances
newInputParallelismUpdate :: InputParallelismUpdate Source #
Create a value of InputParallelismUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:countUpdate:InputParallelismUpdate', inputParallelismUpdate_countUpdate - Number of in-application streams to create for the specified streaming
source.
inputParallelismUpdate_countUpdate :: Lens' InputParallelismUpdate (Maybe Natural) Source #
Number of in-application streams to create for the specified streaming source.
InputProcessingConfiguration
data InputProcessingConfiguration Source #
Provides a description of a processor that is used to preprocess the records in the stream before being processed by your application code. Currently, the only input processor available is AWS Lambda.
See: newInputProcessingConfiguration smart constructor.
Constructors
| InputProcessingConfiguration' | |
Fields
| |
Instances
newInputProcessingConfiguration Source #
Arguments
| :: InputLambdaProcessor | |
| -> InputProcessingConfiguration |
Create a value of InputProcessingConfiguration with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:inputLambdaProcessor:InputProcessingConfiguration', inputProcessingConfiguration_inputLambdaProcessor - The
InputLambdaProcessor
that is used to preprocess the records in the stream before being
processed by your application code.
inputProcessingConfiguration_inputLambdaProcessor :: Lens' InputProcessingConfiguration InputLambdaProcessor Source #
The InputLambdaProcessor that is used to preprocess the records in the stream before being processed by your application code.
InputProcessingConfigurationDescription
data InputProcessingConfigurationDescription Source #
Provides configuration information about an input processor. Currently, the only input processor available is AWS Lambda.
See: newInputProcessingConfigurationDescription smart constructor.
Constructors
| InputProcessingConfigurationDescription' | |
Fields
| |
Instances
newInputProcessingConfigurationDescription :: InputProcessingConfigurationDescription Source #
Create a value of InputProcessingConfigurationDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:inputLambdaProcessorDescription:InputProcessingConfigurationDescription', inputProcessingConfigurationDescription_inputLambdaProcessorDescription - Provides configuration information about the associated
InputLambdaProcessorDescription.
inputProcessingConfigurationDescription_inputLambdaProcessorDescription :: Lens' InputProcessingConfigurationDescription (Maybe InputLambdaProcessorDescription) Source #
Provides configuration information about the associated InputLambdaProcessorDescription.
InputProcessingConfigurationUpdate
data InputProcessingConfigurationUpdate Source #
Describes updates to an InputProcessingConfiguration.
See: newInputProcessingConfigurationUpdate smart constructor.
Constructors
| InputProcessingConfigurationUpdate' | |
Fields
| |
Instances
newInputProcessingConfigurationUpdate Source #
Arguments
| :: InputLambdaProcessorUpdate |
|
| -> InputProcessingConfigurationUpdate |
Create a value of InputProcessingConfigurationUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:inputLambdaProcessorUpdate:InputProcessingConfigurationUpdate', inputProcessingConfigurationUpdate_inputLambdaProcessorUpdate - Provides update information for an
InputLambdaProcessor.
inputProcessingConfigurationUpdate_inputLambdaProcessorUpdate :: Lens' InputProcessingConfigurationUpdate InputLambdaProcessorUpdate Source #
Provides update information for an InputLambdaProcessor.
InputSchemaUpdate
data InputSchemaUpdate Source #
Describes updates for the application's input schema.
See: newInputSchemaUpdate smart constructor.
Constructors
| InputSchemaUpdate' | |
Fields
| |
Instances
newInputSchemaUpdate :: InputSchemaUpdate Source #
Create a value of InputSchemaUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:recordColumnUpdates:InputSchemaUpdate', inputSchemaUpdate_recordColumnUpdates - A list of RecordColumn objects. Each object describes the mapping of
the streaming source element to the corresponding column in the
in-application stream.
$sel:recordEncodingUpdate:InputSchemaUpdate', inputSchemaUpdate_recordEncodingUpdate - Specifies the encoding of the records in the streaming source. For
example, UTF-8.
$sel:recordFormatUpdate:InputSchemaUpdate', inputSchemaUpdate_recordFormatUpdate - Specifies the format of the records on the streaming source.
inputSchemaUpdate_recordColumnUpdates :: Lens' InputSchemaUpdate (Maybe (NonEmpty RecordColumn)) Source #
A list of RecordColumn objects. Each object describes the mapping of
the streaming source element to the corresponding column in the
in-application stream.
inputSchemaUpdate_recordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text) Source #
Specifies the encoding of the records in the streaming source. For example, UTF-8.
inputSchemaUpdate_recordFormatUpdate :: Lens' InputSchemaUpdate (Maybe RecordFormat) Source #
Specifies the format of the records on the streaming source.
InputStartingPositionConfiguration
data InputStartingPositionConfiguration Source #
Describes the point at which the application reads from the streaming source.
See: newInputStartingPositionConfiguration smart constructor.
Constructors
| InputStartingPositionConfiguration' | |
Fields
| |
Instances
newInputStartingPositionConfiguration :: InputStartingPositionConfiguration Source #
Create a value of InputStartingPositionConfiguration with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:inputStartingPosition:InputStartingPositionConfiguration', inputStartingPositionConfiguration_inputStartingPosition - The starting position on the stream.
NOW- Start reading just after the most recent record in the stream, start at the request time stamp that the customer issued.TRIM_HORIZON- Start reading at the last untrimmed record in the stream, which is the oldest record available in the stream. This option is not available for an Amazon Kinesis Firehose delivery stream.LAST_STOPPED_POINT- Resume reading from where the application last stopped reading.
inputStartingPositionConfiguration_inputStartingPosition :: Lens' InputStartingPositionConfiguration (Maybe InputStartingPosition) Source #
The starting position on the stream.
NOW- Start reading just after the most recent record in the stream, start at the request time stamp that the customer issued.TRIM_HORIZON- Start reading at the last untrimmed record in the stream, which is the oldest record available in the stream. This option is not available for an Amazon Kinesis Firehose delivery stream.LAST_STOPPED_POINT- Resume reading from where the application last stopped reading.
InputUpdate
data InputUpdate Source #
Describes updates to a specific input configuration (identified by the
InputId of an application).
See: newInputUpdate smart constructor.
Constructors
| InputUpdate' | |
Fields
| |
Instances
Arguments
| :: Text | |
| -> InputUpdate |
Create a value of InputUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:inputParallelismUpdate:InputUpdate', inputUpdate_inputParallelismUpdate - Describes the parallelism updates (the number in-application streams
Amazon Kinesis Analytics creates for the specific streaming source).
$sel:inputProcessingConfigurationUpdate:InputUpdate', inputUpdate_inputProcessingConfigurationUpdate - Describes updates for an input processing configuration.
$sel:inputSchemaUpdate:InputUpdate', inputUpdate_inputSchemaUpdate - Describes the data format on the streaming source, and how record
elements on the streaming source map to columns of the in-application
stream that is created.
$sel:kinesisFirehoseInputUpdate:InputUpdate', inputUpdate_kinesisFirehoseInputUpdate - If an Amazon Kinesis Firehose delivery stream is the streaming source to
be updated, provides an updated stream ARN and IAM role ARN.
$sel:kinesisStreamsInputUpdate:InputUpdate', inputUpdate_kinesisStreamsInputUpdate - If an Amazon Kinesis stream is the streaming source to be updated,
provides an updated stream Amazon Resource Name (ARN) and IAM role ARN.
$sel:namePrefixUpdate:InputUpdate', inputUpdate_namePrefixUpdate - Name prefix for in-application streams that Amazon Kinesis Analytics
creates for the specific streaming source.
$sel:inputId:InputUpdate', inputUpdate_inputId - Input ID of the application input to be updated.
inputUpdate_inputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate) Source #
Describes the parallelism updates (the number in-application streams Amazon Kinesis Analytics creates for the specific streaming source).
inputUpdate_inputProcessingConfigurationUpdate :: Lens' InputUpdate (Maybe InputProcessingConfigurationUpdate) Source #
Describes updates for an input processing configuration.
inputUpdate_inputSchemaUpdate :: Lens' InputUpdate (Maybe InputSchemaUpdate) Source #
Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.
inputUpdate_kinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate) Source #
If an Amazon Kinesis Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.
inputUpdate_kinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate) Source #
If an Amazon Kinesis stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN) and IAM role ARN.
inputUpdate_namePrefixUpdate :: Lens' InputUpdate (Maybe Text) Source #
Name prefix for in-application streams that Amazon Kinesis Analytics creates for the specific streaming source.
inputUpdate_inputId :: Lens' InputUpdate Text Source #
Input ID of the application input to be updated.
JSONMappingParameters
data JSONMappingParameters Source #
Provides additional mapping information when JSON is the record format on the streaming source.
See: newJSONMappingParameters smart constructor.
Constructors
| JSONMappingParameters' | |
Fields
| |
Instances
newJSONMappingParameters Source #
Create a value of JSONMappingParameters with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:recordRowPath:JSONMappingParameters', jSONMappingParameters_recordRowPath - Path to the top-level parent that contains the records.
jSONMappingParameters_recordRowPath :: Lens' JSONMappingParameters Text Source #
Path to the top-level parent that contains the records.
KinesisFirehoseInput
data KinesisFirehoseInput Source #
Identifies an Amazon Kinesis Firehose delivery stream as the streaming source. You provide the delivery stream's Amazon Resource Name (ARN) and an IAM role ARN that enables Amazon Kinesis Analytics to access the stream on your behalf.
See: newKinesisFirehoseInput smart constructor.
Constructors
| KinesisFirehoseInput' | |
Fields
| |
Instances
newKinesisFirehoseInput Source #
Arguments
| :: Text | |
| -> Text | |
| -> KinesisFirehoseInput |
Create a value of KinesisFirehoseInput with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisFirehoseInput', kinesisFirehoseInput_resourceARN - ARN of the input delivery stream.
$sel:roleARN:KinesisFirehoseInput', kinesisFirehoseInput_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream on your behalf. You need to make sure that the role has the
necessary permissions to access the stream.
kinesisFirehoseInput_resourceARN :: Lens' KinesisFirehoseInput Text Source #
ARN of the input delivery stream.
kinesisFirehoseInput_roleARN :: Lens' KinesisFirehoseInput Text Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to make sure that the role has the necessary permissions to access the stream.
KinesisFirehoseInputDescription
data KinesisFirehoseInputDescription Source #
Describes the Amazon Kinesis Firehose delivery stream that is configured as the streaming source in the application input configuration.
See: newKinesisFirehoseInputDescription smart constructor.
Constructors
| KinesisFirehoseInputDescription' | |
Instances
newKinesisFirehoseInputDescription :: KinesisFirehoseInputDescription Source #
Create a value of KinesisFirehoseInputDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisFirehoseInputDescription', kinesisFirehoseInputDescription_resourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery
stream.
$sel:roleARN:KinesisFirehoseInputDescription', kinesisFirehoseInputDescription_roleARN - ARN of the IAM role that Amazon Kinesis Analytics assumes to access the
stream.
kinesisFirehoseInputDescription_resourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.
kinesisFirehoseInputDescription_roleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics assumes to access the stream.
KinesisFirehoseInputUpdate
data KinesisFirehoseInputUpdate Source #
When updating application input configuration, provides information about an Amazon Kinesis Firehose delivery stream as the streaming source.
See: newKinesisFirehoseInputUpdate smart constructor.
Constructors
| KinesisFirehoseInputUpdate' | |
Fields
| |
Instances
newKinesisFirehoseInputUpdate :: KinesisFirehoseInputUpdate Source #
Create a value of KinesisFirehoseInputUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARNUpdate:KinesisFirehoseInputUpdate', kinesisFirehoseInputUpdate_resourceARNUpdate - Amazon Resource Name (ARN) of the input Amazon Kinesis Firehose delivery
stream to read.
$sel:roleARNUpdate:KinesisFirehoseInputUpdate', kinesisFirehoseInputUpdate_roleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream on your behalf. You need to grant the necessary permissions
to this role.
kinesisFirehoseInputUpdate_resourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the input Amazon Kinesis Firehose delivery stream to read.
kinesisFirehoseInputUpdate_roleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.
KinesisFirehoseOutput
data KinesisFirehoseOutput Source #
When configuring application output, identifies an Amazon Kinesis Firehose delivery stream as the destination. You provide the stream Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to write to the stream on your behalf.
See: newKinesisFirehoseOutput smart constructor.
Constructors
| KinesisFirehoseOutput' | |
Fields
| |
Instances
newKinesisFirehoseOutput Source #
Arguments
| :: Text | |
| -> Text | |
| -> KinesisFirehoseOutput |
Create a value of KinesisFirehoseOutput with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisFirehoseOutput', kinesisFirehoseOutput_resourceARN - ARN of the destination Amazon Kinesis Firehose delivery stream to write
to.
$sel:roleARN:KinesisFirehoseOutput', kinesisFirehoseOutput_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to
the destination stream on your behalf. You need to grant the necessary
permissions to this role.
kinesisFirehoseOutput_resourceARN :: Lens' KinesisFirehoseOutput Text Source #
ARN of the destination Amazon Kinesis Firehose delivery stream to write to.
kinesisFirehoseOutput_roleARN :: Lens' KinesisFirehoseOutput Text Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. You need to grant the necessary permissions to this role.
KinesisFirehoseOutputDescription
data KinesisFirehoseOutputDescription Source #
For an application output, describes the Amazon Kinesis Firehose delivery stream configured as its destination.
See: newKinesisFirehoseOutputDescription smart constructor.
Constructors
| KinesisFirehoseOutputDescription' | |
Instances
newKinesisFirehoseOutputDescription :: KinesisFirehoseOutputDescription Source #
Create a value of KinesisFirehoseOutputDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisFirehoseOutputDescription', kinesisFirehoseOutputDescription_resourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery
stream.
$sel:roleARN:KinesisFirehoseOutputDescription', kinesisFirehoseOutputDescription_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream.
kinesisFirehoseOutputDescription_resourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.
kinesisFirehoseOutputDescription_roleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.
KinesisFirehoseOutputUpdate
data KinesisFirehoseOutputUpdate Source #
When updating an output configuration using the UpdateApplication operation, provides information about an Amazon Kinesis Firehose delivery stream configured as the destination.
See: newKinesisFirehoseOutputUpdate smart constructor.
Constructors
| KinesisFirehoseOutputUpdate' | |
Fields
| |
Instances
newKinesisFirehoseOutputUpdate :: KinesisFirehoseOutputUpdate Source #
Create a value of KinesisFirehoseOutputUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARNUpdate:KinesisFirehoseOutputUpdate', kinesisFirehoseOutputUpdate_resourceARNUpdate - Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery
stream to write to.
$sel:roleARNUpdate:KinesisFirehoseOutputUpdate', kinesisFirehoseOutputUpdate_roleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream on your behalf. You need to grant the necessary permissions
to this role.
kinesisFirehoseOutputUpdate_resourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream to write to.
kinesisFirehoseOutputUpdate_roleARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.
KinesisStreamsInput
data KinesisStreamsInput Source #
Identifies an Amazon Kinesis stream as the streaming source. You provide the stream's Amazon Resource Name (ARN) and an IAM role ARN that enables Amazon Kinesis Analytics to access the stream on your behalf.
See: newKinesisStreamsInput smart constructor.
Constructors
| KinesisStreamsInput' | |
Fields
| |
Instances
newKinesisStreamsInput Source #
Arguments
| :: Text | |
| -> Text | |
| -> KinesisStreamsInput |
Create a value of KinesisStreamsInput with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisStreamsInput', kinesisStreamsInput_resourceARN - ARN of the input Amazon Kinesis stream to read.
$sel:roleARN:KinesisStreamsInput', kinesisStreamsInput_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream on your behalf. You need to grant the necessary permissions
to this role.
kinesisStreamsInput_resourceARN :: Lens' KinesisStreamsInput Text Source #
ARN of the input Amazon Kinesis stream to read.
kinesisStreamsInput_roleARN :: Lens' KinesisStreamsInput Text Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.
KinesisStreamsInputDescription
data KinesisStreamsInputDescription Source #
Describes the Amazon Kinesis stream that is configured as the streaming source in the application input configuration.
See: newKinesisStreamsInputDescription smart constructor.
Constructors
| KinesisStreamsInputDescription' | |
Instances
newKinesisStreamsInputDescription :: KinesisStreamsInputDescription Source #
Create a value of KinesisStreamsInputDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisStreamsInputDescription', kinesisStreamsInputDescription_resourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis stream.
$sel:roleARN:KinesisStreamsInputDescription', kinesisStreamsInputDescription_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream.
kinesisStreamsInputDescription_resourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis stream.
kinesisStreamsInputDescription_roleARN :: Lens' KinesisStreamsInputDescription (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.
KinesisStreamsInputUpdate
data KinesisStreamsInputUpdate Source #
When updating application input configuration, provides information about an Amazon Kinesis stream as the streaming source.
See: newKinesisStreamsInputUpdate smart constructor.
Constructors
| KinesisStreamsInputUpdate' | |
Fields
| |
Instances
newKinesisStreamsInputUpdate :: KinesisStreamsInputUpdate Source #
Create a value of KinesisStreamsInputUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARNUpdate:KinesisStreamsInputUpdate', kinesisStreamsInputUpdate_resourceARNUpdate - Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.
$sel:roleARNUpdate:KinesisStreamsInputUpdate', kinesisStreamsInputUpdate_roleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream on your behalf. You need to grant the necessary permissions
to this role.
kinesisStreamsInputUpdate_resourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.
kinesisStreamsInputUpdate_roleARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.
KinesisStreamsOutput
data KinesisStreamsOutput Source #
When configuring application output, identifies an Amazon Kinesis stream as the destination. You provide the stream Amazon Resource Name (ARN) and also an IAM role ARN that Amazon Kinesis Analytics can use to write to the stream on your behalf.
See: newKinesisStreamsOutput smart constructor.
Constructors
| KinesisStreamsOutput' | |
Fields
| |
Instances
newKinesisStreamsOutput Source #
Arguments
| :: Text | |
| -> Text | |
| -> KinesisStreamsOutput |
Create a value of KinesisStreamsOutput with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisStreamsOutput', kinesisStreamsOutput_resourceARN - ARN of the destination Amazon Kinesis stream to write to.
$sel:roleARN:KinesisStreamsOutput', kinesisStreamsOutput_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to
the destination stream on your behalf. You need to grant the necessary
permissions to this role.
kinesisStreamsOutput_resourceARN :: Lens' KinesisStreamsOutput Text Source #
ARN of the destination Amazon Kinesis stream to write to.
kinesisStreamsOutput_roleARN :: Lens' KinesisStreamsOutput Text Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. You need to grant the necessary permissions to this role.
KinesisStreamsOutputDescription
data KinesisStreamsOutputDescription Source #
For an application output, describes the Amazon Kinesis stream configured as its destination.
See: newKinesisStreamsOutputDescription smart constructor.
Constructors
| KinesisStreamsOutputDescription' | |
Instances
newKinesisStreamsOutputDescription :: KinesisStreamsOutputDescription Source #
Create a value of KinesisStreamsOutputDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:KinesisStreamsOutputDescription', kinesisStreamsOutputDescription_resourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis stream.
$sel:roleARN:KinesisStreamsOutputDescription', kinesisStreamsOutputDescription_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream.
kinesisStreamsOutputDescription_resourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis stream.
kinesisStreamsOutputDescription_roleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.
KinesisStreamsOutputUpdate
data KinesisStreamsOutputUpdate Source #
When updating an output configuration using the UpdateApplication operation, provides information about an Amazon Kinesis stream configured as the destination.
See: newKinesisStreamsOutputUpdate smart constructor.
Constructors
| KinesisStreamsOutputUpdate' | |
Fields
| |
Instances
newKinesisStreamsOutputUpdate :: KinesisStreamsOutputUpdate Source #
Create a value of KinesisStreamsOutputUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARNUpdate:KinesisStreamsOutputUpdate', kinesisStreamsOutputUpdate_resourceARNUpdate - Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want
to write the output.
$sel:roleARNUpdate:KinesisStreamsOutputUpdate', kinesisStreamsOutputUpdate_roleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access
the stream on your behalf. You need to grant the necessary permissions
to this role.
kinesisStreamsOutputUpdate_resourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want to write the output.
kinesisStreamsOutputUpdate_roleARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.
LambdaOutput
data LambdaOutput Source #
When configuring application output, identifies an AWS Lambda function as the destination. You provide the function Amazon Resource Name (ARN) and also an IAM role ARN that Amazon Kinesis Analytics can use to write to the function on your behalf.
See: newLambdaOutput smart constructor.
Constructors
| LambdaOutput' | |
Fields
| |
Instances
Create a value of LambdaOutput with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:LambdaOutput', lambdaOutput_resourceARN - Amazon Resource Name (ARN) of the destination Lambda function to write
to.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
$sel:roleARN:LambdaOutput', lambdaOutput_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to
the destination function on your behalf. You need to grant the necessary
permissions to this role.
lambdaOutput_resourceARN :: Lens' LambdaOutput Text Source #
Amazon Resource Name (ARN) of the destination Lambda function to write to.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
lambdaOutput_roleARN :: Lens' LambdaOutput Text Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function on your behalf. You need to grant the necessary permissions to this role.
LambdaOutputDescription
data LambdaOutputDescription Source #
For an application output, describes the AWS Lambda function configured as its destination.
See: newLambdaOutputDescription smart constructor.
Constructors
| LambdaOutputDescription' | |
Instances
newLambdaOutputDescription :: LambdaOutputDescription Source #
Create a value of LambdaOutputDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARN:LambdaOutputDescription', lambdaOutputDescription_resourceARN - Amazon Resource Name (ARN) of the destination Lambda function.
$sel:roleARN:LambdaOutputDescription', lambdaOutputDescription_roleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to
the destination function.
lambdaOutputDescription_resourceARN :: Lens' LambdaOutputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the destination Lambda function.
lambdaOutputDescription_roleARN :: Lens' LambdaOutputDescription (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function.
LambdaOutputUpdate
data LambdaOutputUpdate Source #
When updating an output configuration using the UpdateApplication operation, provides information about an AWS Lambda function configured as the destination.
See: newLambdaOutputUpdate smart constructor.
Constructors
| LambdaOutputUpdate' | |
Fields
| |
Instances
newLambdaOutputUpdate :: LambdaOutputUpdate Source #
Create a value of LambdaOutputUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:resourceARNUpdate:LambdaOutputUpdate', lambdaOutputUpdate_resourceARNUpdate - Amazon Resource Name (ARN) of the destination Lambda function.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
$sel:roleARNUpdate:LambdaOutputUpdate', lambdaOutputUpdate_roleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to
the destination function on your behalf. You need to grant the necessary
permissions to this role.
lambdaOutputUpdate_resourceARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the destination Lambda function.
To specify an earlier version of the Lambda function than the latest, include the Lambda function version in the Lambda function ARN. For more information about Lambda ARNs, see Example ARNs: AWS Lambda
lambdaOutputUpdate_roleARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function on your behalf. You need to grant the necessary permissions to this role.
MappingParameters
data MappingParameters Source #
When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
See: newMappingParameters smart constructor.
Constructors
| MappingParameters' | |
Fields
| |
Instances
newMappingParameters :: MappingParameters Source #
Create a value of MappingParameters with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:cSVMappingParameters:MappingParameters', mappingParameters_cSVMappingParameters - Provides additional mapping information when the record format uses
delimiters (for example, CSV).
$sel:jSONMappingParameters:MappingParameters', mappingParameters_jSONMappingParameters - Provides additional mapping information when JSON is the record format
on the streaming source.
mappingParameters_cSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters) Source #
Provides additional mapping information when the record format uses delimiters (for example, CSV).
mappingParameters_jSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters) Source #
Provides additional mapping information when JSON is the record format on the streaming source.
Output
Describes application output configuration in which you identify an in-application stream and a destination where you want the in-application stream data to be written. The destination can be an Amazon Kinesis stream or an Amazon Kinesis Firehose delivery stream.
For limits on how many destinations an application can write and other limitations, see Limits.
See: newOutput smart constructor.
Constructors
| Output' | |
Fields
| |
Instances
Create a value of Output with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:kinesisFirehoseOutput:Output', output_kinesisFirehoseOutput - Identifies an Amazon Kinesis Firehose delivery stream as the
destination.
$sel:kinesisStreamsOutput:Output', output_kinesisStreamsOutput - Identifies an Amazon Kinesis stream as the destination.
$sel:lambdaOutput:Output', output_lambdaOutput - Identifies an AWS Lambda function as the destination.
$sel:name:Output', output_name - Name of the in-application stream.
$sel:destinationSchema:Output', output_destinationSchema - Describes the data format when records are written to the destination.
For more information, see
Configuring Application Output.
output_kinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput) Source #
Identifies an Amazon Kinesis Firehose delivery stream as the destination.
output_kinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput) Source #
Identifies an Amazon Kinesis stream as the destination.
output_lambdaOutput :: Lens' Output (Maybe LambdaOutput) Source #
Identifies an AWS Lambda function as the destination.
output_destinationSchema :: Lens' Output DestinationSchema Source #
Describes the data format when records are written to the destination. For more information, see Configuring Application Output.
OutputDescription
data OutputDescription Source #
Describes the application output configuration, which includes the in-application stream name and the destination where the stream data is written. The destination can be an Amazon Kinesis stream or an Amazon Kinesis Firehose delivery stream.
See: newOutputDescription smart constructor.
Constructors
| OutputDescription' | |
Fields
| |
Instances
newOutputDescription :: OutputDescription Source #
Create a value of OutputDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:destinationSchema:OutputDescription', outputDescription_destinationSchema - Data format used for writing data to the destination.
$sel:kinesisFirehoseOutputDescription:OutputDescription', outputDescription_kinesisFirehoseOutputDescription - Describes the Amazon Kinesis Firehose delivery stream configured as the
destination where output is written.
$sel:kinesisStreamsOutputDescription:OutputDescription', outputDescription_kinesisStreamsOutputDescription - Describes Amazon Kinesis stream configured as the destination where
output is written.
$sel:lambdaOutputDescription:OutputDescription', outputDescription_lambdaOutputDescription - Describes the AWS Lambda function configured as the destination where
output is written.
$sel:name:OutputDescription', outputDescription_name - Name of the in-application stream configured as output.
$sel:outputId:OutputDescription', outputDescription_outputId - A unique identifier for the output configuration.
outputDescription_destinationSchema :: Lens' OutputDescription (Maybe DestinationSchema) Source #
Data format used for writing data to the destination.
outputDescription_kinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription) Source #
Describes the Amazon Kinesis Firehose delivery stream configured as the destination where output is written.
outputDescription_kinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription) Source #
Describes Amazon Kinesis stream configured as the destination where output is written.
outputDescription_lambdaOutputDescription :: Lens' OutputDescription (Maybe LambdaOutputDescription) Source #
Describes the AWS Lambda function configured as the destination where output is written.
outputDescription_name :: Lens' OutputDescription (Maybe Text) Source #
Name of the in-application stream configured as output.
outputDescription_outputId :: Lens' OutputDescription (Maybe Text) Source #
A unique identifier for the output configuration.
OutputUpdate
data OutputUpdate Source #
Describes updates to the output configuration identified by the
OutputId.
See: newOutputUpdate smart constructor.
Constructors
| OutputUpdate' | |
Fields
| |
Instances
Arguments
| :: Text | |
| -> OutputUpdate |
Create a value of OutputUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:destinationSchemaUpdate:OutputUpdate', outputUpdate_destinationSchemaUpdate - Describes the data format when records are written to the destination.
For more information, see
Configuring Application Output.
$sel:kinesisFirehoseOutputUpdate:OutputUpdate', outputUpdate_kinesisFirehoseOutputUpdate - Describes an Amazon Kinesis Firehose delivery stream as the destination
for the output.
$sel:kinesisStreamsOutputUpdate:OutputUpdate', outputUpdate_kinesisStreamsOutputUpdate - Describes an Amazon Kinesis stream as the destination for the output.
$sel:lambdaOutputUpdate:OutputUpdate', outputUpdate_lambdaOutputUpdate - Describes an AWS Lambda function as the destination for the output.
$sel:nameUpdate:OutputUpdate', outputUpdate_nameUpdate - If you want to specify a different in-application stream for this output
configuration, use this field to specify the new in-application stream
name.
$sel:outputId:OutputUpdate', outputUpdate_outputId - Identifies the specific output configuration that you want to update.
outputUpdate_destinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema) Source #
Describes the data format when records are written to the destination. For more information, see Configuring Application Output.
outputUpdate_kinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate) Source #
Describes an Amazon Kinesis Firehose delivery stream as the destination for the output.
outputUpdate_kinesisStreamsOutputUpdate :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate) Source #
Describes an Amazon Kinesis stream as the destination for the output.
outputUpdate_lambdaOutputUpdate :: Lens' OutputUpdate (Maybe LambdaOutputUpdate) Source #
Describes an AWS Lambda function as the destination for the output.
outputUpdate_nameUpdate :: Lens' OutputUpdate (Maybe Text) Source #
If you want to specify a different in-application stream for this output configuration, use this field to specify the new in-application stream name.
outputUpdate_outputId :: Lens' OutputUpdate Text Source #
Identifies the specific output configuration that you want to update.
RecordColumn
data RecordColumn Source #
Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
Also used to describe the format of the reference data source.
See: newRecordColumn smart constructor.
Constructors
| RecordColumn' | |
Fields
| |
Instances
Arguments
| :: Text | |
| -> Text | |
| -> RecordColumn |
Create a value of RecordColumn with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:mapping:RecordColumn', recordColumn_mapping - Reference to the data element in the streaming input or the reference
data source. This element is required if the
RecordFormatType
is JSON.
$sel:name:RecordColumn', recordColumn_name - Name of the column created in the in-application input stream or
reference table.
$sel:sqlType:RecordColumn', recordColumn_sqlType - Type of column created in the in-application input stream or reference
table.
recordColumn_mapping :: Lens' RecordColumn (Maybe Text) Source #
Reference to the data element in the streaming input or the reference
data source. This element is required if the
RecordFormatType
is JSON.
recordColumn_name :: Lens' RecordColumn Text Source #
Name of the column created in the in-application input stream or reference table.
recordColumn_sqlType :: Lens' RecordColumn Text Source #
Type of column created in the in-application input stream or reference table.
RecordFormat
data RecordFormat Source #
Describes the record format and relevant mapping information that should be applied to schematize the records on the stream.
See: newRecordFormat smart constructor.
Constructors
| RecordFormat' | |
Fields
| |
Instances
Create a value of RecordFormat with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:mappingParameters:RecordFormat', recordFormat_mappingParameters - When configuring application input at the time of creating or updating
an application, provides additional mapping information specific to the
record format (such as JSON, CSV, or record fields delimited by some
delimiter) on the streaming source.
$sel:recordFormatType:RecordFormat', recordFormat_recordFormatType - The type of record format.
recordFormat_mappingParameters :: Lens' RecordFormat (Maybe MappingParameters) Source #
When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
recordFormat_recordFormatType :: Lens' RecordFormat RecordFormatType Source #
The type of record format.
ReferenceDataSource
data ReferenceDataSource Source #
Describes the reference data source by providing the source information (S3 bucket name and object key name), the resulting in-application table name that is created, and the necessary schema to map the data elements in the Amazon S3 object to the in-application table.
See: newReferenceDataSource smart constructor.
Constructors
| ReferenceDataSource' | |
Fields
| |
Instances
newReferenceDataSource Source #
Arguments
| :: Text | |
| -> SourceSchema | |
| -> ReferenceDataSource |
Create a value of ReferenceDataSource with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:s3ReferenceDataSource:ReferenceDataSource', referenceDataSource_s3ReferenceDataSource - Identifies the S3 bucket and object that contains the reference data.
Also identifies the IAM role Amazon Kinesis Analytics can assume to read
this object on your behalf. An Amazon Kinesis Analytics application
loads reference data only once. If the data changes, you call the
UpdateApplication operation to trigger reloading of data into your
application.
$sel:tableName:ReferenceDataSource', referenceDataSource_tableName - Name of the in-application table to create.
$sel:referenceSchema:ReferenceDataSource', referenceDataSource_referenceSchema - Describes the format of the data in the streaming source, and how each
data element maps to corresponding columns created in the in-application
stream.
referenceDataSource_s3ReferenceDataSource :: Lens' ReferenceDataSource (Maybe S3ReferenceDataSource) Source #
Identifies the S3 bucket and object that contains the reference data.
Also identifies the IAM role Amazon Kinesis Analytics can assume to read
this object on your behalf. An Amazon Kinesis Analytics application
loads reference data only once. If the data changes, you call the
UpdateApplication operation to trigger reloading of data into your
application.
referenceDataSource_tableName :: Lens' ReferenceDataSource Text Source #
Name of the in-application table to create.
referenceDataSource_referenceSchema :: Lens' ReferenceDataSource SourceSchema Source #
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
ReferenceDataSourceDescription
data ReferenceDataSourceDescription Source #
Describes the reference data source configured for an application.
See: newReferenceDataSourceDescription smart constructor.
Constructors
| ReferenceDataSourceDescription' | |
Fields
| |
Instances
newReferenceDataSourceDescription Source #
Arguments
| :: Text | |
| -> Text | |
| -> S3ReferenceDataSourceDescription |
|
| -> ReferenceDataSourceDescription |
Create a value of ReferenceDataSourceDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:referenceSchema:ReferenceDataSourceDescription', referenceDataSourceDescription_referenceSchema - Describes the format of the data in the streaming source, and how each
data element maps to corresponding columns created in the in-application
stream.
$sel:referenceId:ReferenceDataSourceDescription', referenceDataSourceDescription_referenceId - ID of the reference data source. This is the ID that Amazon Kinesis
Analytics assigns when you add the reference data source to your
application using the
AddApplicationReferenceDataSource
operation.
$sel:tableName:ReferenceDataSourceDescription', referenceDataSourceDescription_tableName - The in-application table name created by the specific reference data
source configuration.
$sel:s3ReferenceDataSourceDescription:ReferenceDataSourceDescription', referenceDataSourceDescription_s3ReferenceDataSourceDescription - Provides the S3 bucket name, the object key name that contains the
reference data. It also provides the Amazon Resource Name (ARN) of the
IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3
object and populate the in-application reference table.
referenceDataSourceDescription_referenceSchema :: Lens' ReferenceDataSourceDescription (Maybe SourceSchema) Source #
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
referenceDataSourceDescription_referenceId :: Lens' ReferenceDataSourceDescription Text Source #
ID of the reference data source. This is the ID that Amazon Kinesis Analytics assigns when you add the reference data source to your application using the AddApplicationReferenceDataSource operation.
referenceDataSourceDescription_tableName :: Lens' ReferenceDataSourceDescription Text Source #
The in-application table name created by the specific reference data source configuration.
referenceDataSourceDescription_s3ReferenceDataSourceDescription :: Lens' ReferenceDataSourceDescription S3ReferenceDataSourceDescription Source #
Provides the S3 bucket name, the object key name that contains the reference data. It also provides the Amazon Resource Name (ARN) of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application reference table.
ReferenceDataSourceUpdate
data ReferenceDataSourceUpdate Source #
When you update a reference data source configuration for an application, this object provides all the updated values (such as the source bucket name and object key name), the in-application table name that is created, and updated mapping information that maps the data in the Amazon S3 object to the in-application reference table that is created.
See: newReferenceDataSourceUpdate smart constructor.
Constructors
| ReferenceDataSourceUpdate' | |
Fields
| |
Instances
newReferenceDataSourceUpdate Source #
Create a value of ReferenceDataSourceUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:referenceSchemaUpdate:ReferenceDataSourceUpdate', referenceDataSourceUpdate_referenceSchemaUpdate - Describes the format of the data in the streaming source, and how each
data element maps to corresponding columns created in the in-application
stream.
$sel:s3ReferenceDataSourceUpdate:ReferenceDataSourceUpdate', referenceDataSourceUpdate_s3ReferenceDataSourceUpdate - Describes the S3 bucket name, object key name, and IAM role that Amazon
Kinesis Analytics can assume to read the Amazon S3 object on your behalf
and populate the in-application reference table.
$sel:tableNameUpdate:ReferenceDataSourceUpdate', referenceDataSourceUpdate_tableNameUpdate - In-application table name that is created by this update.
$sel:referenceId:ReferenceDataSourceUpdate', referenceDataSourceUpdate_referenceId - ID of the reference data source being updated. You can use the
DescribeApplication
operation to get this value.
referenceDataSourceUpdate_referenceSchemaUpdate :: Lens' ReferenceDataSourceUpdate (Maybe SourceSchema) Source #
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
referenceDataSourceUpdate_s3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe S3ReferenceDataSourceUpdate) Source #
Describes the S3 bucket name, object key name, and IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf and populate the in-application reference table.
referenceDataSourceUpdate_tableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text) Source #
In-application table name that is created by this update.
referenceDataSourceUpdate_referenceId :: Lens' ReferenceDataSourceUpdate Text Source #
ID of the reference data source being updated. You can use the DescribeApplication operation to get this value.
S3Configuration
data S3Configuration Source #
Provides a description of an Amazon S3 data source, including the Amazon Resource Name (ARN) of the S3 bucket, the ARN of the IAM role that is used to access the bucket, and the name of the Amazon S3 object that contains the data.
See: newS3Configuration smart constructor.
Constructors
| S3Configuration' | |
Instances
Arguments
| :: Text | |
| -> Text | |
| -> Text | |
| -> S3Configuration |
Create a value of S3Configuration with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:roleARN:S3Configuration', s3Configuration_roleARN - IAM ARN of the role used to access the data.
$sel:bucketARN:S3Configuration', s3Configuration_bucketARN - ARN of the S3 bucket that contains the data.
$sel:fileKey:S3Configuration', s3Configuration_fileKey - The name of the object that contains the data.
s3Configuration_roleARN :: Lens' S3Configuration Text Source #
IAM ARN of the role used to access the data.
s3Configuration_bucketARN :: Lens' S3Configuration Text Source #
ARN of the S3 bucket that contains the data.
s3Configuration_fileKey :: Lens' S3Configuration Text Source #
The name of the object that contains the data.
S3ReferenceDataSource
data S3ReferenceDataSource Source #
Identifies the S3 bucket and object that contains the reference data. Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf.
An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.
See: newS3ReferenceDataSource smart constructor.
Constructors
| S3ReferenceDataSource' | |
Fields
| |
Instances
newS3ReferenceDataSource Source #
Arguments
| :: Text | |
| -> Text | |
| -> Text | |
| -> S3ReferenceDataSource |
Create a value of S3ReferenceDataSource with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:bucketARN:S3ReferenceDataSource', s3ReferenceDataSource_bucketARN - Amazon Resource Name (ARN) of the S3 bucket.
$sel:fileKey:S3ReferenceDataSource', s3ReferenceDataSource_fileKey - Object key name containing reference data.
$sel:referenceRoleARN:S3ReferenceDataSource', s3ReferenceDataSource_referenceRoleARN - ARN of the IAM role that the service can assume to read data on your
behalf. This role must have permission for the s3:GetObject action on
the object and trust policy that allows Amazon Kinesis Analytics service
principal to assume this role.
s3ReferenceDataSource_bucketARN :: Lens' S3ReferenceDataSource Text Source #
Amazon Resource Name (ARN) of the S3 bucket.
s3ReferenceDataSource_fileKey :: Lens' S3ReferenceDataSource Text Source #
Object key name containing reference data.
s3ReferenceDataSource_referenceRoleARN :: Lens' S3ReferenceDataSource Text Source #
ARN of the IAM role that the service can assume to read data on your
behalf. This role must have permission for the s3:GetObject action on
the object and trust policy that allows Amazon Kinesis Analytics service
principal to assume this role.
S3ReferenceDataSourceDescription
data S3ReferenceDataSourceDescription Source #
Provides the bucket name and object key name that stores the reference data.
See: newS3ReferenceDataSourceDescription smart constructor.
Constructors
| S3ReferenceDataSourceDescription' | |
Instances
newS3ReferenceDataSourceDescription Source #
Arguments
| :: Text | |
| -> Text | |
| -> Text | |
| -> S3ReferenceDataSourceDescription |
Create a value of S3ReferenceDataSourceDescription with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:bucketARN:S3ReferenceDataSourceDescription', s3ReferenceDataSourceDescription_bucketARN - Amazon Resource Name (ARN) of the S3 bucket.
$sel:fileKey:S3ReferenceDataSourceDescription', s3ReferenceDataSourceDescription_fileKey - Amazon S3 object key name.
$sel:referenceRoleARN:S3ReferenceDataSourceDescription', s3ReferenceDataSourceDescription_referenceRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to read the
Amazon S3 object on your behalf to populate the in-application reference
table.
s3ReferenceDataSourceDescription_bucketARN :: Lens' S3ReferenceDataSourceDescription Text Source #
Amazon Resource Name (ARN) of the S3 bucket.
s3ReferenceDataSourceDescription_fileKey :: Lens' S3ReferenceDataSourceDescription Text Source #
Amazon S3 object key name.
s3ReferenceDataSourceDescription_referenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf to populate the in-application reference table.
S3ReferenceDataSourceUpdate
data S3ReferenceDataSourceUpdate Source #
Describes the S3 bucket name, object key name, and IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf and populate the in-application reference table.
See: newS3ReferenceDataSourceUpdate smart constructor.
Constructors
| S3ReferenceDataSourceUpdate' | |
Fields
| |
Instances
newS3ReferenceDataSourceUpdate :: S3ReferenceDataSourceUpdate Source #
Create a value of S3ReferenceDataSourceUpdate with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:bucketARNUpdate:S3ReferenceDataSourceUpdate', s3ReferenceDataSourceUpdate_bucketARNUpdate - Amazon Resource Name (ARN) of the S3 bucket.
$sel:fileKeyUpdate:S3ReferenceDataSourceUpdate', s3ReferenceDataSourceUpdate_fileKeyUpdate - Object key name.
$sel:referenceRoleARNUpdate:S3ReferenceDataSourceUpdate', s3ReferenceDataSourceUpdate_referenceRoleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to read the
Amazon S3 object and populate the in-application.
s3ReferenceDataSourceUpdate_bucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the S3 bucket.
s3ReferenceDataSourceUpdate_fileKeyUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) Source #
Object key name.
s3ReferenceDataSourceUpdate_referenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) Source #
ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application.
SourceSchema
data SourceSchema Source #
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
See: newSourceSchema smart constructor.
Constructors
| SourceSchema' | |
Fields
| |
Instances
Arguments
| :: RecordFormat | |
| -> NonEmpty RecordColumn | |
| -> SourceSchema |
Create a value of SourceSchema with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:recordEncoding:SourceSchema', sourceSchema_recordEncoding - Specifies the encoding of the records in the streaming source. For
example, UTF-8.
$sel:recordFormat:SourceSchema', sourceSchema_recordFormat - Specifies the format of the records on the streaming source.
$sel:recordColumns:SourceSchema', sourceSchema_recordColumns - A list of RecordColumn objects.
sourceSchema_recordEncoding :: Lens' SourceSchema (Maybe Text) Source #
Specifies the encoding of the records in the streaming source. For example, UTF-8.
sourceSchema_recordFormat :: Lens' SourceSchema RecordFormat Source #
Specifies the format of the records on the streaming source.
sourceSchema_recordColumns :: Lens' SourceSchema (NonEmpty RecordColumn) Source #
A list of RecordColumn objects.
Tag
A key-value pair (the value is optional) that you can define and assign to AWS resources. If you specify a tag that already exists, the tag value is replaced with the value that you specify in the request. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50. For more information, see Using Tagging.
See: newTag smart constructor.
Constructors
| Tag' | |
Instances
| FromJSON Tag Source # | |
| ToJSON Tag Source # | |
Defined in Amazonka.KinesisAnalytics.Types.Tag | |
| Generic Tag Source # | |
| Read Tag Source # | |
| Show Tag Source # | |
| NFData Tag Source # | |
Defined in Amazonka.KinesisAnalytics.Types.Tag | |
| Eq Tag Source # | |
| Hashable Tag Source # | |
Defined in Amazonka.KinesisAnalytics.Types.Tag | |
| type Rep Tag Source # | |
Defined in Amazonka.KinesisAnalytics.Types.Tag type Rep Tag = D1 ('MetaData "Tag" "Amazonka.KinesisAnalytics.Types.Tag" "amazonka-kinesis-analytics-2.0-7I8X2DEyFUlG6TCxCRLiwg" 'False) (C1 ('MetaCons "Tag'" 'PrefixI 'True) (S1 ('MetaSel ('Just "value") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Text)) :*: S1 ('MetaSel ('Just "key") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Text))) | |
Create a value of Tag with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:value:Tag', tag_value - The value of the key-value tag. The value is optional.
$sel:key:Tag', tag_key - The key of the key-value tag.