Copyright | (c) 2013-2018 Brendan Hay |
---|---|
License | Mozilla Public License, v. 2.0. |
Maintainer | Brendan Hay <brendan.g.hay+amazonka@gmail.com> |
Stability | auto-generated |
Portability | non-portable (GHC extensions) |
Safe Haskell | None |
Language | Haskell2010 |
- 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
- kinesisAnalytics :: Service
- _InvalidApplicationConfigurationException :: AsError a => Getting (First ServiceError) a ServiceError
- _ResourceProvisionedThroughputExceededException :: AsError a => Getting (First ServiceError) a ServiceError
- _InvalidArgumentException :: AsError a => Getting (First ServiceError) a ServiceError
- _CodeValidationException :: AsError a => Getting (First ServiceError) a ServiceError
- _ConcurrentModificationException :: AsError a => Getting (First ServiceError) a ServiceError
- _ServiceUnavailableException :: AsError a => Getting (First ServiceError) a ServiceError
- _UnableToDetectSchemaException :: AsError a => Getting (First ServiceError) a ServiceError
- _ResourceNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError
- _LimitExceededException :: AsError a => Getting (First ServiceError) a ServiceError
- _ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError
- data ApplicationStatus
- data InputStartingPosition
- data RecordFormatType
- data ApplicationDetail
- applicationDetail :: Text -> Text -> ApplicationStatus -> Natural -> ApplicationDetail
- adApplicationDescription :: Lens' ApplicationDetail (Maybe Text)
- adOutputDescriptions :: Lens' ApplicationDetail [OutputDescription]
- adCloudWatchLoggingOptionDescriptions :: Lens' ApplicationDetail [CloudWatchLoggingOptionDescription]
- adReferenceDataSourceDescriptions :: Lens' ApplicationDetail [ReferenceDataSourceDescription]
- adInputDescriptions :: Lens' ApplicationDetail [InputDescription]
- adApplicationCode :: Lens' ApplicationDetail (Maybe Text)
- adCreateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)
- adLastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)
- adApplicationName :: Lens' ApplicationDetail Text
- adApplicationARN :: Lens' ApplicationDetail Text
- adApplicationStatus :: Lens' ApplicationDetail ApplicationStatus
- adApplicationVersionId :: Lens' ApplicationDetail Natural
- data ApplicationSummary
- applicationSummary :: Text -> Text -> ApplicationStatus -> ApplicationSummary
- asApplicationName :: Lens' ApplicationSummary Text
- asApplicationARN :: Lens' ApplicationSummary Text
- asApplicationStatus :: Lens' ApplicationSummary ApplicationStatus
- data ApplicationUpdate
- applicationUpdate :: ApplicationUpdate
- auReferenceDataSourceUpdates :: Lens' ApplicationUpdate [ReferenceDataSourceUpdate]
- auInputUpdates :: Lens' ApplicationUpdate [InputUpdate]
- auCloudWatchLoggingOptionUpdates :: Lens' ApplicationUpdate [CloudWatchLoggingOptionUpdate]
- auOutputUpdates :: Lens' ApplicationUpdate [OutputUpdate]
- auApplicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text)
- data CSVMappingParameters
- csvMappingParameters :: Text -> Text -> CSVMappingParameters
- cmpRecordRowDelimiter :: Lens' CSVMappingParameters Text
- cmpRecordColumnDelimiter :: Lens' CSVMappingParameters Text
- data CloudWatchLoggingOption
- cloudWatchLoggingOption :: Text -> Text -> CloudWatchLoggingOption
- cwloLogStreamARN :: Lens' CloudWatchLoggingOption Text
- cwloRoleARN :: Lens' CloudWatchLoggingOption Text
- data CloudWatchLoggingOptionDescription
- cloudWatchLoggingOptionDescription :: Text -> Text -> CloudWatchLoggingOptionDescription
- cwlodCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionDescription (Maybe Text)
- cwlodLogStreamARN :: Lens' CloudWatchLoggingOptionDescription Text
- cwlodRoleARN :: Lens' CloudWatchLoggingOptionDescription Text
- data CloudWatchLoggingOptionUpdate
- cloudWatchLoggingOptionUpdate :: Text -> CloudWatchLoggingOptionUpdate
- cwlouRoleARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text)
- cwlouLogStreamARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text)
- cwlouCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionUpdate Text
- data DestinationSchema
- destinationSchema :: DestinationSchema
- dsRecordFormatType :: Lens' DestinationSchema (Maybe RecordFormatType)
- data Input
- input :: Text -> SourceSchema -> Input
- iInputParallelism :: Lens' Input (Maybe InputParallelism)
- iInputProcessingConfiguration :: Lens' Input (Maybe InputProcessingConfiguration)
- iKinesisStreamsInput :: Lens' Input (Maybe KinesisStreamsInput)
- iKinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput)
- iNamePrefix :: Lens' Input Text
- iInputSchema :: Lens' Input SourceSchema
- data InputConfiguration
- inputConfiguration :: Text -> InputStartingPositionConfiguration -> InputConfiguration
- icId :: Lens' InputConfiguration Text
- icInputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration
- data InputDescription
- inputDescription :: InputDescription
- idInputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration)
- idInputParallelism :: Lens' InputDescription (Maybe InputParallelism)
- idInputId :: Lens' InputDescription (Maybe Text)
- idInAppStreamNames :: Lens' InputDescription [Text]
- idKinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription)
- idInputSchema :: Lens' InputDescription (Maybe SourceSchema)
- idKinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription)
- idNamePrefix :: Lens' InputDescription (Maybe Text)
- idInputProcessingConfigurationDescription :: Lens' InputDescription (Maybe InputProcessingConfigurationDescription)
- data InputLambdaProcessor
- inputLambdaProcessor :: Text -> Text -> InputLambdaProcessor
- ilpResourceARN :: Lens' InputLambdaProcessor Text
- ilpRoleARN :: Lens' InputLambdaProcessor Text
- data InputLambdaProcessorDescription
- inputLambdaProcessorDescription :: InputLambdaProcessorDescription
- ilpdResourceARN :: Lens' InputLambdaProcessorDescription (Maybe Text)
- ilpdRoleARN :: Lens' InputLambdaProcessorDescription (Maybe Text)
- data InputLambdaProcessorUpdate
- inputLambdaProcessorUpdate :: InputLambdaProcessorUpdate
- ilpuRoleARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)
- ilpuResourceARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)
- data InputParallelism
- inputParallelism :: InputParallelism
- ipCount :: Lens' InputParallelism (Maybe Natural)
- data InputParallelismUpdate
- inputParallelismUpdate :: InputParallelismUpdate
- ipuCountUpdate :: Lens' InputParallelismUpdate (Maybe Natural)
- data InputProcessingConfiguration
- inputProcessingConfiguration :: InputLambdaProcessor -> InputProcessingConfiguration
- ipcInputLambdaProcessor :: Lens' InputProcessingConfiguration InputLambdaProcessor
- data InputProcessingConfigurationDescription
- inputProcessingConfigurationDescription :: InputProcessingConfigurationDescription
- ipcdInputLambdaProcessorDescription :: Lens' InputProcessingConfigurationDescription (Maybe InputLambdaProcessorDescription)
- data InputProcessingConfigurationUpdate
- inputProcessingConfigurationUpdate :: InputLambdaProcessorUpdate -> InputProcessingConfigurationUpdate
- ipcuInputLambdaProcessorUpdate :: Lens' InputProcessingConfigurationUpdate InputLambdaProcessorUpdate
- data InputSchemaUpdate
- inputSchemaUpdate :: InputSchemaUpdate
- isuRecordFormatUpdate :: Lens' InputSchemaUpdate (Maybe RecordFormat)
- isuRecordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text)
- isuRecordColumnUpdates :: Lens' InputSchemaUpdate (Maybe (NonEmpty RecordColumn))
- data InputStartingPositionConfiguration
- inputStartingPositionConfiguration :: InputStartingPositionConfiguration
- ispcInputStartingPosition :: Lens' InputStartingPositionConfiguration (Maybe InputStartingPosition)
- data InputUpdate
- inputUpdate :: Text -> InputUpdate
- iuInputProcessingConfigurationUpdate :: Lens' InputUpdate (Maybe InputProcessingConfigurationUpdate)
- iuKinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate)
- iuInputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate)
- iuNamePrefixUpdate :: Lens' InputUpdate (Maybe Text)
- iuInputSchemaUpdate :: Lens' InputUpdate (Maybe InputSchemaUpdate)
- iuKinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate)
- iuInputId :: Lens' InputUpdate Text
- data JSONMappingParameters
- jsonMappingParameters :: Text -> JSONMappingParameters
- jmpRecordRowPath :: Lens' JSONMappingParameters Text
- data KinesisFirehoseInput
- kinesisFirehoseInput :: Text -> Text -> KinesisFirehoseInput
- kfiResourceARN :: Lens' KinesisFirehoseInput Text
- kfiRoleARN :: Lens' KinesisFirehoseInput Text
- data KinesisFirehoseInputDescription
- kinesisFirehoseInputDescription :: KinesisFirehoseInputDescription
- kfidResourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)
- kfidRoleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)
- data KinesisFirehoseInputUpdate
- kinesisFirehoseInputUpdate :: KinesisFirehoseInputUpdate
- kfiuRoleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)
- kfiuResourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)
- data KinesisFirehoseOutput
- kinesisFirehoseOutput :: Text -> Text -> KinesisFirehoseOutput
- kfoResourceARN :: Lens' KinesisFirehoseOutput Text
- kfoRoleARN :: Lens' KinesisFirehoseOutput Text
- data KinesisFirehoseOutputDescription
- kinesisFirehoseOutputDescription :: KinesisFirehoseOutputDescription
- kfodResourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)
- kfodRoleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)
- data KinesisFirehoseOutputUpdate
- kinesisFirehoseOutputUpdate :: KinesisFirehoseOutputUpdate
- kfouRoleARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)
- kfouResourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)
- data KinesisStreamsInput
- kinesisStreamsInput :: Text -> Text -> KinesisStreamsInput
- ksiResourceARN :: Lens' KinesisStreamsInput Text
- ksiRoleARN :: Lens' KinesisStreamsInput Text
- data KinesisStreamsInputDescription
- kinesisStreamsInputDescription :: KinesisStreamsInputDescription
- ksidResourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text)
- ksidRoleARN :: Lens' KinesisStreamsInputDescription (Maybe Text)
- data KinesisStreamsInputUpdate
- kinesisStreamsInputUpdate :: KinesisStreamsInputUpdate
- ksiuRoleARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)
- ksiuResourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)
- data KinesisStreamsOutput
- kinesisStreamsOutput :: Text -> Text -> KinesisStreamsOutput
- ksoResourceARN :: Lens' KinesisStreamsOutput Text
- ksoRoleARN :: Lens' KinesisStreamsOutput Text
- data KinesisStreamsOutputDescription
- kinesisStreamsOutputDescription :: KinesisStreamsOutputDescription
- ksodResourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)
- ksodRoleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)
- data KinesisStreamsOutputUpdate
- kinesisStreamsOutputUpdate :: KinesisStreamsOutputUpdate
- ksouRoleARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)
- ksouResourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)
- data LambdaOutput
- lambdaOutput :: Text -> Text -> LambdaOutput
- loResourceARN :: Lens' LambdaOutput Text
- loRoleARN :: Lens' LambdaOutput Text
- data LambdaOutputDescription
- lambdaOutputDescription :: LambdaOutputDescription
- lodResourceARN :: Lens' LambdaOutputDescription (Maybe Text)
- lodRoleARN :: Lens' LambdaOutputDescription (Maybe Text)
- data LambdaOutputUpdate
- lambdaOutputUpdate :: LambdaOutputUpdate
- louRoleARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text)
- louResourceARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text)
- data MappingParameters
- mappingParameters :: MappingParameters
- mpCSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters)
- mpJSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters)
- data Output
- output :: Text -> DestinationSchema -> Output
- oLambdaOutput :: Lens' Output (Maybe LambdaOutput)
- oKinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput)
- oKinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput)
- oName :: Lens' Output Text
- oDestinationSchema :: Lens' Output DestinationSchema
- data OutputDescription
- outputDescription :: OutputDescription
- odOutputId :: Lens' OutputDescription (Maybe Text)
- odDestinationSchema :: Lens' OutputDescription (Maybe DestinationSchema)
- odKinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription)
- odKinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription)
- odName :: Lens' OutputDescription (Maybe Text)
- odLambdaOutputDescription :: Lens' OutputDescription (Maybe LambdaOutputDescription)
- data OutputUpdate
- outputUpdate :: Text -> OutputUpdate
- ouKinesisStreamsOutputUpdate :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate)
- ouDestinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema)
- ouKinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate)
- ouNameUpdate :: Lens' OutputUpdate (Maybe Text)
- ouLambdaOutputUpdate :: Lens' OutputUpdate (Maybe LambdaOutputUpdate)
- ouOutputId :: Lens' OutputUpdate Text
- data RecordColumn
- recordColumn :: Text -> Text -> RecordColumn
- rcMapping :: Lens' RecordColumn (Maybe Text)
- rcName :: Lens' RecordColumn Text
- rcSqlType :: Lens' RecordColumn Text
- data RecordFormat
- recordFormat :: RecordFormatType -> RecordFormat
- rfMappingParameters :: Lens' RecordFormat (Maybe MappingParameters)
- rfRecordFormatType :: Lens' RecordFormat RecordFormatType
- data ReferenceDataSource
- referenceDataSource :: Text -> SourceSchema -> ReferenceDataSource
- rdsS3ReferenceDataSource :: Lens' ReferenceDataSource (Maybe S3ReferenceDataSource)
- rdsTableName :: Lens' ReferenceDataSource Text
- rdsReferenceSchema :: Lens' ReferenceDataSource SourceSchema
- data ReferenceDataSourceDescription
- referenceDataSourceDescription :: Text -> Text -> S3ReferenceDataSourceDescription -> ReferenceDataSourceDescription
- rdsdReferenceSchema :: Lens' ReferenceDataSourceDescription (Maybe SourceSchema)
- rdsdReferenceId :: Lens' ReferenceDataSourceDescription Text
- rdsdTableName :: Lens' ReferenceDataSourceDescription Text
- rdsdS3ReferenceDataSourceDescription :: Lens' ReferenceDataSourceDescription S3ReferenceDataSourceDescription
- data ReferenceDataSourceUpdate
- referenceDataSourceUpdate :: Text -> ReferenceDataSourceUpdate
- rdsuTableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text)
- rdsuS3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe S3ReferenceDataSourceUpdate)
- rdsuReferenceSchemaUpdate :: Lens' ReferenceDataSourceUpdate (Maybe SourceSchema)
- rdsuReferenceId :: Lens' ReferenceDataSourceUpdate Text
- data S3Configuration
- s3Configuration :: Text -> Text -> Text -> S3Configuration
- scRoleARN :: Lens' S3Configuration Text
- scBucketARN :: Lens' S3Configuration Text
- scFileKey :: Lens' S3Configuration Text
- data S3ReferenceDataSource
- s3ReferenceDataSource :: Text -> Text -> Text -> S3ReferenceDataSource
- srdsBucketARN :: Lens' S3ReferenceDataSource Text
- srdsFileKey :: Lens' S3ReferenceDataSource Text
- srdsReferenceRoleARN :: Lens' S3ReferenceDataSource Text
- data S3ReferenceDataSourceDescription
- s3ReferenceDataSourceDescription :: Text -> Text -> Text -> S3ReferenceDataSourceDescription
- srdsdBucketARN :: Lens' S3ReferenceDataSourceDescription Text
- srdsdFileKey :: Lens' S3ReferenceDataSourceDescription Text
- srdsdReferenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text
- data S3ReferenceDataSourceUpdate
- s3ReferenceDataSourceUpdate :: S3ReferenceDataSourceUpdate
- srdsuBucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)
- srdsuFileKeyUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)
- srdsuReferenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)
- data SourceSchema
- sourceSchema :: RecordFormat -> NonEmpty RecordColumn -> SourceSchema
- ssRecordEncoding :: Lens' SourceSchema (Maybe Text)
- ssRecordFormat :: Lens' SourceSchema RecordFormat
- ssRecordColumns :: Lens' SourceSchema (NonEmpty RecordColumn)
Service Configuration
kinesisAnalytics :: Service Source #
API version 2015-08-14
of the Amazon Kinesis Analytics SDK configuration.
Errors
_InvalidApplicationConfigurationException :: AsError a => Getting (First ServiceError) a ServiceError Source #
User-provided application configuration is not valid.
_ResourceProvisionedThroughputExceededException :: AsError a => Getting (First ServiceError) 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.
_InvalidArgumentException :: AsError a => Getting (First ServiceError) a ServiceError Source #
Specified input parameter value is invalid.
_CodeValidationException :: AsError a => Getting (First ServiceError) a ServiceError Source #
User-provided application code (query) is invalid. This can be a simple syntax error.
_ConcurrentModificationException :: AsError a => Getting (First ServiceError) 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.
_ServiceUnavailableException :: AsError a => Getting (First ServiceError) a ServiceError Source #
The service is unavailable, back off and retry the operation.
_UnableToDetectSchemaException :: AsError a => Getting (First ServiceError) a ServiceError Source #
Data format is not valid, Amazon Kinesis Analytics is not able to detect schema for the given streaming source.
_ResourceNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError Source #
Specified application can't be found.
_LimitExceededException :: AsError a => Getting (First ServiceError) a ServiceError Source #
Exceeded the number of applications allowed.
_ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError Source #
Application is not available for this operation.
ApplicationStatus
data ApplicationStatus Source #
InputStartingPosition
data InputStartingPosition Source #
RecordFormatType
data RecordFormatType Source #
ApplicationDetail
data ApplicationDetail Source #
Provides a description of the application, including the application Amazon Resource Name (ARN), status, latest version, and input and output configuration.
See: applicationDetail
smart constructor.
:: Text | |
-> Text | |
-> ApplicationStatus | |
-> Natural | |
-> ApplicationDetail |
Creates a value of ApplicationDetail
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
adApplicationDescription
- Description of the application.adOutputDescriptions
- Describes the application output configuration. For more information, see Configuring Application Output .adCloudWatchLoggingOptionDescriptions
- 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 .adReferenceDataSourceDescriptions
- Describes reference data sources configured for the application. For more information, see Configuring Application Input .adInputDescriptions
- Describes the application input configuration. For more information, see Configuring Application Input .adApplicationCode
- Returns the application code that you provided to perform data analysis on any of the in-application streams in your application.adCreateTimestamp
- Time stamp when the application version was created.adLastUpdateTimestamp
- Time stamp when the application was last updated.adApplicationName
- Name of the application.adApplicationARN
- ARN of the application.adApplicationStatus
- Status of the application.adApplicationVersionId
- Provides the current application version.
adApplicationDescription :: Lens' ApplicationDetail (Maybe Text) Source #
Description of the application.
adOutputDescriptions :: Lens' ApplicationDetail [OutputDescription] Source #
Describes the application output configuration. For more information, see Configuring Application Output .
adCloudWatchLoggingOptionDescriptions :: Lens' ApplicationDetail [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 .
adReferenceDataSourceDescriptions :: Lens' ApplicationDetail [ReferenceDataSourceDescription] Source #
Describes reference data sources configured for the application. For more information, see Configuring Application Input .
adInputDescriptions :: Lens' ApplicationDetail [InputDescription] Source #
Describes the application input configuration. For more information, see Configuring Application Input .
adApplicationCode :: 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.
adCreateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime) Source #
Time stamp when the application version was created.
adLastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime) Source #
Time stamp when the application was last updated.
adApplicationName :: Lens' ApplicationDetail Text Source #
Name of the application.
adApplicationARN :: Lens' ApplicationDetail Text Source #
ARN of the application.
adApplicationStatus :: Lens' ApplicationDetail ApplicationStatus Source #
Status of the application.
adApplicationVersionId :: Lens' ApplicationDetail Natural Source #
Provides the current application version.
ApplicationSummary
data ApplicationSummary Source #
Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.
See: applicationSummary
smart constructor.
:: Text | |
-> Text | |
-> ApplicationStatus | |
-> ApplicationSummary |
Creates a value of ApplicationSummary
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
asApplicationName
- Name of the application.asApplicationARN
- ARN of the application.asApplicationStatus
- Status of the application.
asApplicationName :: Lens' ApplicationSummary Text Source #
Name of the application.
asApplicationARN :: Lens' ApplicationSummary Text Source #
ARN of the application.
asApplicationStatus :: Lens' ApplicationSummary ApplicationStatus Source #
Status of the application.
ApplicationUpdate
data ApplicationUpdate Source #
Describes updates to apply to an existing Amazon Kinesis Analytics application.
See: applicationUpdate
smart constructor.
applicationUpdate :: ApplicationUpdate Source #
Creates a value of ApplicationUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
auReferenceDataSourceUpdates
- Describes application reference data source updates.auInputUpdates
- Describes application input configuration updates.auCloudWatchLoggingOptionUpdates
- Describes application CloudWatch logging option updates.auOutputUpdates
- Describes application output configuration updates.auApplicationCodeUpdate
- Describes application code updates.
auReferenceDataSourceUpdates :: Lens' ApplicationUpdate [ReferenceDataSourceUpdate] Source #
Describes application reference data source updates.
auInputUpdates :: Lens' ApplicationUpdate [InputUpdate] Source #
Describes application input configuration updates.
auCloudWatchLoggingOptionUpdates :: Lens' ApplicationUpdate [CloudWatchLoggingOptionUpdate] Source #
Describes application CloudWatch logging option updates.
auOutputUpdates :: Lens' ApplicationUpdate [OutputUpdate] Source #
Describes application output configuration updates.
auApplicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text) Source #
Describes application code 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: csvMappingParameters
smart constructor.
Creates a value of CSVMappingParameters
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
cmpRecordRowDelimiter
- Row delimiter. For example, in a CSV format, '\n' is the typical row delimiter.cmpRecordColumnDelimiter
- Column delimiter. For example, in a CSV format, a comma (",") is the typical column delimiter.
cmpRecordRowDelimiter :: Lens' CSVMappingParameters Text Source #
Row delimiter. For example, in a CSV format, '\n' is the typical row delimiter.
cmpRecordColumnDelimiter :: 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: cloudWatchLoggingOption
smart constructor.
cloudWatchLoggingOption Source #
Creates a value of CloudWatchLoggingOption
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
cwloLogStreamARN
- ARN of the CloudWatch log to receive application messages.cwloRoleARN
- 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 thePutLogEvents
policy action enabled.
cwloLogStreamARN :: Lens' CloudWatchLoggingOption Text Source #
ARN of the CloudWatch log to receive application messages.
cwloRoleARN :: 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: cloudWatchLoggingOptionDescription
smart constructor.
cloudWatchLoggingOptionDescription Source #
Creates a value of CloudWatchLoggingOptionDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
cwlodCloudWatchLoggingOptionId
- ID of the CloudWatch logging option description.cwlodLogStreamARN
- ARN of the CloudWatch log to receive application messages.cwlodRoleARN
- IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role used must have thePutLogEvents
policy action enabled.
cwlodCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionDescription (Maybe Text) Source #
ID of the CloudWatch logging option description.
cwlodLogStreamARN :: Lens' CloudWatchLoggingOptionDescription Text Source #
ARN of the CloudWatch log to receive application messages.
cwlodRoleARN :: 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: cloudWatchLoggingOptionUpdate
smart constructor.
cloudWatchLoggingOptionUpdate Source #
Creates a value of CloudWatchLoggingOptionUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
cwlouRoleARNUpdate
- IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role used must have thePutLogEvents
policy action enabled.cwlouLogStreamARNUpdate
- ARN of the CloudWatch log to receive application messages.cwlouCloudWatchLoggingOptionId
- ID of the CloudWatch logging option to update
cwlouRoleARNUpdate :: 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.
cwlouLogStreamARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text) Source #
ARN of the CloudWatch log to receive application messages.
cwlouCloudWatchLoggingOptionId :: 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: destinationSchema
smart constructor.
destinationSchema :: DestinationSchema Source #
Creates a value of DestinationSchema
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
dsRecordFormatType
- Specifies the format of the records on the output stream.
dsRecordFormatType :: Lens' DestinationSchema (Maybe 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: input
smart constructor.
Creates a value of Input
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
iInputParallelism
- 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 .iInputProcessingConfiguration
- TheInputProcessingConfiguration
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 isInputLambdaProcessor
.iKinesisStreamsInput
- 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: EitherKinesisStreamsInput
orKinesisFirehoseInput
is required.iKinesisFirehoseInput
- 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: EitherKinesisStreamsInput
orKinesisFirehoseInput
is required.iNamePrefix
- 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 theInputParallelism
count you specified) in-application streams with names "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.iInputSchema
- 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.
iInputParallelism :: 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. (see Configuring Application Input .
iInputProcessingConfiguration :: 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
.
iKinesisStreamsInput :: 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.
iKinesisFirehoseInput :: 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.
iNamePrefix :: 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.
iInputSchema :: 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: inputConfiguration
smart constructor.
Creates a value of InputConfiguration
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
icId
- Input source ID. You can get this ID by calling theDescribeApplication
operation.icInputStartingPositionConfiguration
- Point at which you want the application to start processing records from the streaming source.
icId :: Lens' InputConfiguration Text Source #
Input source ID. You can get this ID by calling the DescribeApplication
operation.
icInputStartingPositionConfiguration :: 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: inputDescription
smart constructor.
inputDescription :: InputDescription Source #
Creates a value of InputDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
idInputStartingPositionConfiguration
- Point at which the application is configured to read from the input stream.idInputParallelism
- Describes the configured parallelism (number of in-application streams mapped to the streaming source).idInputId
- 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.idInAppStreamNames
- Returns the in-application stream names that are mapped to the stream source.idKinesisFirehoseInputDescription
- 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.idInputSchema
- 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.idKinesisStreamsInputDescription
- 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.idNamePrefix
- In-application name prefix.idInputProcessingConfigurationDescription
- The description of the preprocessor that executes on records in this input before the application's code is run.
idInputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration) Source #
Point at which the application is configured to read from the input stream.
idInputParallelism :: Lens' InputDescription (Maybe InputParallelism) Source #
Describes the configured parallelism (number of in-application streams mapped to the streaming source).
idInputId :: 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.
idInAppStreamNames :: Lens' InputDescription [Text] Source #
Returns the in-application stream names that are mapped to the stream source.
idKinesisFirehoseInputDescription :: 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.
idInputSchema :: 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.
idKinesisStreamsInputDescription :: 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.
idNamePrefix :: Lens' InputDescription (Maybe Text) Source #
In-application name prefix.
idInputProcessingConfigurationDescription :: Lens' InputDescription (Maybe InputProcessingConfigurationDescription) Source #
The description of the preprocessor that executes on records in this input before the application's code is run.
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: inputLambdaProcessor
smart constructor.
Creates a value of InputLambdaProcessor
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ilpResourceARN
- The ARN of the AWS Lambda function that operates on records in the stream.ilpRoleARN
- The ARN of the IAM role that is used to access the AWS Lambda function.
ilpResourceARN :: Lens' InputLambdaProcessor Text Source #
The ARN of the AWS Lambda function that operates on records in the stream.
ilpRoleARN :: 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: inputLambdaProcessorDescription
smart constructor.
inputLambdaProcessorDescription :: InputLambdaProcessorDescription Source #
Creates a value of InputLambdaProcessorDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ilpdResourceARN
- The ARN of the AWS Lambda function that is used to preprocess the records in the stream.ilpdRoleARN
- The ARN of the IAM role that is used to access the AWS Lambda function.
ilpdResourceARN :: Lens' InputLambdaProcessorDescription (Maybe Text) Source #
The ARN of the AWS Lambda function that is used to preprocess the records in the stream.
ilpdRoleARN :: 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: inputLambdaProcessorUpdate
smart constructor.
inputLambdaProcessorUpdate :: InputLambdaProcessorUpdate Source #
Creates a value of InputLambdaProcessorUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ilpuRoleARNUpdate
- The ARN of the new IAM role that is used to access the AWS Lambda function.ilpuResourceARNUpdate
- The Amazon Resource Name (ARN) of the new AWS Lambda function that is used to preprocess the records in the stream.
ilpuRoleARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text) Source #
The ARN of the new IAM role that is used to access the AWS Lambda function.
ilpuResourceARNUpdate :: 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.
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: inputParallelism
smart constructor.
inputParallelism :: InputParallelism Source #
Creates a value of InputParallelism
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ipCount :: 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: inputParallelismUpdate
smart constructor.
inputParallelismUpdate :: InputParallelismUpdate Source #
Creates a value of InputParallelismUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ipuCountUpdate
- Number of in-application streams to create for the specified streaming source.
ipuCountUpdate :: 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: inputProcessingConfiguration
smart constructor.
inputProcessingConfiguration Source #
Creates a value of InputProcessingConfiguration
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ipcInputLambdaProcessor
- TheInputLambdaProcessor
that is used to preprocess the records in the stream before being processed by your application code.
ipcInputLambdaProcessor :: 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: inputProcessingConfigurationDescription
smart constructor.
inputProcessingConfigurationDescription :: InputProcessingConfigurationDescription Source #
Creates a value of InputProcessingConfigurationDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ipcdInputLambdaProcessorDescription
- Provides configuration information about the associatedInputLambdaProcessorDescription
.
ipcdInputLambdaProcessorDescription :: Lens' InputProcessingConfigurationDescription (Maybe InputLambdaProcessorDescription) Source #
Provides configuration information about the associated InputLambdaProcessorDescription
.
InputProcessingConfigurationUpdate
data InputProcessingConfigurationUpdate Source #
Describes updates to an InputProcessingConfiguration
.
See: inputProcessingConfigurationUpdate
smart constructor.
inputProcessingConfigurationUpdate Source #
Creates a value of InputProcessingConfigurationUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ipcuInputLambdaProcessorUpdate
- Provides update information for anInputLambdaProcessor
.
ipcuInputLambdaProcessorUpdate :: Lens' InputProcessingConfigurationUpdate InputLambdaProcessorUpdate Source #
Provides update information for an InputLambdaProcessor
.
InputSchemaUpdate
data InputSchemaUpdate Source #
Describes updates for the application's input schema.
See: inputSchemaUpdate
smart constructor.
inputSchemaUpdate :: InputSchemaUpdate Source #
Creates a value of InputSchemaUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
isuRecordFormatUpdate
- Specifies the format of the records on the streaming source.isuRecordEncodingUpdate
- Specifies the encoding of the records in the streaming source. For example, UTF-8.isuRecordColumnUpdates
- A list ofRecordColumn
objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.
isuRecordFormatUpdate :: Lens' InputSchemaUpdate (Maybe RecordFormat) Source #
Specifies the format of the records on the streaming source.
isuRecordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text) Source #
Specifies the encoding of the records in the streaming source. For example, UTF-8.
isuRecordColumnUpdates :: 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.
InputStartingPositionConfiguration
data InputStartingPositionConfiguration Source #
Describes the point at which the application reads from the streaming source.
See: inputStartingPositionConfiguration
smart constructor.
inputStartingPositionConfiguration :: InputStartingPositionConfiguration Source #
Creates a value of InputStartingPositionConfiguration
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ispcInputStartingPosition
- 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.
ispcInputStartingPosition :: 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: inputUpdate
smart constructor.
:: Text | |
-> InputUpdate |
Creates a value of InputUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
iuInputProcessingConfigurationUpdate
- Describes updates for an input processing configuration.iuKinesisStreamsInputUpdate
- If an Amazon Kinesis stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN) and IAM role ARN.iuInputParallelismUpdate
- Describes the parallelism updates (the number in-application streams Amazon Kinesis Analytics creates for the specific streaming source).iuNamePrefixUpdate
- Name prefix for in-application streams that Amazon Kinesis Analytics creates for the specific streaming source.iuInputSchemaUpdate
- 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.iuKinesisFirehoseInputUpdate
- If an Amazon Kinesis Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.iuInputId
- Input ID of the application input to be updated.
iuInputProcessingConfigurationUpdate :: Lens' InputUpdate (Maybe InputProcessingConfigurationUpdate) Source #
Describes updates for an input processing configuration.
iuKinesisStreamsInputUpdate :: 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.
iuInputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate) Source #
Describes the parallelism updates (the number in-application streams Amazon Kinesis Analytics creates for the specific streaming source).
iuNamePrefixUpdate :: Lens' InputUpdate (Maybe Text) Source #
Name prefix for in-application streams that Amazon Kinesis Analytics creates for the specific streaming source.
iuInputSchemaUpdate :: 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.
iuKinesisFirehoseInputUpdate :: 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.
JSONMappingParameters
data JSONMappingParameters Source #
Provides additional mapping information when JSON is the record format on the streaming source.
See: jsonMappingParameters
smart constructor.
jsonMappingParameters Source #
Creates a value of JSONMappingParameters
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
jmpRecordRowPath
- Path to the top-level parent that contains the records.
jmpRecordRowPath :: 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: kinesisFirehoseInput
smart constructor.
Creates a value of KinesisFirehoseInput
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
kfiResourceARN
- ARN of the input delivery stream.kfiRoleARN
- ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to make sure the role has necessary permissions to access the stream.
kfiResourceARN :: Lens' KinesisFirehoseInput Text Source #
ARN of the input delivery stream.
kfiRoleARN :: 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 the role has 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: kinesisFirehoseInputDescription
smart constructor.
kinesisFirehoseInputDescription :: KinesisFirehoseInputDescription Source #
Creates a value of KinesisFirehoseInputDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
kfidResourceARN
- Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.kfidRoleARN
- ARN of the IAM role that Amazon Kinesis Analytics assumes to access the stream.
kfidResourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.
kfidRoleARN :: 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: kinesisFirehoseInputUpdate
smart constructor.
kinesisFirehoseInputUpdate :: KinesisFirehoseInputUpdate Source #
Creates a value of KinesisFirehoseInputUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
kfiuRoleARNUpdate
- ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant necessary permissions to this role.kfiuResourceARNUpdate
- Amazon Resource Name (ARN) of the input Amazon Kinesis Firehose delivery stream to read.
kfiuRoleARNUpdate :: 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 necessary permissions to this role.
kfiuResourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the input Amazon Kinesis Firehose delivery stream to read.
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: kinesisFirehoseOutput
smart constructor.
kinesisFirehoseOutput Source #
Creates a value of KinesisFirehoseOutput
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
kfoResourceARN
- ARN of the destination Amazon Kinesis Firehose delivery stream to write to.kfoRoleARN
- 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.
kfoResourceARN :: Lens' KinesisFirehoseOutput Text Source #
ARN of the destination Amazon Kinesis Firehose delivery stream to write to.
kfoRoleARN :: 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: kinesisFirehoseOutputDescription
smart constructor.
kinesisFirehoseOutputDescription :: KinesisFirehoseOutputDescription Source #
Creates a value of KinesisFirehoseOutputDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
kfodResourceARN
- Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.kfodRoleARN
- ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.
kfodResourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.
kfodRoleARN :: 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: kinesisFirehoseOutputUpdate
smart constructor.
kinesisFirehoseOutputUpdate :: KinesisFirehoseOutputUpdate Source #
Creates a value of KinesisFirehoseOutputUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
kfouRoleARNUpdate
- ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant necessary permissions to this role.kfouResourceARNUpdate
- Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream to write to.
kfouRoleARNUpdate :: 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 necessary permissions to this role.
kfouResourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream to write to.
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: kinesisStreamsInput
smart constructor.
Creates a value of KinesisStreamsInput
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ksiResourceARN
- ARN of the input Amazon Kinesis stream to read.ksiRoleARN
- 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.
ksiResourceARN :: Lens' KinesisStreamsInput Text Source #
ARN of the input Amazon Kinesis stream to read.
ksiRoleARN :: 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: kinesisStreamsInputDescription
smart constructor.
kinesisStreamsInputDescription :: KinesisStreamsInputDescription Source #
Creates a value of KinesisStreamsInputDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ksidResourceARN
- Amazon Resource Name (ARN) of the Amazon Kinesis stream.ksidRoleARN
- ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.
ksidResourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis stream.
ksidRoleARN :: 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: kinesisStreamsInputUpdate
smart constructor.
kinesisStreamsInputUpdate :: KinesisStreamsInputUpdate Source #
Creates a value of KinesisStreamsInputUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ksiuRoleARNUpdate
- 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.ksiuResourceARNUpdate
- Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.
ksiuRoleARNUpdate :: 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.
ksiuResourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.
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: kinesisStreamsOutput
smart constructor.
Creates a value of KinesisStreamsOutput
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ksoResourceARN
- ARN of the destination Amazon Kinesis stream to write to.ksoRoleARN
- 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.
ksoResourceARN :: Lens' KinesisStreamsOutput Text Source #
ARN of the destination Amazon Kinesis stream to write to.
ksoRoleARN :: 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: kinesisStreamsOutputDescription
smart constructor.
kinesisStreamsOutputDescription :: KinesisStreamsOutputDescription Source #
Creates a value of KinesisStreamsOutputDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ksodResourceARN
- Amazon Resource Name (ARN) of the Amazon Kinesis stream.ksodRoleARN
- ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.
ksodResourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis stream.
ksodRoleARN :: 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: kinesisStreamsOutputUpdate
smart constructor.
kinesisStreamsOutputUpdate :: KinesisStreamsOutputUpdate Source #
Creates a value of KinesisStreamsOutputUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ksouRoleARNUpdate
- 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.ksouResourceARNUpdate
- Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want to write the output.
ksouRoleARNUpdate :: 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.
ksouResourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want to write the output.
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: lambdaOutput
smart constructor.
Creates a value of LambdaOutput
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
loResourceARN
- Amazon Resource Name (ARN) of the destination Lambda function to write to.loRoleARN
- 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.
loResourceARN :: Lens' LambdaOutput Text Source #
Amazon Resource Name (ARN) of the destination Lambda function to write to.
loRoleARN :: 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: lambdaOutputDescription
smart constructor.
lambdaOutputDescription :: LambdaOutputDescription Source #
Creates a value of LambdaOutputDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
lodResourceARN
- Amazon Resource Name (ARN) of the destination Lambda function.lodRoleARN
- ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function.
lodResourceARN :: Lens' LambdaOutputDescription (Maybe Text) Source #
Amazon Resource Name (ARN) of the destination Lambda function.
lodRoleARN :: 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: lambdaOutputUpdate
smart constructor.
lambdaOutputUpdate :: LambdaOutputUpdate Source #
Creates a value of LambdaOutputUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
louRoleARNUpdate
- 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.louResourceARNUpdate
- Amazon Resource Name (ARN) of the destination Lambda function.
louRoleARNUpdate :: 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.
louResourceARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the destination Lambda function.
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: mappingParameters
smart constructor.
mappingParameters :: MappingParameters Source #
Creates a value of MappingParameters
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
mpCSVMappingParameters
- Provides additional mapping information when the record format uses delimiters (for example, CSV).mpJSONMappingParameters
- Provides additional mapping information when JSON is the record format on the streaming source.
mpCSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters) Source #
Provides additional mapping information when the record format uses delimiters (for example, CSV).
mpJSONMappingParameters :: 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: output
smart constructor.
Creates a value of Output
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
oLambdaOutput
- Identifies an AWS Lambda function as the destination.oKinesisStreamsOutput
- Identifies an Amazon Kinesis stream as the destination.oKinesisFirehoseOutput
- Identifies an Amazon Kinesis Firehose delivery stream as the destination.oName
- Name of the in-application stream.oDestinationSchema
- Describes the data format when records are written to the destination. For more information, see Configuring Application Output .
oLambdaOutput :: Lens' Output (Maybe LambdaOutput) Source #
Identifies an AWS Lambda function as the destination.
oKinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput) Source #
Identifies an Amazon Kinesis stream as the destination.
oKinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput) Source #
Identifies an Amazon Kinesis Firehose delivery stream as the destination.
oDestinationSchema :: 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: outputDescription
smart constructor.
outputDescription :: OutputDescription Source #
Creates a value of OutputDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
odOutputId
- A unique identifier for the output configuration.odDestinationSchema
- Data format used for writing data to the destination.odKinesisFirehoseOutputDescription
- Describes the Amazon Kinesis Firehose delivery stream configured as the destination where output is written.odKinesisStreamsOutputDescription
- Describes Amazon Kinesis stream configured as the destination where output is written.odName
- Name of the in-application stream configured as output.odLambdaOutputDescription
- Describes the AWS Lambda function configured as the destination where output is written.
odOutputId :: Lens' OutputDescription (Maybe Text) Source #
A unique identifier for the output configuration.
odDestinationSchema :: Lens' OutputDescription (Maybe DestinationSchema) Source #
Data format used for writing data to the destination.
odKinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription) Source #
Describes the Amazon Kinesis Firehose delivery stream configured as the destination where output is written.
odKinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription) Source #
Describes Amazon Kinesis stream configured as the destination where output is written.
odName :: Lens' OutputDescription (Maybe Text) Source #
Name of the in-application stream configured as output.
odLambdaOutputDescription :: Lens' OutputDescription (Maybe LambdaOutputDescription) Source #
Describes the AWS Lambda function configured as the destination where output is written.
OutputUpdate
data OutputUpdate Source #
Describes updates to the output configuration identified by the OutputId
.
See: outputUpdate
smart constructor.
Creates a value of OutputUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ouKinesisStreamsOutputUpdate
- Describes an Amazon Kinesis stream as the destination for the output.ouDestinationSchemaUpdate
- Describes the data format when records are written to the destination. For more information, see Configuring Application Output .ouKinesisFirehoseOutputUpdate
- Describes an Amazon Kinesis Firehose delivery stream as the destination for the output.ouNameUpdate
- 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.ouLambdaOutputUpdate
- Describes an AWS Lambda function as the destination for the output.ouOutputId
- Identifies the specific output configuration that you want to update.
ouKinesisStreamsOutputUpdate :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate) Source #
Describes an Amazon Kinesis stream as the destination for the output.
ouDestinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema) Source #
Describes the data format when records are written to the destination. For more information, see Configuring Application Output .
ouKinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate) Source #
Describes an Amazon Kinesis Firehose delivery stream as the destination for the output.
ouNameUpdate :: 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.
ouLambdaOutputUpdate :: Lens' OutputUpdate (Maybe LambdaOutputUpdate) Source #
Describes an AWS Lambda function as the destination for the output.
ouOutputId :: 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: recordColumn
smart constructor.
:: Text | |
-> Text | |
-> RecordColumn |
Creates a value of RecordColumn
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
rcMapping :: Lens' RecordColumn (Maybe Text) Source #
Reference to the data element in the streaming input of the reference data source.
rcName :: Lens' RecordColumn Text Source #
Name of the column created in the in-application input stream or reference table.
rcSqlType :: 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: recordFormat
smart constructor.
Creates a value of RecordFormat
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
rfMappingParameters
- 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.rfRecordFormatType
- The type of record format.
rfMappingParameters :: 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.
rfRecordFormatType :: 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: referenceDataSource
smart constructor.
Creates a value of ReferenceDataSource
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
rdsS3ReferenceDataSource
- 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 theUpdateApplication
operation to trigger reloading of data into your application.rdsTableName
- Name of the in-application table to create.rdsReferenceSchema
- 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.
rdsS3ReferenceDataSource :: 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.
rdsTableName :: Lens' ReferenceDataSource Text Source #
Name of the in-application table to create.
rdsReferenceSchema :: 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: referenceDataSourceDescription
smart constructor.
referenceDataSourceDescription Source #
Creates a value of ReferenceDataSourceDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
rdsdReferenceSchema
- 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.rdsdReferenceId
- 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 theAddApplicationReferenceDataSource
operation.rdsdTableName
- The in-application table name created by the specific reference data source configuration.rdsdS3ReferenceDataSourceDescription
- 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.
rdsdReferenceSchema :: 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.
rdsdReferenceId :: 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.
rdsdTableName :: Lens' ReferenceDataSourceDescription Text Source #
The in-application table name created by the specific reference data source configuration.
rdsdS3ReferenceDataSourceDescription :: 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: referenceDataSourceUpdate
smart constructor.
referenceDataSourceUpdate Source #
Creates a value of ReferenceDataSourceUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
rdsuTableNameUpdate
- In-application table name that is created by this update.rdsuS3ReferenceDataSourceUpdate
- 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.rdsuReferenceSchemaUpdate
- 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.rdsuReferenceId
- ID of the reference data source being updated. You can use theDescribeApplication
operation to get this value.
rdsuTableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text) Source #
In-application table name that is created by this update.
rdsuS3ReferenceDataSourceUpdate :: 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.
rdsuReferenceSchemaUpdate :: 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.
rdsuReferenceId :: 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 S3 object that contains the data.
See: s3Configuration
smart constructor.
Creates a value of S3Configuration
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
scRoleARN
- IAM ARN of the role used to access the data.scBucketARN
- ARN of the S3 bucket that contains the data.scFileKey
- The name of the object that contains the data.
scBucketARN :: Lens' S3Configuration Text Source #
ARN of the S3 bucket 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: s3ReferenceDataSource
smart constructor.
s3ReferenceDataSource Source #
Creates a value of S3ReferenceDataSource
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
srdsBucketARN
- Amazon Resource Name (ARN) of the S3 bucket.srdsFileKey
- Object key name containing reference data.srdsReferenceRoleARN
- ARN of the IAM role that the service can assume to read data on your behalf. This role must have permission for thes3:GetObject
action on the object and trust policy that allows Amazon Kinesis Analytics service principal to assume this role.
srdsBucketARN :: Lens' S3ReferenceDataSource Text Source #
Amazon Resource Name (ARN) of the S3 bucket.
srdsFileKey :: Lens' S3ReferenceDataSource Text Source #
Object key name containing reference data.
srdsReferenceRoleARN :: 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: s3ReferenceDataSourceDescription
smart constructor.
s3ReferenceDataSourceDescription Source #
:: Text | |
-> Text | |
-> Text | |
-> S3ReferenceDataSourceDescription |
Creates a value of S3ReferenceDataSourceDescription
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
srdsdBucketARN
- Amazon Resource Name (ARN) of the S3 bucket.srdsdFileKey
- Amazon S3 object key name.srdsdReferenceRoleARN
- 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.
srdsdBucketARN :: Lens' S3ReferenceDataSourceDescription Text Source #
Amazon Resource Name (ARN) of the S3 bucket.
srdsdFileKey :: Lens' S3ReferenceDataSourceDescription Text Source #
Amazon S3 object key name.
srdsdReferenceRoleARN :: 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: s3ReferenceDataSourceUpdate
smart constructor.
s3ReferenceDataSourceUpdate :: S3ReferenceDataSourceUpdate Source #
Creates a value of S3ReferenceDataSourceUpdate
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
srdsuBucketARNUpdate
- Amazon Resource Name (ARN) of the S3 bucket.srdsuFileKeyUpdate
- Object key name.srdsuReferenceRoleARNUpdate
- ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application.
srdsuBucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) Source #
Amazon Resource Name (ARN) of the S3 bucket.
srdsuFileKeyUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) Source #
Object key name.
srdsuReferenceRoleARNUpdate :: 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: sourceSchema
smart constructor.
Creates a value of SourceSchema
with the minimum fields required to make a request.
Use one of the following lenses to modify other fields as desired:
ssRecordEncoding
- Specifies the encoding of the records in the streaming source. For example, UTF-8.ssRecordFormat
- Specifies the format of the records on the streaming source.ssRecordColumns
- A list ofRecordColumn
objects.
ssRecordEncoding :: Lens' SourceSchema (Maybe Text) Source #
Specifies the encoding of the records in the streaming source. For example, UTF-8.
ssRecordFormat :: Lens' SourceSchema RecordFormat Source #
Specifies the format of the records on the streaming source.
ssRecordColumns :: Lens' SourceSchema (NonEmpty RecordColumn) Source #
A list of RecordColumn
objects.