amazonka-kinesis-analytics-1.4.5: Amazon Kinesis Analytics SDK.

Copyright(c) 2013-2016 Brendan Hay
LicenseMozilla Public License, v. 2.0.
MaintainerBrendan Hay <brendan.g.hay@gmail.com>
Stabilityauto-generated
Portabilitynon-portable (GHC extensions)
Safe HaskellNone
LanguageHaskell2010

Network.AWS.KinesisAnalytics

Contents

Description

Amazon Kinesis Analytics is the easiest way to process streaming data in real time with standard SQL without having to learn new programming languages or processing frameworks. Amazon Kinesis Analytics enables you to create and run SQL queries on streaming data so that you can gain actionable insights and respond to your business and customer needs promptly.

Amazon Kinesis Analytics takes care of everything required to run your queries continuously and scales automatically to match the volume and throughput rate of your incoming data. With Amazon Kinesis Analytics, you only pay for the resources your queries consume. There is no minimum fee or setup cost.

Synopsis

Service Configuration

kinesisAnalytics :: Service #

API version 2015-08-14 of the Amazon Kinesis Analytics SDK configuration.

Errors

Error matchers are designed for use with the functions provided by Control.Exception.Lens. This allows catching (and rethrowing) service specific errors returned by KinesisAnalytics.

InvalidApplicationConfigurationException

_InvalidApplicationConfigurationException :: AsError a => Getting (First ServiceError) a ServiceError #

User-provided application configuration is not valid.

ResourceProvisionedThroughputExceededException

_ResourceProvisionedThroughputExceededException :: AsError a => Getting (First ServiceError) a ServiceError #

Discovery failed to get a record from the streaming source because of the Kinesis Streams ProvisionedThroughputExceededException.

InvalidArgumentException

_InvalidArgumentException :: AsError a => Getting (First ServiceError) a ServiceError #

Specified input parameter value is invalid.

CodeValidationException

_CodeValidationException :: AsError a => Getting (First ServiceError) a ServiceError #

User-provided application code (query) is invalid. This can be a simple syntax error.

ConcurrentModificationException

_ConcurrentModificationException :: AsError a => Getting (First ServiceError) a ServiceError #

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.

UnableToDetectSchemaException

_UnableToDetectSchemaException :: AsError a => Getting (First ServiceError) a ServiceError #

Data format is not valid, Kinesis Analytics is not able to detect schema for the given streaming source.

ResourceNotFoundException

_ResourceNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError #

Specified application can't be found.

LimitExceededException

_LimitExceededException :: AsError a => Getting (First ServiceError) a ServiceError #

Exceeded the number of applications allowed.

ResourceInUseException

_ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError #

Application is not available for this operation.

Waiters

Waiters poll by repeatedly sending a request until some remote success condition configured by the Wait specification is fulfilled. The Wait specification determines how many attempts should be made, in addition to delay and retry strategies.

Operations

Some AWS operations return results that are incomplete and require subsequent requests in order to obtain the entire result set. The process of sending subsequent requests to continue where a previous request left off is called pagination. For example, the ListObjects operation of Amazon S3 returns up to 1000 objects at a time, and you must send subsequent requests with the appropriate Marker in order to retrieve the next page of results.

Operations that have an AWSPager instance can transparently perform subsequent requests, correctly setting Markers and other request facets to iterate through the entire result set of a truncated API operation. Operations which support this have an additional note in the documentation.

Many operations have the ability to filter results on the server side. See the individual operation parameters for details.

AddApplicationOutput

DiscoverInputSchema

DescribeApplication

StartApplication

DeleteApplicationReferenceDataSource

DeleteApplication

UpdateApplication

CreateApplication

DeleteApplicationOutput

StopApplication

AddApplicationReferenceDataSource

AddApplicationInput

ListApplications

Types

ApplicationStatus

data ApplicationStatus #

Instances

Bounded ApplicationStatus # 
Enum ApplicationStatus # 
Eq ApplicationStatus # 
Data ApplicationStatus # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ApplicationStatus -> c ApplicationStatus #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ApplicationStatus #

toConstr :: ApplicationStatus -> Constr #

dataTypeOf :: ApplicationStatus -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c ApplicationStatus) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ApplicationStatus) #

gmapT :: (forall b. Data b => b -> b) -> ApplicationStatus -> ApplicationStatus #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationStatus -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationStatus -> r #

gmapQ :: (forall d. Data d => d -> u) -> ApplicationStatus -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ApplicationStatus -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ApplicationStatus -> m ApplicationStatus #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationStatus -> m ApplicationStatus #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationStatus -> m ApplicationStatus #

Ord ApplicationStatus # 
Read ApplicationStatus # 
Show ApplicationStatus # 
Generic ApplicationStatus # 
Hashable ApplicationStatus # 
FromJSON ApplicationStatus # 
NFData ApplicationStatus # 

Methods

rnf :: ApplicationStatus -> () #

ToQuery ApplicationStatus # 
ToHeader ApplicationStatus # 
ToByteString ApplicationStatus # 
FromText ApplicationStatus # 
ToText ApplicationStatus # 
type Rep ApplicationStatus # 
type Rep ApplicationStatus = D1 (MetaData "ApplicationStatus" "Network.AWS.KinesisAnalytics.Types.Sum" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) ((:+:) ((:+:) (C1 (MetaCons "Deleting" PrefixI False) U1) ((:+:) (C1 (MetaCons "Ready" PrefixI False) U1) (C1 (MetaCons "Running" PrefixI False) U1))) ((:+:) (C1 (MetaCons "Starting" PrefixI False) U1) ((:+:) (C1 (MetaCons "Stopping" PrefixI False) U1) (C1 (MetaCons "Updating" PrefixI False) U1))))

InputStartingPosition

data InputStartingPosition #

Instances

Bounded InputStartingPosition # 
Enum InputStartingPosition # 
Eq InputStartingPosition # 
Data InputStartingPosition # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputStartingPosition -> c InputStartingPosition #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputStartingPosition #

toConstr :: InputStartingPosition -> Constr #

dataTypeOf :: InputStartingPosition -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputStartingPosition) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputStartingPosition) #

gmapT :: (forall b. Data b => b -> b) -> InputStartingPosition -> InputStartingPosition #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputStartingPosition -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputStartingPosition -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputStartingPosition -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputStartingPosition -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputStartingPosition -> m InputStartingPosition #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputStartingPosition -> m InputStartingPosition #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputStartingPosition -> m InputStartingPosition #

Ord InputStartingPosition # 
Read InputStartingPosition # 
Show InputStartingPosition # 
Generic InputStartingPosition # 
Hashable InputStartingPosition # 
ToJSON InputStartingPosition # 
FromJSON InputStartingPosition # 
NFData InputStartingPosition # 

Methods

rnf :: InputStartingPosition -> () #

ToQuery InputStartingPosition # 
ToHeader InputStartingPosition # 
ToByteString InputStartingPosition # 
FromText InputStartingPosition # 
ToText InputStartingPosition # 
type Rep InputStartingPosition # 
type Rep InputStartingPosition = D1 (MetaData "InputStartingPosition" "Network.AWS.KinesisAnalytics.Types.Sum" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) ((:+:) (C1 (MetaCons "LastStoppedPoint" PrefixI False) U1) ((:+:) (C1 (MetaCons "Now" PrefixI False) U1) (C1 (MetaCons "TrimHorizon" PrefixI False) U1)))

RecordFormatType

data RecordFormatType #

Constructors

CSV 
JSON 

Instances

Bounded RecordFormatType # 
Enum RecordFormatType # 
Eq RecordFormatType # 
Data RecordFormatType # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> RecordFormatType -> c RecordFormatType #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c RecordFormatType #

toConstr :: RecordFormatType -> Constr #

dataTypeOf :: RecordFormatType -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c RecordFormatType) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c RecordFormatType) #

gmapT :: (forall b. Data b => b -> b) -> RecordFormatType -> RecordFormatType #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> RecordFormatType -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> RecordFormatType -> r #

gmapQ :: (forall d. Data d => d -> u) -> RecordFormatType -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> RecordFormatType -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> RecordFormatType -> m RecordFormatType #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> RecordFormatType -> m RecordFormatType #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> RecordFormatType -> m RecordFormatType #

Ord RecordFormatType # 
Read RecordFormatType # 
Show RecordFormatType # 
Generic RecordFormatType # 
Hashable RecordFormatType # 
ToJSON RecordFormatType # 
FromJSON RecordFormatType # 
NFData RecordFormatType # 

Methods

rnf :: RecordFormatType -> () #

ToQuery RecordFormatType # 
ToHeader RecordFormatType # 
ToByteString RecordFormatType # 
FromText RecordFormatType # 
ToText RecordFormatType # 
type Rep RecordFormatType # 
type Rep RecordFormatType = D1 (MetaData "RecordFormatType" "Network.AWS.KinesisAnalytics.Types.Sum" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) ((:+:) (C1 (MetaCons "CSV" PrefixI False) U1) (C1 (MetaCons "JSON" PrefixI False) U1))

ApplicationDetail

data ApplicationDetail #

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.

Instances

Eq ApplicationDetail # 
Data ApplicationDetail # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ApplicationDetail -> c ApplicationDetail #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ApplicationDetail #

toConstr :: ApplicationDetail -> Constr #

dataTypeOf :: ApplicationDetail -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c ApplicationDetail) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ApplicationDetail) #

gmapT :: (forall b. Data b => b -> b) -> ApplicationDetail -> ApplicationDetail #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationDetail -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationDetail -> r #

gmapQ :: (forall d. Data d => d -> u) -> ApplicationDetail -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ApplicationDetail -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ApplicationDetail -> m ApplicationDetail #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationDetail -> m ApplicationDetail #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationDetail -> m ApplicationDetail #

Read ApplicationDetail # 
Show ApplicationDetail # 
Generic ApplicationDetail # 
Hashable ApplicationDetail # 
FromJSON ApplicationDetail # 
NFData ApplicationDetail # 

Methods

rnf :: ApplicationDetail -> () #

type Rep ApplicationDetail # 
type Rep ApplicationDetail = D1 (MetaData "ApplicationDetail" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "ApplicationDetail'" PrefixI True) ((:*:) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_adApplicationDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_adOutputDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [OutputDescription])))) ((:*:) (S1 (MetaSel (Just Symbol "_adReferenceDataSourceDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [ReferenceDataSourceDescription]))) ((:*:) (S1 (MetaSel (Just Symbol "_adInputDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [InputDescription]))) (S1 (MetaSel (Just Symbol "_adApplicationCode") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_adCreateTimestamp") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe POSIX))) ((:*:) (S1 (MetaSel (Just Symbol "_adLastUpdateTimestamp") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe POSIX))) (S1 (MetaSel (Just Symbol "_adApplicationName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))) ((:*:) (S1 (MetaSel (Just Symbol "_adApplicationARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) ((:*:) (S1 (MetaSel (Just Symbol "_adApplicationStatus") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ApplicationStatus)) (S1 (MetaSel (Just Symbol "_adApplicationVersionId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Nat)))))))

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 :: Lens' ApplicationDetail (Maybe Text) #

Description of the application.

adOutputDescriptions :: Lens' ApplicationDetail [OutputDescription] #

Describes the application output configuration. For more information, see Configuring Application Output .

adReferenceDataSourceDescriptions :: Lens' ApplicationDetail [ReferenceDataSourceDescription] #

Describes reference data sources configured for the application. For more information, see Configuring Application Input .

adInputDescriptions :: Lens' ApplicationDetail [InputDescription] #

Describes the application input configuration. For more information, see Configuring Application Input .

adApplicationCode :: Lens' ApplicationDetail (Maybe Text) #

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) #

Timestamp when the application version was created.

adLastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime) #

Timestamp when the application was last updated.

adApplicationName :: Lens' ApplicationDetail Text #

Name of the application.

adApplicationARN :: Lens' ApplicationDetail Text #

ARN of the application.

adApplicationVersionId :: Lens' ApplicationDetail Natural #

Provides the current application version.

ApplicationSummary

data ApplicationSummary #

Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.

See: applicationSummary smart constructor.

Instances

Eq ApplicationSummary # 
Data ApplicationSummary # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ApplicationSummary -> c ApplicationSummary #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ApplicationSummary #

toConstr :: ApplicationSummary -> Constr #

dataTypeOf :: ApplicationSummary -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c ApplicationSummary) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ApplicationSummary) #

gmapT :: (forall b. Data b => b -> b) -> ApplicationSummary -> ApplicationSummary #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationSummary -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationSummary -> r #

gmapQ :: (forall d. Data d => d -> u) -> ApplicationSummary -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ApplicationSummary -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ApplicationSummary -> m ApplicationSummary #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationSummary -> m ApplicationSummary #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationSummary -> m ApplicationSummary #

Read ApplicationSummary # 
Show ApplicationSummary # 
Generic ApplicationSummary # 
Hashable ApplicationSummary # 
FromJSON ApplicationSummary # 
NFData ApplicationSummary # 

Methods

rnf :: ApplicationSummary -> () #

type Rep ApplicationSummary # 
type Rep ApplicationSummary = D1 (MetaData "ApplicationSummary" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "ApplicationSummary'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_asApplicationName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) ((:*:) (S1 (MetaSel (Just Symbol "_asApplicationARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_asApplicationStatus") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 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 :: Lens' ApplicationSummary Text #

Name of the application.

asApplicationARN :: Lens' ApplicationSummary Text #

ARN of the application.

ApplicationUpdate

data ApplicationUpdate #

Describes updates to apply to an existing Kinesis Analytics application.

See: applicationUpdate smart constructor.

Instances

Eq ApplicationUpdate # 
Data ApplicationUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ApplicationUpdate -> c ApplicationUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ApplicationUpdate #

toConstr :: ApplicationUpdate -> Constr #

dataTypeOf :: ApplicationUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c ApplicationUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ApplicationUpdate) #

gmapT :: (forall b. Data b => b -> b) -> ApplicationUpdate -> ApplicationUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ApplicationUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> ApplicationUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ApplicationUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ApplicationUpdate -> m ApplicationUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationUpdate -> m ApplicationUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ApplicationUpdate -> m ApplicationUpdate #

Read ApplicationUpdate # 
Show ApplicationUpdate # 
Generic ApplicationUpdate # 
Hashable ApplicationUpdate # 
ToJSON ApplicationUpdate # 
NFData ApplicationUpdate # 

Methods

rnf :: ApplicationUpdate -> () #

type Rep ApplicationUpdate # 
type Rep ApplicationUpdate = D1 (MetaData "ApplicationUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "ApplicationUpdate'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_auReferenceDataSourceUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [ReferenceDataSourceUpdate]))) (S1 (MetaSel (Just Symbol "_auInputUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [InputUpdate])))) ((:*:) (S1 (MetaSel (Just Symbol "_auOutputUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [OutputUpdate]))) (S1 (MetaSel (Just Symbol "_auApplicationCodeUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))))

applicationUpdate :: ApplicationUpdate #

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 :: Lens' ApplicationUpdate [ReferenceDataSourceUpdate] #

Describes application reference data source updates.

auInputUpdates :: Lens' ApplicationUpdate [InputUpdate] #

Describes application input configuration updates.

auOutputUpdates :: Lens' ApplicationUpdate [OutputUpdate] #

Describes application output configuration updates.

auApplicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text) #

Describes application code updates.

CSVMappingParameters

data CSVMappingParameters #

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.

Instances

Eq CSVMappingParameters # 
Data CSVMappingParameters # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> CSVMappingParameters -> c CSVMappingParameters #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c CSVMappingParameters #

toConstr :: CSVMappingParameters -> Constr #

dataTypeOf :: CSVMappingParameters -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c CSVMappingParameters) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c CSVMappingParameters) #

gmapT :: (forall b. Data b => b -> b) -> CSVMappingParameters -> CSVMappingParameters #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> CSVMappingParameters -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> CSVMappingParameters -> r #

gmapQ :: (forall d. Data d => d -> u) -> CSVMappingParameters -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> CSVMappingParameters -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> CSVMappingParameters -> m CSVMappingParameters #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> CSVMappingParameters -> m CSVMappingParameters #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> CSVMappingParameters -> m CSVMappingParameters #

Read CSVMappingParameters # 
Show CSVMappingParameters # 
Generic CSVMappingParameters # 
Hashable CSVMappingParameters # 
ToJSON CSVMappingParameters # 
FromJSON CSVMappingParameters # 
NFData CSVMappingParameters # 

Methods

rnf :: CSVMappingParameters -> () #

type Rep CSVMappingParameters # 
type Rep CSVMappingParameters = D1 (MetaData "CSVMappingParameters" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "CSVMappingParameters'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_cmpRecordRowDelimiter") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_cmpRecordColumnDelimiter") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))))

csvMappingParameters #

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 :: Lens' CSVMappingParameters Text #

Row delimiter. For example, in a CSV format, '\n' is the typical row delimiter.

cmpRecordColumnDelimiter :: Lens' CSVMappingParameters Text #

Column delimiter. For example, in a CSV format, a comma (",") is the typical column delimiter.

DestinationSchema

data DestinationSchema #

Describes the data format when records are written to the destination. For more information, see Configuring Application Output .

See: destinationSchema smart constructor.

Instances

Eq DestinationSchema # 
Data DestinationSchema # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> DestinationSchema -> c DestinationSchema #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c DestinationSchema #

toConstr :: DestinationSchema -> Constr #

dataTypeOf :: DestinationSchema -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c DestinationSchema) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c DestinationSchema) #

gmapT :: (forall b. Data b => b -> b) -> DestinationSchema -> DestinationSchema #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> DestinationSchema -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> DestinationSchema -> r #

gmapQ :: (forall d. Data d => d -> u) -> DestinationSchema -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> DestinationSchema -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> DestinationSchema -> m DestinationSchema #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> DestinationSchema -> m DestinationSchema #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> DestinationSchema -> m DestinationSchema #

Read DestinationSchema # 
Show DestinationSchema # 
Generic DestinationSchema # 
Hashable DestinationSchema # 
ToJSON DestinationSchema # 
FromJSON DestinationSchema # 
NFData DestinationSchema # 

Methods

rnf :: DestinationSchema -> () #

type Rep DestinationSchema # 
type Rep DestinationSchema = D1 (MetaData "DestinationSchema" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" True) (C1 (MetaCons "DestinationSchema'" PrefixI True) (S1 (MetaSel (Just Symbol "_dsRecordFormatType") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe RecordFormatType))))

destinationSchema :: DestinationSchema #

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 :: Lens' DestinationSchema (Maybe RecordFormatType) #

Specifies the format of the records on the output stream.

Input

data 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.

Instances

Eq Input # 

Methods

(==) :: Input -> Input -> Bool #

(/=) :: Input -> Input -> Bool #

Data Input # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> Input -> c Input #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c Input #

toConstr :: Input -> Constr #

dataTypeOf :: Input -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c Input) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c Input) #

gmapT :: (forall b. Data b => b -> b) -> Input -> Input #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> Input -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> Input -> r #

gmapQ :: (forall d. Data d => d -> u) -> Input -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> Input -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> Input -> m Input #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> Input -> m Input #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> Input -> m Input #

Read Input # 
Show Input # 

Methods

showsPrec :: Int -> Input -> ShowS #

show :: Input -> String #

showList :: [Input] -> ShowS #

Generic Input # 

Associated Types

type Rep Input :: * -> * #

Methods

from :: Input -> Rep Input x #

to :: Rep Input x -> Input #

Hashable Input # 

Methods

hashWithSalt :: Int -> Input -> Int #

hash :: Input -> Int #

ToJSON Input # 
NFData Input # 

Methods

rnf :: Input -> () #

type Rep Input # 
type Rep Input = D1 (MetaData "Input" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "Input'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_iInputParallelism") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputParallelism))) (S1 (MetaSel (Just Symbol "_iKinesisStreamsInput") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsInput)))) ((:*:) (S1 (MetaSel (Just Symbol "_iKinesisFirehoseInput") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseInput))) ((:*:) (S1 (MetaSel (Just Symbol "_iNamePrefix") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_iInputSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 SourceSchema))))))

input #

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 will be routed to these in-application input streams. (see Configuring Application Input .
  • 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.
  • iKinesisFirehoseInput - If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the Firehose delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
  • iNamePrefix - Name prefix to use when creating in-application stream. Suppose you specify a prefix MyInApplicationStream. Kinesis Analytics will then create one or more (as per the InputParallelism 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) #

Describes the number of in-application streams to create. Data from your source will be routed to these in-application input streams. (see Configuring Application Input .

iKinesisStreamsInput :: Lens' Input (Maybe 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.

iKinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput) #

If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the Firehose delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

iNamePrefix :: Lens' Input Text #

Name prefix to use when creating in-application stream. Suppose you specify a prefix MyInApplicationStream. Kinesis Analytics will then create 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 #

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 #

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.

Instances

Eq InputConfiguration # 
Data InputConfiguration # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputConfiguration -> c InputConfiguration #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputConfiguration #

toConstr :: InputConfiguration -> Constr #

dataTypeOf :: InputConfiguration -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputConfiguration) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputConfiguration) #

gmapT :: (forall b. Data b => b -> b) -> InputConfiguration -> InputConfiguration #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputConfiguration -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputConfiguration -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputConfiguration -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputConfiguration -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputConfiguration -> m InputConfiguration #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputConfiguration -> m InputConfiguration #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputConfiguration -> m InputConfiguration #

Read InputConfiguration # 
Show InputConfiguration # 
Generic InputConfiguration # 
Hashable InputConfiguration # 
ToJSON InputConfiguration # 
NFData InputConfiguration # 

Methods

rnf :: InputConfiguration -> () #

type Rep InputConfiguration # 
type Rep InputConfiguration = D1 (MetaData "InputConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "InputConfiguration'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_icId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_icInputStartingPositionConfiguration") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 InputStartingPositionConfiguration))))

inputConfiguration #

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 the DescribeApplication operation.
  • icInputStartingPositionConfiguration - Point at which you want the application to start processing records from the streaming source.

icId :: Lens' InputConfiguration Text #

Input source ID. You can get this ID by calling the DescribeApplication operation.

icInputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration #

Point at which you want the application to start processing records from the streaming source.

InputDescription

data InputDescription #

Describes the application input configuration. For more information, see Configuring Application Input .

See: inputDescription smart constructor.

Instances

Eq InputDescription # 
Data InputDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputDescription -> c InputDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputDescription #

toConstr :: InputDescription -> Constr #

dataTypeOf :: InputDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputDescription) #

gmapT :: (forall b. Data b => b -> b) -> InputDescription -> InputDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputDescription -> m InputDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputDescription -> m InputDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputDescription -> m InputDescription #

Read InputDescription # 
Show InputDescription # 
Generic InputDescription # 
Hashable InputDescription # 
FromJSON InputDescription # 
NFData InputDescription # 

Methods

rnf :: InputDescription -> () #

type Rep InputDescription # 
type Rep InputDescription = D1 (MetaData "InputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "InputDescription'" PrefixI True) ((:*:) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_idInputStartingPositionConfiguration") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputStartingPositionConfiguration))) (S1 (MetaSel (Just Symbol "_idInputParallelism") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputParallelism)))) ((:*:) (S1 (MetaSel (Just Symbol "_idInputId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_idInAppStreamNames") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [Text]))))) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_idKinesisFirehoseInputDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseInputDescription))) (S1 (MetaSel (Just Symbol "_idInputSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceSchema)))) ((:*:) (S1 (MetaSel (Just Symbol "_idKinesisStreamsInputDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsInputDescription))) (S1 (MetaSel (Just Symbol "_idNamePrefix") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))))

inputDescription :: InputDescription #

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 Firehose delivery stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
  • idInputSchema - Undocumented member.
  • idKinesisStreamsInputDescription - If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
  • idNamePrefix - In-application name prefix.

idInputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration) #

Point at which the application is configured to read from the input stream.

idInputParallelism :: Lens' InputDescription (Maybe InputParallelism) #

Describes the configured parallelism (number of in-application streams mapped to the streaming source).

idInputId :: Lens' InputDescription (Maybe Text) #

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] #

Returns the in-application stream names that are mapped to the stream source.

idKinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription) #

If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the Firehose delivery stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

idKinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription) #

If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.

idNamePrefix :: Lens' InputDescription (Maybe Text) #

In-application name prefix.

InputParallelism

data InputParallelism #

Describes the number of in-application streams to create for a given streaming source. For information about parallellism, see Configuring Application Input .

See: inputParallelism smart constructor.

Instances

Eq InputParallelism # 
Data InputParallelism # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputParallelism -> c InputParallelism #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputParallelism #

toConstr :: InputParallelism -> Constr #

dataTypeOf :: InputParallelism -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputParallelism) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputParallelism) #

gmapT :: (forall b. Data b => b -> b) -> InputParallelism -> InputParallelism #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputParallelism -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputParallelism -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputParallelism -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputParallelism -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputParallelism -> m InputParallelism #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputParallelism -> m InputParallelism #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputParallelism -> m InputParallelism #

Read InputParallelism # 
Show InputParallelism # 
Generic InputParallelism # 
Hashable InputParallelism # 
ToJSON InputParallelism # 
FromJSON InputParallelism # 
NFData InputParallelism # 

Methods

rnf :: InputParallelism -> () #

type Rep InputParallelism # 
type Rep InputParallelism = D1 (MetaData "InputParallelism" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" True) (C1 (MetaCons "InputParallelism'" PrefixI True) (S1 (MetaSel (Just Symbol "_ipCount") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Nat))))

inputParallelism :: InputParallelism #

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 - Number of in-application streams to create. For more information, see Limits .

ipCount :: Lens' InputParallelism (Maybe Natural) #

Number of in-application streams to create. For more information, see Limits .

InputParallelismUpdate

data InputParallelismUpdate #

Provides updates to the parallelism count.

See: inputParallelismUpdate smart constructor.

Instances

Eq InputParallelismUpdate # 
Data InputParallelismUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputParallelismUpdate -> c InputParallelismUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputParallelismUpdate #

toConstr :: InputParallelismUpdate -> Constr #

dataTypeOf :: InputParallelismUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputParallelismUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputParallelismUpdate) #

gmapT :: (forall b. Data b => b -> b) -> InputParallelismUpdate -> InputParallelismUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputParallelismUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputParallelismUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputParallelismUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputParallelismUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputParallelismUpdate -> m InputParallelismUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputParallelismUpdate -> m InputParallelismUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputParallelismUpdate -> m InputParallelismUpdate #

Read InputParallelismUpdate # 
Show InputParallelismUpdate # 
Generic InputParallelismUpdate # 
Hashable InputParallelismUpdate # 
ToJSON InputParallelismUpdate # 
NFData InputParallelismUpdate # 

Methods

rnf :: InputParallelismUpdate -> () #

type Rep InputParallelismUpdate # 
type Rep InputParallelismUpdate = D1 (MetaData "InputParallelismUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" True) (C1 (MetaCons "InputParallelismUpdate'" PrefixI True) (S1 (MetaSel (Just Symbol "_ipuCountUpdate") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Nat))))

inputParallelismUpdate :: InputParallelismUpdate #

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) #

Number of in-application streams to create for the specified streaming source.

InputSchemaUpdate

data InputSchemaUpdate #

Describes updates for the application's input schema.

See: inputSchemaUpdate smart constructor.

Instances

Eq InputSchemaUpdate # 
Data InputSchemaUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputSchemaUpdate -> c InputSchemaUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputSchemaUpdate #

toConstr :: InputSchemaUpdate -> Constr #

dataTypeOf :: InputSchemaUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputSchemaUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputSchemaUpdate) #

gmapT :: (forall b. Data b => b -> b) -> InputSchemaUpdate -> InputSchemaUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputSchemaUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputSchemaUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputSchemaUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputSchemaUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputSchemaUpdate -> m InputSchemaUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputSchemaUpdate -> m InputSchemaUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputSchemaUpdate -> m InputSchemaUpdate #

Read InputSchemaUpdate # 
Show InputSchemaUpdate # 
Generic InputSchemaUpdate # 
Hashable InputSchemaUpdate # 
ToJSON InputSchemaUpdate # 
NFData InputSchemaUpdate # 

Methods

rnf :: InputSchemaUpdate -> () #

type Rep InputSchemaUpdate # 
type Rep InputSchemaUpdate = D1 (MetaData "InputSchemaUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "InputSchemaUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_isuRecordFormatUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe RecordFormat))) ((:*:) (S1 (MetaSel (Just Symbol "_isuRecordEncodingUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_isuRecordColumnUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe (List1 RecordColumn)))))))

inputSchemaUpdate :: InputSchemaUpdate #

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 of RecordColumn 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) #

Specifies the format of the records on the streaming source.

isuRecordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text) #

Specifies the encoding of the records in the streaming source. For example, UTF-8.

isuRecordColumnUpdates :: Lens' InputSchemaUpdate (Maybe (NonEmpty RecordColumn)) #

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 #

Describes the point at which the application reads from the streaming source.

See: inputStartingPositionConfiguration smart constructor.

Instances

Eq InputStartingPositionConfiguration # 
Data InputStartingPositionConfiguration # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputStartingPositionConfiguration -> c InputStartingPositionConfiguration #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputStartingPositionConfiguration #

toConstr :: InputStartingPositionConfiguration -> Constr #

dataTypeOf :: InputStartingPositionConfiguration -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputStartingPositionConfiguration) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputStartingPositionConfiguration) #

gmapT :: (forall b. Data b => b -> b) -> InputStartingPositionConfiguration -> InputStartingPositionConfiguration #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputStartingPositionConfiguration -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputStartingPositionConfiguration -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputStartingPositionConfiguration -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputStartingPositionConfiguration -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputStartingPositionConfiguration -> m InputStartingPositionConfiguration #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputStartingPositionConfiguration -> m InputStartingPositionConfiguration #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputStartingPositionConfiguration -> m InputStartingPositionConfiguration #

Read InputStartingPositionConfiguration # 
Show InputStartingPositionConfiguration # 
Generic InputStartingPositionConfiguration # 
Hashable InputStartingPositionConfiguration # 
ToJSON InputStartingPositionConfiguration # 
FromJSON InputStartingPositionConfiguration # 
NFData InputStartingPositionConfiguration # 
type Rep InputStartingPositionConfiguration # 
type Rep InputStartingPositionConfiguration = D1 (MetaData "InputStartingPositionConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" True) (C1 (MetaCons "InputStartingPositionConfiguration'" PrefixI True) (S1 (MetaSel (Just Symbol "_ispcInputStartingPosition") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe InputStartingPosition))))

inputStartingPositionConfiguration :: InputStartingPositionConfiguration #

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. * LATEST - Start reading just after the most recent record in the stream. * 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) #

The starting position on the stream. * LATEST - Start reading just after the most recent record in the stream. * 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 #

Describes updates to a specific input configuration (identified by the InputId of an application).

See: inputUpdate smart constructor.

Instances

Eq InputUpdate # 
Data InputUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> InputUpdate -> c InputUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c InputUpdate #

toConstr :: InputUpdate -> Constr #

dataTypeOf :: InputUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c InputUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c InputUpdate) #

gmapT :: (forall b. Data b => b -> b) -> InputUpdate -> InputUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> InputUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> InputUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> InputUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> InputUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> InputUpdate -> m InputUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> InputUpdate -> m InputUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> InputUpdate -> m InputUpdate #

Read InputUpdate # 
Show InputUpdate # 
Generic InputUpdate # 

Associated Types

type Rep InputUpdate :: * -> * #

Hashable InputUpdate # 
ToJSON InputUpdate # 
NFData InputUpdate # 

Methods

rnf :: InputUpdate -> () #

type Rep InputUpdate # 
type Rep InputUpdate = D1 (MetaData "InputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "InputUpdate'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_iuKinesisStreamsInputUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsInputUpdate))) ((:*:) (S1 (MetaSel (Just Symbol "_iuInputParallelismUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputParallelismUpdate))) (S1 (MetaSel (Just Symbol "_iuNamePrefixUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))) ((:*:) (S1 (MetaSel (Just Symbol "_iuInputSchemaUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputSchemaUpdate))) ((:*:) (S1 (MetaSel (Just Symbol "_iuKinesisFirehoseInputUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseInputUpdate))) (S1 (MetaSel (Just Symbol "_iuInputId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))))))

inputUpdate #

Arguments

:: Text

iuInputId

-> 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:

  • iuKinesisStreamsInputUpdate - If a Amazon Kinesis stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.
  • iuInputParallelismUpdate - Describes the parallelism updates (the number in-application streams Kinesis Analytics creates for the specific streaming source).
  • iuNamePrefixUpdate - Name prefix for in-application stream(s) that 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 Amazon Resource Name (ARN) and IAM role ARN.
  • iuInputId - Input ID of the application input to be updated.

iuKinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate) #

If a Amazon Kinesis stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.

iuInputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate) #

Describes the parallelism updates (the number in-application streams Kinesis Analytics creates for the specific streaming source).

iuNamePrefixUpdate :: Lens' InputUpdate (Maybe Text) #

Name prefix for in-application stream(s) that Kinesis Analytics creates for the specific streaming source.

iuInputSchemaUpdate :: Lens' InputUpdate (Maybe 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.

iuKinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate) #

If an Amazon Kinesis Firehose delivery stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN) and IAM role ARN.

iuInputId :: Lens' InputUpdate Text #

Input ID of the application input to be updated.

JSONMappingParameters

data JSONMappingParameters #

Provides additional mapping information when JSON is the record format on the streaming source.

See: jsonMappingParameters smart constructor.

Instances

Eq JSONMappingParameters # 
Data JSONMappingParameters # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> JSONMappingParameters -> c JSONMappingParameters #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c JSONMappingParameters #

toConstr :: JSONMappingParameters -> Constr #

dataTypeOf :: JSONMappingParameters -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c JSONMappingParameters) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c JSONMappingParameters) #

gmapT :: (forall b. Data b => b -> b) -> JSONMappingParameters -> JSONMappingParameters #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> JSONMappingParameters -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> JSONMappingParameters -> r #

gmapQ :: (forall d. Data d => d -> u) -> JSONMappingParameters -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> JSONMappingParameters -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> JSONMappingParameters -> m JSONMappingParameters #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> JSONMappingParameters -> m JSONMappingParameters #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> JSONMappingParameters -> m JSONMappingParameters #

Read JSONMappingParameters # 
Show JSONMappingParameters # 
Generic JSONMappingParameters # 
Hashable JSONMappingParameters # 
ToJSON JSONMappingParameters # 
FromJSON JSONMappingParameters # 
NFData JSONMappingParameters # 

Methods

rnf :: JSONMappingParameters -> () #

type Rep JSONMappingParameters # 
type Rep JSONMappingParameters = D1 (MetaData "JSONMappingParameters" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" True) (C1 (MetaCons "JSONMappingParameters'" PrefixI True) (S1 (MetaSel (Just Symbol "_jmpRecordRowPath") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

jsonMappingParameters #

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. For example, consider the following JSON record: In the RecordRowPath , "$" refers to the root and path "$.vehicle.Model" refers to the specific Model key in the JSON.

jmpRecordRowPath :: Lens' JSONMappingParameters Text #

Path to the top-level parent that contains the records. For example, consider the following JSON record: In the RecordRowPath , "$" refers to the root and path "$.vehicle.Model" refers to the specific Model key in the JSON.

KinesisFirehoseInput

data KinesisFirehoseInput #

Identifies an Amazon Kinesis Firehose delivery stream as the streaming source. You provide the Firehose 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.

Instances

Eq KinesisFirehoseInput # 
Data KinesisFirehoseInput # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisFirehoseInput -> c KinesisFirehoseInput #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisFirehoseInput #

toConstr :: KinesisFirehoseInput -> Constr #

dataTypeOf :: KinesisFirehoseInput -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisFirehoseInput) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisFirehoseInput) #

gmapT :: (forall b. Data b => b -> b) -> KinesisFirehoseInput -> KinesisFirehoseInput #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseInput -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseInput -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisFirehoseInput -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisFirehoseInput -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisFirehoseInput -> m KinesisFirehoseInput #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseInput -> m KinesisFirehoseInput #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseInput -> m KinesisFirehoseInput #

Read KinesisFirehoseInput # 
Show KinesisFirehoseInput # 
Generic KinesisFirehoseInput # 
Hashable KinesisFirehoseInput # 
ToJSON KinesisFirehoseInput # 
NFData KinesisFirehoseInput # 

Methods

rnf :: KinesisFirehoseInput -> () #

type Rep KinesisFirehoseInput # 
type Rep KinesisFirehoseInput = D1 (MetaData "KinesisFirehoseInput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisFirehoseInput'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfiResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_kfiRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))))

kinesisFirehoseInput #

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 Firehose 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 #

ARN of the input Firehose delivery stream.

kfiRoleARN :: Lens' KinesisFirehoseInput Text #

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 #

Describes the Amazon Kinesis Firehose delivery stream that is configured as the streaming source in the application input configuration.

See: kinesisFirehoseInputDescription smart constructor.

Instances

Eq KinesisFirehoseInputDescription # 
Data KinesisFirehoseInputDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisFirehoseInputDescription -> c KinesisFirehoseInputDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisFirehoseInputDescription #

toConstr :: KinesisFirehoseInputDescription -> Constr #

dataTypeOf :: KinesisFirehoseInputDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisFirehoseInputDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisFirehoseInputDescription) #

gmapT :: (forall b. Data b => b -> b) -> KinesisFirehoseInputDescription -> KinesisFirehoseInputDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseInputDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseInputDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisFirehoseInputDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisFirehoseInputDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisFirehoseInputDescription -> m KinesisFirehoseInputDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseInputDescription -> m KinesisFirehoseInputDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseInputDescription -> m KinesisFirehoseInputDescription #

Read KinesisFirehoseInputDescription # 
Show KinesisFirehoseInputDescription # 
Generic KinesisFirehoseInputDescription # 
Hashable KinesisFirehoseInputDescription # 
FromJSON KinesisFirehoseInputDescription # 
NFData KinesisFirehoseInputDescription # 
type Rep KinesisFirehoseInputDescription # 
type Rep KinesisFirehoseInputDescription = D1 (MetaData "KinesisFirehoseInputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisFirehoseInputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfidResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfidRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseInputDescription :: KinesisFirehoseInputDescription #

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) #

Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.

kfidRoleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text) #

ARN of the IAM role that Amazon Kinesis Analytics assumes to access the stream.

KinesisFirehoseInputUpdate

data KinesisFirehoseInputUpdate #

When updating application input configuration, provides information about an Amazon Kinesis Firehose delivery stream as the streaming source.

See: kinesisFirehoseInputUpdate smart constructor.

Instances

Eq KinesisFirehoseInputUpdate # 
Data KinesisFirehoseInputUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisFirehoseInputUpdate -> c KinesisFirehoseInputUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisFirehoseInputUpdate #

toConstr :: KinesisFirehoseInputUpdate -> Constr #

dataTypeOf :: KinesisFirehoseInputUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisFirehoseInputUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisFirehoseInputUpdate) #

gmapT :: (forall b. Data b => b -> b) -> KinesisFirehoseInputUpdate -> KinesisFirehoseInputUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseInputUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseInputUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisFirehoseInputUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisFirehoseInputUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisFirehoseInputUpdate -> m KinesisFirehoseInputUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseInputUpdate -> m KinesisFirehoseInputUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseInputUpdate -> m KinesisFirehoseInputUpdate #

Read KinesisFirehoseInputUpdate # 
Show KinesisFirehoseInputUpdate # 
Generic KinesisFirehoseInputUpdate # 
Hashable KinesisFirehoseInputUpdate # 
ToJSON KinesisFirehoseInputUpdate # 
NFData KinesisFirehoseInputUpdate # 
type Rep KinesisFirehoseInputUpdate # 
type Rep KinesisFirehoseInputUpdate = D1 (MetaData "KinesisFirehoseInputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisFirehoseInputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfiuRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfiuResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseInputUpdate :: KinesisFirehoseInputUpdate #

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 - Amazon Resource Name (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 - ARN of the input Amazon Kinesis Firehose delivery stream to read.

kfiuRoleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text) #

Amazon Resource Name (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) #

ARN of the input Amazon Kinesis Firehose delivery stream to read.

KinesisFirehoseOutput

data KinesisFirehoseOutput #

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.

Instances

Eq KinesisFirehoseOutput # 
Data KinesisFirehoseOutput # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisFirehoseOutput -> c KinesisFirehoseOutput #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisFirehoseOutput #

toConstr :: KinesisFirehoseOutput -> Constr #

dataTypeOf :: KinesisFirehoseOutput -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisFirehoseOutput) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisFirehoseOutput) #

gmapT :: (forall b. Data b => b -> b) -> KinesisFirehoseOutput -> KinesisFirehoseOutput #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseOutput -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseOutput -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisFirehoseOutput -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisFirehoseOutput -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutput -> m KinesisFirehoseOutput #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutput -> m KinesisFirehoseOutput #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutput -> m KinesisFirehoseOutput #

Read KinesisFirehoseOutput # 
Show KinesisFirehoseOutput # 
Generic KinesisFirehoseOutput # 
Hashable KinesisFirehoseOutput # 
ToJSON KinesisFirehoseOutput # 
NFData KinesisFirehoseOutput # 

Methods

rnf :: KinesisFirehoseOutput -> () #

type Rep KinesisFirehoseOutput # 
type Rep KinesisFirehoseOutput = D1 (MetaData "KinesisFirehoseOutput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisFirehoseOutput'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfoResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_kfoRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))))

kinesisFirehoseOutput #

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 #

ARN of the destination Amazon Kinesis Firehose delivery stream to write to.

kfoRoleARN :: Lens' KinesisFirehoseOutput Text #

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 #

For an application output, describes the Amazon Kinesis Firehose delivery stream configured as its destination.

See: kinesisFirehoseOutputDescription smart constructor.

Instances

Eq KinesisFirehoseOutputDescription # 
Data KinesisFirehoseOutputDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisFirehoseOutputDescription -> c KinesisFirehoseOutputDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisFirehoseOutputDescription #

toConstr :: KinesisFirehoseOutputDescription -> Constr #

dataTypeOf :: KinesisFirehoseOutputDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisFirehoseOutputDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisFirehoseOutputDescription) #

gmapT :: (forall b. Data b => b -> b) -> KinesisFirehoseOutputDescription -> KinesisFirehoseOutputDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseOutputDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseOutputDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisFirehoseOutputDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisFirehoseOutputDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutputDescription -> m KinesisFirehoseOutputDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutputDescription -> m KinesisFirehoseOutputDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutputDescription -> m KinesisFirehoseOutputDescription #

Read KinesisFirehoseOutputDescription # 
Show KinesisFirehoseOutputDescription # 
Generic KinesisFirehoseOutputDescription # 
Hashable KinesisFirehoseOutputDescription # 
FromJSON KinesisFirehoseOutputDescription # 
NFData KinesisFirehoseOutputDescription # 
type Rep KinesisFirehoseOutputDescription # 
type Rep KinesisFirehoseOutputDescription = D1 (MetaData "KinesisFirehoseOutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisFirehoseOutputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfodResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfodRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseOutputDescription :: KinesisFirehoseOutputDescription #

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) #

Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.

kfodRoleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text) #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.

KinesisFirehoseOutputUpdate

data KinesisFirehoseOutputUpdate #

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.

Instances

Eq KinesisFirehoseOutputUpdate # 
Data KinesisFirehoseOutputUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisFirehoseOutputUpdate -> c KinesisFirehoseOutputUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisFirehoseOutputUpdate #

toConstr :: KinesisFirehoseOutputUpdate -> Constr #

dataTypeOf :: KinesisFirehoseOutputUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisFirehoseOutputUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisFirehoseOutputUpdate) #

gmapT :: (forall b. Data b => b -> b) -> KinesisFirehoseOutputUpdate -> KinesisFirehoseOutputUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseOutputUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisFirehoseOutputUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisFirehoseOutputUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisFirehoseOutputUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutputUpdate -> m KinesisFirehoseOutputUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutputUpdate -> m KinesisFirehoseOutputUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisFirehoseOutputUpdate -> m KinesisFirehoseOutputUpdate #

Read KinesisFirehoseOutputUpdate # 
Show KinesisFirehoseOutputUpdate # 
Generic KinesisFirehoseOutputUpdate # 
Hashable KinesisFirehoseOutputUpdate # 
ToJSON KinesisFirehoseOutputUpdate # 
NFData KinesisFirehoseOutputUpdate # 
type Rep KinesisFirehoseOutputUpdate # 
type Rep KinesisFirehoseOutputUpdate = D1 (MetaData "KinesisFirehoseOutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisFirehoseOutputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfouRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfouResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseOutputUpdate :: KinesisFirehoseOutputUpdate #

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) #

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) #

Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream to write to.

KinesisStreamsInput

data KinesisStreamsInput #

Identifies an Amazon Kinesis stream as the streaming source. You provide the stream's ARN and an IAM role ARN that enables Amazon Kinesis Analytics to access the stream on your behalf.

See: kinesisStreamsInput smart constructor.

Instances

Eq KinesisStreamsInput # 
Data KinesisStreamsInput # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisStreamsInput -> c KinesisStreamsInput #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisStreamsInput #

toConstr :: KinesisStreamsInput -> Constr #

dataTypeOf :: KinesisStreamsInput -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisStreamsInput) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisStreamsInput) #

gmapT :: (forall b. Data b => b -> b) -> KinesisStreamsInput -> KinesisStreamsInput #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsInput -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsInput -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisStreamsInput -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisStreamsInput -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisStreamsInput -> m KinesisStreamsInput #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsInput -> m KinesisStreamsInput #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsInput -> m KinesisStreamsInput #

Read KinesisStreamsInput # 
Show KinesisStreamsInput # 
Generic KinesisStreamsInput # 
Hashable KinesisStreamsInput # 
ToJSON KinesisStreamsInput # 
NFData KinesisStreamsInput # 

Methods

rnf :: KinesisStreamsInput -> () #

type Rep KinesisStreamsInput # 
type Rep KinesisStreamsInput = D1 (MetaData "KinesisStreamsInput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisStreamsInput'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksiResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_ksiRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))))

kinesisStreamsInput #

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 #

ARN of the input Amazon Kinesis stream to read.

ksiRoleARN :: Lens' KinesisStreamsInput Text #

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 #

Describes the Amazon Kinesis stream that is configured as the streaming source in the application input configuration.

See: kinesisStreamsInputDescription smart constructor.

Instances

Eq KinesisStreamsInputDescription # 
Data KinesisStreamsInputDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisStreamsInputDescription -> c KinesisStreamsInputDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisStreamsInputDescription #

toConstr :: KinesisStreamsInputDescription -> Constr #

dataTypeOf :: KinesisStreamsInputDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisStreamsInputDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisStreamsInputDescription) #

gmapT :: (forall b. Data b => b -> b) -> KinesisStreamsInputDescription -> KinesisStreamsInputDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsInputDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsInputDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisStreamsInputDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisStreamsInputDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisStreamsInputDescription -> m KinesisStreamsInputDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsInputDescription -> m KinesisStreamsInputDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsInputDescription -> m KinesisStreamsInputDescription #

Read KinesisStreamsInputDescription # 
Show KinesisStreamsInputDescription # 
Generic KinesisStreamsInputDescription # 
Hashable KinesisStreamsInputDescription # 
FromJSON KinesisStreamsInputDescription # 
NFData KinesisStreamsInputDescription # 
type Rep KinesisStreamsInputDescription # 
type Rep KinesisStreamsInputDescription = D1 (MetaData "KinesisStreamsInputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisStreamsInputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksidResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksidRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsInputDescription :: KinesisStreamsInputDescription #

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) #

Amazon Resource Name (ARN) of the Amazon Kinesis stream.

ksidRoleARN :: Lens' KinesisStreamsInputDescription (Maybe Text) #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.

KinesisStreamsInputUpdate

data KinesisStreamsInputUpdate #

When updating application input configuration, provides information about an Amazon Kinesis stream as the streaming source.

See: kinesisStreamsInputUpdate smart constructor.

Instances

Eq KinesisStreamsInputUpdate # 
Data KinesisStreamsInputUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisStreamsInputUpdate -> c KinesisStreamsInputUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisStreamsInputUpdate #

toConstr :: KinesisStreamsInputUpdate -> Constr #

dataTypeOf :: KinesisStreamsInputUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisStreamsInputUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisStreamsInputUpdate) #

gmapT :: (forall b. Data b => b -> b) -> KinesisStreamsInputUpdate -> KinesisStreamsInputUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsInputUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsInputUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisStreamsInputUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisStreamsInputUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisStreamsInputUpdate -> m KinesisStreamsInputUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsInputUpdate -> m KinesisStreamsInputUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsInputUpdate -> m KinesisStreamsInputUpdate #

Read KinesisStreamsInputUpdate # 
Show KinesisStreamsInputUpdate # 
Generic KinesisStreamsInputUpdate # 
Hashable KinesisStreamsInputUpdate # 
ToJSON KinesisStreamsInputUpdate # 
NFData KinesisStreamsInputUpdate # 
type Rep KinesisStreamsInputUpdate # 
type Rep KinesisStreamsInputUpdate = D1 (MetaData "KinesisStreamsInputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisStreamsInputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksiuRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksiuResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsInputUpdate :: KinesisStreamsInputUpdate #

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) #

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) #

Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.

KinesisStreamsOutput

data KinesisStreamsOutput #

When configuring application output, identifies a 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.

Instances

Eq KinesisStreamsOutput # 
Data KinesisStreamsOutput # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisStreamsOutput -> c KinesisStreamsOutput #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisStreamsOutput #

toConstr :: KinesisStreamsOutput -> Constr #

dataTypeOf :: KinesisStreamsOutput -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisStreamsOutput) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisStreamsOutput) #

gmapT :: (forall b. Data b => b -> b) -> KinesisStreamsOutput -> KinesisStreamsOutput #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsOutput -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsOutput -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisStreamsOutput -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisStreamsOutput -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisStreamsOutput -> m KinesisStreamsOutput #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsOutput -> m KinesisStreamsOutput #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsOutput -> m KinesisStreamsOutput #

Read KinesisStreamsOutput # 
Show KinesisStreamsOutput # 
Generic KinesisStreamsOutput # 
Hashable KinesisStreamsOutput # 
ToJSON KinesisStreamsOutput # 
NFData KinesisStreamsOutput # 

Methods

rnf :: KinesisStreamsOutput -> () #

type Rep KinesisStreamsOutput # 
type Rep KinesisStreamsOutput = D1 (MetaData "KinesisStreamsOutput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisStreamsOutput'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksoResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_ksoRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))))

kinesisStreamsOutput #

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 #

ARN of the destination Amazon Kinesis stream to write to.

ksoRoleARN :: Lens' KinesisStreamsOutput Text #

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 #

For an application output, describes the Amazon Kinesis stream configured as its destination.

See: kinesisStreamsOutputDescription smart constructor.

Instances

Eq KinesisStreamsOutputDescription # 
Data KinesisStreamsOutputDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisStreamsOutputDescription -> c KinesisStreamsOutputDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisStreamsOutputDescription #

toConstr :: KinesisStreamsOutputDescription -> Constr #

dataTypeOf :: KinesisStreamsOutputDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisStreamsOutputDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisStreamsOutputDescription) #

gmapT :: (forall b. Data b => b -> b) -> KinesisStreamsOutputDescription -> KinesisStreamsOutputDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsOutputDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsOutputDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisStreamsOutputDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisStreamsOutputDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisStreamsOutputDescription -> m KinesisStreamsOutputDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsOutputDescription -> m KinesisStreamsOutputDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsOutputDescription -> m KinesisStreamsOutputDescription #

Read KinesisStreamsOutputDescription # 
Show KinesisStreamsOutputDescription # 
Generic KinesisStreamsOutputDescription # 
Hashable KinesisStreamsOutputDescription # 
FromJSON KinesisStreamsOutputDescription # 
NFData KinesisStreamsOutputDescription # 
type Rep KinesisStreamsOutputDescription # 
type Rep KinesisStreamsOutputDescription = D1 (MetaData "KinesisStreamsOutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisStreamsOutputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksodResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksodRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsOutputDescription :: KinesisStreamsOutputDescription #

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) #

Amazon Resource Name (ARN) of the Amazon Kinesis stream.

ksodRoleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text) #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.

KinesisStreamsOutputUpdate

data KinesisStreamsOutputUpdate #

When updating an output configuration using the UpdateApplication operation, provides information about an Amazon Kinesis stream configured as the destination.

See: kinesisStreamsOutputUpdate smart constructor.

Instances

Eq KinesisStreamsOutputUpdate # 
Data KinesisStreamsOutputUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> KinesisStreamsOutputUpdate -> c KinesisStreamsOutputUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c KinesisStreamsOutputUpdate #

toConstr :: KinesisStreamsOutputUpdate -> Constr #

dataTypeOf :: KinesisStreamsOutputUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c KinesisStreamsOutputUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c KinesisStreamsOutputUpdate) #

gmapT :: (forall b. Data b => b -> b) -> KinesisStreamsOutputUpdate -> KinesisStreamsOutputUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsOutputUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> KinesisStreamsOutputUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> KinesisStreamsOutputUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> KinesisStreamsOutputUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> KinesisStreamsOutputUpdate -> m KinesisStreamsOutputUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsOutputUpdate -> m KinesisStreamsOutputUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> KinesisStreamsOutputUpdate -> m KinesisStreamsOutputUpdate #

Read KinesisStreamsOutputUpdate # 
Show KinesisStreamsOutputUpdate # 
Generic KinesisStreamsOutputUpdate # 
Hashable KinesisStreamsOutputUpdate # 
ToJSON KinesisStreamsOutputUpdate # 
NFData KinesisStreamsOutputUpdate # 
type Rep KinesisStreamsOutputUpdate # 
type Rep KinesisStreamsOutputUpdate = D1 (MetaData "KinesisStreamsOutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "KinesisStreamsOutputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksouRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksouResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsOutputUpdate :: KinesisStreamsOutputUpdate #

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) #

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) #

Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want to write the output.

MappingParameters

data 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.

See: mappingParameters smart constructor.

Instances

Eq MappingParameters # 
Data MappingParameters # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> MappingParameters -> c MappingParameters #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c MappingParameters #

toConstr :: MappingParameters -> Constr #

dataTypeOf :: MappingParameters -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c MappingParameters) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c MappingParameters) #

gmapT :: (forall b. Data b => b -> b) -> MappingParameters -> MappingParameters #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> MappingParameters -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> MappingParameters -> r #

gmapQ :: (forall d. Data d => d -> u) -> MappingParameters -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> MappingParameters -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> MappingParameters -> m MappingParameters #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> MappingParameters -> m MappingParameters #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> MappingParameters -> m MappingParameters #

Read MappingParameters # 
Show MappingParameters # 
Generic MappingParameters # 
Hashable MappingParameters # 
ToJSON MappingParameters # 
FromJSON MappingParameters # 
NFData MappingParameters # 

Methods

rnf :: MappingParameters -> () #

type Rep MappingParameters # 
type Rep MappingParameters = D1 (MetaData "MappingParameters" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "MappingParameters'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_mpCSVMappingParameters") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe CSVMappingParameters))) (S1 (MetaSel (Just Symbol "_mpJSONMappingParameters") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe JSONMappingParameters)))))

mappingParameters :: MappingParameters #

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) #

Provides additional mapping information when the record format uses delimiters (for example, CSV).

mpJSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters) #

Provides additional mapping information when JSON is the record format on the streaming source.

Output

data 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.

You can configure your application to write output to up to five destinations.

See: output smart constructor.

Instances

Eq Output # 

Methods

(==) :: Output -> Output -> Bool #

(/=) :: Output -> Output -> Bool #

Data Output # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> Output -> c Output #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c Output #

toConstr :: Output -> Constr #

dataTypeOf :: Output -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c Output) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c Output) #

gmapT :: (forall b. Data b => b -> b) -> Output -> Output #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> Output -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> Output -> r #

gmapQ :: (forall d. Data d => d -> u) -> Output -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> Output -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> Output -> m Output #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> Output -> m Output #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> Output -> m Output #

Read Output # 
Show Output # 
Generic Output # 

Associated Types

type Rep Output :: * -> * #

Methods

from :: Output -> Rep Output x #

to :: Rep Output x -> Output #

Hashable Output # 

Methods

hashWithSalt :: Int -> Output -> Int #

hash :: Output -> Int #

ToJSON Output # 
NFData Output # 

Methods

rnf :: Output -> () #

type Rep Output # 
type Rep Output = D1 (MetaData "Output" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "Output'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_oKinesisStreamsOutput") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsOutput))) (S1 (MetaSel (Just Symbol "_oKinesisFirehoseOutput") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseOutput)))) ((:*:) (S1 (MetaSel (Just Symbol "_oName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_oDestinationSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 DestinationSchema)))))

output #

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:

oKinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput) #

Identifies an Amazon Kinesis stream as the destination.

oKinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput) #

Identifies an Amazon Kinesis Firehose delivery stream as the destination.

oName :: Lens' Output Text #

Name of the in-application stream.

OutputDescription

data OutputDescription #

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.

Instances

Eq OutputDescription # 
Data OutputDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> OutputDescription -> c OutputDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c OutputDescription #

toConstr :: OutputDescription -> Constr #

dataTypeOf :: OutputDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c OutputDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c OutputDescription) #

gmapT :: (forall b. Data b => b -> b) -> OutputDescription -> OutputDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> OutputDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> OutputDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> OutputDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> OutputDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> OutputDescription -> m OutputDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> OutputDescription -> m OutputDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> OutputDescription -> m OutputDescription #

Read OutputDescription # 
Show OutputDescription # 
Generic OutputDescription # 
Hashable OutputDescription # 
FromJSON OutputDescription # 
NFData OutputDescription # 

Methods

rnf :: OutputDescription -> () #

type Rep OutputDescription # 
type Rep OutputDescription = D1 (MetaData "OutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "OutputDescription'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_odOutputId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_odDestinationSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe DestinationSchema)))) ((:*:) (S1 (MetaSel (Just Symbol "_odKinesisFirehoseOutputDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseOutputDescription))) ((:*:) (S1 (MetaSel (Just Symbol "_odKinesisStreamsOutputDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsOutputDescription))) (S1 (MetaSel (Just Symbol "_odName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))))

outputDescription :: OutputDescription #

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 :: Lens' OutputDescription (Maybe Text) #

A unique identifier for the output configuration.

odDestinationSchema :: Lens' OutputDescription (Maybe DestinationSchema) #

Data format used for writing data to the destination.

odKinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription) #

Describes the Amazon Kinesis Firehose delivery stream configured as the destination where output is written.

odKinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription) #

Describes Amazon Kinesis stream configured as the destination where output is written.

odName :: Lens' OutputDescription (Maybe Text) #

Name of the in-application stream configured as output.

OutputUpdate

data OutputUpdate #

Describes updates to the output configuration identified by the OutputId .

See: outputUpdate smart constructor.

Instances

Eq OutputUpdate # 
Data OutputUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> OutputUpdate -> c OutputUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c OutputUpdate #

toConstr :: OutputUpdate -> Constr #

dataTypeOf :: OutputUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c OutputUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c OutputUpdate) #

gmapT :: (forall b. Data b => b -> b) -> OutputUpdate -> OutputUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> OutputUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> OutputUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> OutputUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> OutputUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> OutputUpdate -> m OutputUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> OutputUpdate -> m OutputUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> OutputUpdate -> m OutputUpdate #

Read OutputUpdate # 
Show OutputUpdate # 
Generic OutputUpdate # 

Associated Types

type Rep OutputUpdate :: * -> * #

Hashable OutputUpdate # 
ToJSON OutputUpdate # 
NFData OutputUpdate # 

Methods

rnf :: OutputUpdate -> () #

type Rep OutputUpdate # 
type Rep OutputUpdate = D1 (MetaData "OutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "OutputUpdate'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_ouKinesisStreamsOutputUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsOutputUpdate))) (S1 (MetaSel (Just Symbol "_ouDestinationSchemaUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe DestinationSchema)))) ((:*:) (S1 (MetaSel (Just Symbol "_ouKinesisFirehoseOutputUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseOutputUpdate))) ((:*:) (S1 (MetaSel (Just Symbol "_ouNameUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ouOutputId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))))))

outputUpdate #

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 :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate) #

Describes an Amazon Kinesis stream as the destination for the output.

ouKinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate) #

Describes a Amazon Kinesis Firehose delivery stream as the destination for the output.

ouNameUpdate :: Lens' OutputUpdate (Maybe Text) #

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.

ouOutputId :: Lens' OutputUpdate Text #

Identifies the specific output configuration that you want to update.

RecordColumn

data RecordColumn #

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.

Instances

Eq RecordColumn # 
Data RecordColumn # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> RecordColumn -> c RecordColumn #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c RecordColumn #

toConstr :: RecordColumn -> Constr #

dataTypeOf :: RecordColumn -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c RecordColumn) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c RecordColumn) #

gmapT :: (forall b. Data b => b -> b) -> RecordColumn -> RecordColumn #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> RecordColumn -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> RecordColumn -> r #

gmapQ :: (forall d. Data d => d -> u) -> RecordColumn -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> RecordColumn -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> RecordColumn -> m RecordColumn #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> RecordColumn -> m RecordColumn #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> RecordColumn -> m RecordColumn #

Read RecordColumn # 
Show RecordColumn # 
Generic RecordColumn # 

Associated Types

type Rep RecordColumn :: * -> * #

Hashable RecordColumn # 
ToJSON RecordColumn # 
FromJSON RecordColumn # 
NFData RecordColumn # 

Methods

rnf :: RecordColumn -> () #

type Rep RecordColumn # 
type Rep RecordColumn = D1 (MetaData "RecordColumn" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "RecordColumn'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_rcMapping") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) ((:*:) (S1 (MetaSel (Just Symbol "_rcName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_rcSqlType") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 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 - Reference to the data element in the streaming input of the reference data source.
  • rcName - Name of the column created in the in-application input stream or reference table.
  • rcSqlType - Type of column created in the in-application input stream or reference table.

rcMapping :: Lens' RecordColumn (Maybe Text) #

Reference to the data element in the streaming input of the reference data source.

rcName :: Lens' RecordColumn Text #

Name of the column created in the in-application input stream or reference table.

rcSqlType :: Lens' RecordColumn Text #

Type of column created in the in-application input stream or reference table.

RecordFormat

data RecordFormat #

Describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

See: recordFormat smart constructor.

Instances

Eq RecordFormat # 
Data RecordFormat # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> RecordFormat -> c RecordFormat #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c RecordFormat #

toConstr :: RecordFormat -> Constr #

dataTypeOf :: RecordFormat -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c RecordFormat) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c RecordFormat) #

gmapT :: (forall b. Data b => b -> b) -> RecordFormat -> RecordFormat #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> RecordFormat -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> RecordFormat -> r #

gmapQ :: (forall d. Data d => d -> u) -> RecordFormat -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> RecordFormat -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> RecordFormat -> m RecordFormat #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> RecordFormat -> m RecordFormat #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> RecordFormat -> m RecordFormat #

Read RecordFormat # 
Show RecordFormat # 
Generic RecordFormat # 

Associated Types

type Rep RecordFormat :: * -> * #

Hashable RecordFormat # 
ToJSON RecordFormat # 
FromJSON RecordFormat # 
NFData RecordFormat # 

Methods

rnf :: RecordFormat -> () #

type Rep RecordFormat # 
type Rep RecordFormat = D1 (MetaData "RecordFormat" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "RecordFormat'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_rfMappingParameters") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe MappingParameters))) (S1 (MetaSel (Just Symbol "_rfRecordFormatType") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 RecordFormatType))))

recordFormat #

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:

ReferenceDataSource

data ReferenceDataSource #

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.

Instances

Eq ReferenceDataSource # 
Data ReferenceDataSource # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ReferenceDataSource -> c ReferenceDataSource #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ReferenceDataSource #

toConstr :: ReferenceDataSource -> Constr #

dataTypeOf :: ReferenceDataSource -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c ReferenceDataSource) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ReferenceDataSource) #

gmapT :: (forall b. Data b => b -> b) -> ReferenceDataSource -> ReferenceDataSource #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ReferenceDataSource -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ReferenceDataSource -> r #

gmapQ :: (forall d. Data d => d -> u) -> ReferenceDataSource -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ReferenceDataSource -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ReferenceDataSource -> m ReferenceDataSource #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ReferenceDataSource -> m ReferenceDataSource #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ReferenceDataSource -> m ReferenceDataSource #

Read ReferenceDataSource # 
Show ReferenceDataSource # 
Generic ReferenceDataSource # 
Hashable ReferenceDataSource # 
ToJSON ReferenceDataSource # 
NFData ReferenceDataSource # 

Methods

rnf :: ReferenceDataSource -> () #

type Rep ReferenceDataSource # 
type Rep ReferenceDataSource = D1 (MetaData "ReferenceDataSource" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "ReferenceDataSource'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_rdsS3ReferenceDataSource") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe S3ReferenceDataSource))) ((:*:) (S1 (MetaSel (Just Symbol "_rdsTableName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_rdsReferenceSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 SourceSchema)))))

referenceDataSource #

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:

rdsTableName :: Lens' ReferenceDataSource Text #

Name of the in-application table to create.

ReferenceDataSourceDescription

data ReferenceDataSourceDescription #

Describes the reference data source configured for an application.

See: referenceDataSourceDescription smart constructor.

Instances

Eq ReferenceDataSourceDescription # 
Data ReferenceDataSourceDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ReferenceDataSourceDescription -> c ReferenceDataSourceDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ReferenceDataSourceDescription #

toConstr :: ReferenceDataSourceDescription -> Constr #

dataTypeOf :: ReferenceDataSourceDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c ReferenceDataSourceDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ReferenceDataSourceDescription) #

gmapT :: (forall b. Data b => b -> b) -> ReferenceDataSourceDescription -> ReferenceDataSourceDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ReferenceDataSourceDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ReferenceDataSourceDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> ReferenceDataSourceDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ReferenceDataSourceDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ReferenceDataSourceDescription -> m ReferenceDataSourceDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ReferenceDataSourceDescription -> m ReferenceDataSourceDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ReferenceDataSourceDescription -> m ReferenceDataSourceDescription #

Read ReferenceDataSourceDescription # 
Show ReferenceDataSourceDescription # 
Generic ReferenceDataSourceDescription # 
Hashable ReferenceDataSourceDescription # 
FromJSON ReferenceDataSourceDescription # 
NFData ReferenceDataSourceDescription # 
type Rep ReferenceDataSourceDescription # 
type Rep ReferenceDataSourceDescription = D1 (MetaData "ReferenceDataSourceDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "ReferenceDataSourceDescription'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_rdsdReferenceSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceSchema))) (S1 (MetaSel (Just Symbol "_rdsdReferenceId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))) ((:*:) (S1 (MetaSel (Just Symbol "_rdsdTableName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_rdsdS3ReferenceDataSourceDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 S3ReferenceDataSourceDescription)))))

referenceDataSourceDescription #

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 - Undocumented member.
  • 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 the AddApplicationReferenceDataSource 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.

rdsdReferenceId :: Lens' ReferenceDataSourceDescription Text #

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 #

The in-application table name created by the specific reference data source configuration.

rdsdS3ReferenceDataSourceDescription :: Lens' 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.

ReferenceDataSourceUpdate

data ReferenceDataSourceUpdate #

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.

Instances

Eq ReferenceDataSourceUpdate # 
Data ReferenceDataSourceUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> ReferenceDataSourceUpdate -> c ReferenceDataSourceUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c ReferenceDataSourceUpdate #

toConstr :: ReferenceDataSourceUpdate -> Constr #

dataTypeOf :: ReferenceDataSourceUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c ReferenceDataSourceUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c ReferenceDataSourceUpdate) #

gmapT :: (forall b. Data b => b -> b) -> ReferenceDataSourceUpdate -> ReferenceDataSourceUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> ReferenceDataSourceUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> ReferenceDataSourceUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> ReferenceDataSourceUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> ReferenceDataSourceUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> ReferenceDataSourceUpdate -> m ReferenceDataSourceUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> ReferenceDataSourceUpdate -> m ReferenceDataSourceUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> ReferenceDataSourceUpdate -> m ReferenceDataSourceUpdate #

Read ReferenceDataSourceUpdate # 
Show ReferenceDataSourceUpdate # 
Generic ReferenceDataSourceUpdate # 
Hashable ReferenceDataSourceUpdate # 
ToJSON ReferenceDataSourceUpdate # 
NFData ReferenceDataSourceUpdate # 
type Rep ReferenceDataSourceUpdate # 
type Rep ReferenceDataSourceUpdate = D1 (MetaData "ReferenceDataSourceUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "ReferenceDataSourceUpdate'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_rdsuTableNameUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_rdsuS3ReferenceDataSourceUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe S3ReferenceDataSourceUpdate)))) ((:*:) (S1 (MetaSel (Just Symbol "_rdsuReferenceSchemaUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceSchema))) (S1 (MetaSel (Just Symbol "_rdsuReferenceId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))))

referenceDataSourceUpdate #

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 - Undocumented member.
  • rdsuReferenceId - ID of the reference data source being updated. You can use the DescribeApplication operation to get this value.

rdsuTableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text) #

In-application table name that is created by this update.

rdsuS3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe 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.

rdsuReferenceId :: Lens' ReferenceDataSourceUpdate Text #

ID of the reference data source being updated. You can use the DescribeApplication operation to get this value.

S3ReferenceDataSource

data 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.

See: s3ReferenceDataSource smart constructor.

Instances

Eq S3ReferenceDataSource # 
Data S3ReferenceDataSource # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> S3ReferenceDataSource -> c S3ReferenceDataSource #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c S3ReferenceDataSource #

toConstr :: S3ReferenceDataSource -> Constr #

dataTypeOf :: S3ReferenceDataSource -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c S3ReferenceDataSource) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c S3ReferenceDataSource) #

gmapT :: (forall b. Data b => b -> b) -> S3ReferenceDataSource -> S3ReferenceDataSource #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> S3ReferenceDataSource -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> S3ReferenceDataSource -> r #

gmapQ :: (forall d. Data d => d -> u) -> S3ReferenceDataSource -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> S3ReferenceDataSource -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> S3ReferenceDataSource -> m S3ReferenceDataSource #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> S3ReferenceDataSource -> m S3ReferenceDataSource #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> S3ReferenceDataSource -> m S3ReferenceDataSource #

Read S3ReferenceDataSource # 
Show S3ReferenceDataSource # 
Generic S3ReferenceDataSource # 
Hashable S3ReferenceDataSource # 
ToJSON S3ReferenceDataSource # 
NFData S3ReferenceDataSource # 

Methods

rnf :: S3ReferenceDataSource -> () #

type Rep S3ReferenceDataSource # 
type Rep S3ReferenceDataSource = D1 (MetaData "S3ReferenceDataSource" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "S3ReferenceDataSource'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_srdsBucketARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) ((:*:) (S1 (MetaSel (Just Symbol "_srdsFileKey") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_srdsReferenceRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))))

s3ReferenceDataSource #

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 the s3:GetObject action on the object and trust policy that allows Amazon Kinesis Analytics service principal to assume this role.

srdsBucketARN :: Lens' S3ReferenceDataSource Text #

Amazon Resource Name (ARN) of the S3 bucket.

srdsFileKey :: Lens' S3ReferenceDataSource Text #

Object key name containing reference data.

srdsReferenceRoleARN :: Lens' S3ReferenceDataSource Text #

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 #

Provides the bucket name and object key name that stores the reference data.

See: s3ReferenceDataSourceDescription smart constructor.

Instances

Eq S3ReferenceDataSourceDescription # 
Data S3ReferenceDataSourceDescription # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> S3ReferenceDataSourceDescription -> c S3ReferenceDataSourceDescription #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c S3ReferenceDataSourceDescription #

toConstr :: S3ReferenceDataSourceDescription -> Constr #

dataTypeOf :: S3ReferenceDataSourceDescription -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c S3ReferenceDataSourceDescription) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c S3ReferenceDataSourceDescription) #

gmapT :: (forall b. Data b => b -> b) -> S3ReferenceDataSourceDescription -> S3ReferenceDataSourceDescription #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> S3ReferenceDataSourceDescription -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> S3ReferenceDataSourceDescription -> r #

gmapQ :: (forall d. Data d => d -> u) -> S3ReferenceDataSourceDescription -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> S3ReferenceDataSourceDescription -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> S3ReferenceDataSourceDescription -> m S3ReferenceDataSourceDescription #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> S3ReferenceDataSourceDescription -> m S3ReferenceDataSourceDescription #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> S3ReferenceDataSourceDescription -> m S3ReferenceDataSourceDescription #

Read S3ReferenceDataSourceDescription # 
Show S3ReferenceDataSourceDescription # 
Generic S3ReferenceDataSourceDescription # 
Hashable S3ReferenceDataSourceDescription # 
FromJSON S3ReferenceDataSourceDescription # 
NFData S3ReferenceDataSourceDescription # 
type Rep S3ReferenceDataSourceDescription # 
type Rep S3ReferenceDataSourceDescription = D1 (MetaData "S3ReferenceDataSourceDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "S3ReferenceDataSourceDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_srdsdBucketARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) ((:*:) (S1 (MetaSel (Just Symbol "_srdsdFileKey") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_srdsdReferenceRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 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 #

Amazon Resource Name (ARN) of the S3 bucket.

srdsdReferenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text #

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 #

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.

Instances

Eq S3ReferenceDataSourceUpdate # 
Data S3ReferenceDataSourceUpdate # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> S3ReferenceDataSourceUpdate -> c S3ReferenceDataSourceUpdate #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c S3ReferenceDataSourceUpdate #

toConstr :: S3ReferenceDataSourceUpdate -> Constr #

dataTypeOf :: S3ReferenceDataSourceUpdate -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c S3ReferenceDataSourceUpdate) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c S3ReferenceDataSourceUpdate) #

gmapT :: (forall b. Data b => b -> b) -> S3ReferenceDataSourceUpdate -> S3ReferenceDataSourceUpdate #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> S3ReferenceDataSourceUpdate -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> S3ReferenceDataSourceUpdate -> r #

gmapQ :: (forall d. Data d => d -> u) -> S3ReferenceDataSourceUpdate -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> S3ReferenceDataSourceUpdate -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> S3ReferenceDataSourceUpdate -> m S3ReferenceDataSourceUpdate #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> S3ReferenceDataSourceUpdate -> m S3ReferenceDataSourceUpdate #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> S3ReferenceDataSourceUpdate -> m S3ReferenceDataSourceUpdate #

Read S3ReferenceDataSourceUpdate # 
Show S3ReferenceDataSourceUpdate # 
Generic S3ReferenceDataSourceUpdate # 
Hashable S3ReferenceDataSourceUpdate # 
ToJSON S3ReferenceDataSourceUpdate # 
NFData S3ReferenceDataSourceUpdate # 
type Rep S3ReferenceDataSourceUpdate # 
type Rep S3ReferenceDataSourceUpdate = D1 (MetaData "S3ReferenceDataSourceUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "S3ReferenceDataSourceUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_srdsuBucketARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) ((:*:) (S1 (MetaSel (Just Symbol "_srdsuFileKeyUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_srdsuReferenceRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))))

s3ReferenceDataSourceUpdate :: S3ReferenceDataSourceUpdate #

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 :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) #

Amazon Resource Name (ARN) of the S3 bucket.

srdsuReferenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) #

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 #

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.

Instances

Eq SourceSchema # 
Data SourceSchema # 

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> SourceSchema -> c SourceSchema #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c SourceSchema #

toConstr :: SourceSchema -> Constr #

dataTypeOf :: SourceSchema -> DataType #

dataCast1 :: Typeable (* -> *) t => (forall d. Data d => c (t d)) -> Maybe (c SourceSchema) #

dataCast2 :: Typeable (* -> * -> *) t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c SourceSchema) #

gmapT :: (forall b. Data b => b -> b) -> SourceSchema -> SourceSchema #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> SourceSchema -> r #

gmapQr :: (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> SourceSchema -> r #

gmapQ :: (forall d. Data d => d -> u) -> SourceSchema -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> SourceSchema -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> SourceSchema -> m SourceSchema #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> SourceSchema -> m SourceSchema #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> SourceSchema -> m SourceSchema #

Read SourceSchema # 
Show SourceSchema # 
Generic SourceSchema # 

Associated Types

type Rep SourceSchema :: * -> * #

Hashable SourceSchema # 
ToJSON SourceSchema # 
FromJSON SourceSchema # 
NFData SourceSchema # 

Methods

rnf :: SourceSchema -> () #

type Rep SourceSchema # 
type Rep SourceSchema = D1 (MetaData "SourceSchema" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.4.5-H83WG5KfDkB7lwaI8ml04Y" False) (C1 (MetaCons "SourceSchema'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ssRecordEncoding") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) ((:*:) (S1 (MetaSel (Just Symbol "_ssRecordFormat") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 RecordFormat)) (S1 (MetaSel (Just Symbol "_ssRecordColumns") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (List1 RecordColumn))))))

sourceSchema #

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 of RecordColumn objects.

ssRecordEncoding :: Lens' SourceSchema (Maybe Text) #

Specifies the encoding of the records in the streaming source. For example, UTF-8.

ssRecordFormat :: Lens' SourceSchema RecordFormat #

Specifies the format of the records on the streaming source.

ssRecordColumns :: Lens' SourceSchema (NonEmpty RecordColumn) #

A list of RecordColumn objects.