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

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

Network.AWS.KinesisAnalytics.Types

Contents

Description

 

Synopsis

Service Configuration

kinesisAnalytics :: Service Source #

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

Errors

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

User-provided application configuration is not valid.

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

Discovery failed to get a record from the streaming source because of the Amazon Kinesis Streams ProvisionedThroughputExceededException. For more information, see GetRecords in the Amazon Kinesis Streams API Reference.

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

Specified input parameter value is invalid.

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

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

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

Exception thrown as a result of concurrent modification to an application. For example, two individuals attempting to edit the same application at the same time.

_ServiceUnavailableException :: AsError a => Getting (First ServiceError) a ServiceError Source #

The service is unavailable, back off and retry the operation.

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

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

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

Specified application can't be found.

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

Exceeded the number of applications allowed.

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

Application is not available for this operation.

ApplicationStatus

data ApplicationStatus Source #

Instances

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

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 Source # 
Read ApplicationStatus Source # 
Show ApplicationStatus Source # 
Generic ApplicationStatus Source # 
Hashable ApplicationStatus Source # 
FromJSON ApplicationStatus Source # 
NFData ApplicationStatus Source # 

Methods

rnf :: ApplicationStatus -> () #

ToHeader ApplicationStatus Source # 
ToQuery ApplicationStatus Source # 
ToByteString ApplicationStatus Source # 
FromText ApplicationStatus Source # 
ToText ApplicationStatus Source # 
type Rep ApplicationStatus Source # 
type Rep ApplicationStatus = D1 * (MetaData "ApplicationStatus" "Network.AWS.KinesisAnalytics.Types.Sum" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Instances

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

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 Source # 
Read InputStartingPosition Source # 
Show InputStartingPosition Source # 
Generic InputStartingPosition Source # 
Hashable InputStartingPosition Source # 
ToJSON InputStartingPosition Source # 
FromJSON InputStartingPosition Source # 
NFData InputStartingPosition Source # 

Methods

rnf :: InputStartingPosition -> () #

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

RecordFormatType

data RecordFormatType Source #

Constructors

CSV 
JSON 

Instances

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

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 Source # 
Read RecordFormatType Source # 
Show RecordFormatType Source # 
Generic RecordFormatType Source # 
Hashable RecordFormatType Source # 
ToJSON RecordFormatType Source # 
FromJSON RecordFormatType Source # 
NFData RecordFormatType Source # 

Methods

rnf :: RecordFormatType -> () #

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

ApplicationDetail

data ApplicationDetail Source #

Provides a description of the application, including the application Amazon Resource Name (ARN), status, latest version, and input and output configuration.

See: applicationDetail smart constructor.

Instances

Eq ApplicationDetail Source # 
Data ApplicationDetail Source # 

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 Source # 
Show ApplicationDetail Source # 
Generic ApplicationDetail Source # 
Hashable ApplicationDetail Source # 
FromJSON ApplicationDetail Source # 
NFData ApplicationDetail Source # 

Methods

rnf :: ApplicationDetail -> () #

type Rep ApplicationDetail Source # 
type Rep ApplicationDetail = D1 * (MetaData "ApplicationDetail" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 "_adCloudWatchLoggingOptionDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe [CloudWatchLoggingOptionDescription]))))) ((:*:) * (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 Source #

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

Description of the application.

adOutputDescriptions :: Lens' ApplicationDetail [OutputDescription] Source #

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

adCloudWatchLoggingOptionDescriptions :: Lens' ApplicationDetail [CloudWatchLoggingOptionDescription] Source #

Describes the CloudWatch log streams that are configured to receive application messages. For more information about using CloudWatch log streams with Amazon Kinesis Analytics applications, see Working with Amazon CloudWatch Logs .

adReferenceDataSourceDescriptions :: Lens' ApplicationDetail [ReferenceDataSourceDescription] Source #

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

adInputDescriptions :: Lens' ApplicationDetail [InputDescription] Source #

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

adApplicationCode :: Lens' ApplicationDetail (Maybe Text) Source #

Returns the application code that you provided to perform data analysis on any of the in-application streams in your application.

adCreateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime) Source #

Time stamp when the application version was created.

adLastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime) Source #

Time stamp when the application was last updated.

adApplicationVersionId :: Lens' ApplicationDetail Natural Source #

Provides the current application version.

ApplicationSummary

data ApplicationSummary Source #

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

See: applicationSummary smart constructor.

Instances

Eq ApplicationSummary Source # 
Data ApplicationSummary Source # 

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 Source # 
Show ApplicationSummary Source # 
Generic ApplicationSummary Source # 
Hashable ApplicationSummary Source # 
FromJSON ApplicationSummary Source # 
NFData ApplicationSummary Source # 

Methods

rnf :: ApplicationSummary -> () #

type Rep ApplicationSummary Source # 
type Rep ApplicationSummary = D1 * (MetaData "ApplicationSummary" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

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:

ApplicationUpdate

data ApplicationUpdate Source #

Describes updates to apply to an existing Amazon Kinesis Analytics application.

See: applicationUpdate smart constructor.

Instances

Eq ApplicationUpdate Source # 
Data ApplicationUpdate Source # 

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 Source # 
Show ApplicationUpdate Source # 
Generic ApplicationUpdate Source # 
Hashable ApplicationUpdate Source # 
ToJSON ApplicationUpdate Source # 
NFData ApplicationUpdate Source # 

Methods

rnf :: ApplicationUpdate -> () #

type Rep ApplicationUpdate Source # 
type Rep ApplicationUpdate = D1 * (MetaData "ApplicationUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 "_auCloudWatchLoggingOptionUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe [CloudWatchLoggingOptionUpdate]))) ((:*:) * (S1 * (MetaSel (Just Symbol "_auOutputUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe [OutputUpdate]))) (S1 * (MetaSel (Just Symbol "_auApplicationCodeUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text)))))))

applicationUpdate :: ApplicationUpdate Source #

Creates a value of ApplicationUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

auReferenceDataSourceUpdates :: Lens' ApplicationUpdate [ReferenceDataSourceUpdate] Source #

Describes application reference data source updates.

auInputUpdates :: Lens' ApplicationUpdate [InputUpdate] Source #

Describes application input configuration updates.

auCloudWatchLoggingOptionUpdates :: Lens' ApplicationUpdate [CloudWatchLoggingOptionUpdate] Source #

Describes application CloudWatch logging option updates.

auOutputUpdates :: Lens' ApplicationUpdate [OutputUpdate] Source #

Describes application output configuration updates.

auApplicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text) Source #

Describes application code updates.

CSVMappingParameters

data CSVMappingParameters Source #

Provides additional mapping information when the record format uses delimiters, such as CSV. For example, the following sample records use CSV format, where the records use the '\n' as the row delimiter and a comma (",") as the column delimiter:

"name1", "address1"
"name2, "address2"

See: csvMappingParameters smart constructor.

Instances

Eq CSVMappingParameters Source # 
Data CSVMappingParameters Source # 

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 Source # 
Show CSVMappingParameters Source # 
Generic CSVMappingParameters Source # 
Hashable CSVMappingParameters Source # 
ToJSON CSVMappingParameters Source # 
FromJSON CSVMappingParameters Source # 
NFData CSVMappingParameters Source # 

Methods

rnf :: CSVMappingParameters -> () #

type Rep CSVMappingParameters Source # 
type Rep CSVMappingParameters = D1 * (MetaData "CSVMappingParameters" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

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

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

cmpRecordColumnDelimiter :: Lens' CSVMappingParameters Text Source #

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

CloudWatchLoggingOption

data CloudWatchLoggingOption Source #

Provides a description of CloudWatch logging options, including the log stream Amazon Resource Name (ARN) and the role ARN.

See: cloudWatchLoggingOption smart constructor.

Instances

Eq CloudWatchLoggingOption Source # 
Data CloudWatchLoggingOption Source # 

Methods

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

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

toConstr :: CloudWatchLoggingOption -> Constr #

dataTypeOf :: CloudWatchLoggingOption -> DataType #

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

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

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

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

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

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

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

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

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

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

Read CloudWatchLoggingOption Source # 
Show CloudWatchLoggingOption Source # 
Generic CloudWatchLoggingOption Source # 
Hashable CloudWatchLoggingOption Source # 
ToJSON CloudWatchLoggingOption Source # 
NFData CloudWatchLoggingOption Source # 

Methods

rnf :: CloudWatchLoggingOption -> () #

type Rep CloudWatchLoggingOption Source # 
type Rep CloudWatchLoggingOption = D1 * (MetaData "CloudWatchLoggingOption" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "CloudWatchLoggingOption'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_cwloLogStreamARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_cwloRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text))))

cloudWatchLoggingOption Source #

Creates a value of CloudWatchLoggingOption with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • cwloLogStreamARN - ARN of the CloudWatch log to receive application messages.
  • cwloRoleARN - IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role that is used must have the PutLogEvents policy action enabled.

cwloLogStreamARN :: Lens' CloudWatchLoggingOption Text Source #

ARN of the CloudWatch log to receive application messages.

cwloRoleARN :: Lens' CloudWatchLoggingOption Text Source #

IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role that is used must have the PutLogEvents policy action enabled.

CloudWatchLoggingOptionDescription

data CloudWatchLoggingOptionDescription Source #

Description of the CloudWatch logging option.

See: cloudWatchLoggingOptionDescription smart constructor.

Instances

Eq CloudWatchLoggingOptionDescription Source # 
Data CloudWatchLoggingOptionDescription Source # 

Methods

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

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

toConstr :: CloudWatchLoggingOptionDescription -> Constr #

dataTypeOf :: CloudWatchLoggingOptionDescription -> DataType #

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

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

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

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

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

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

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

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

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

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

Read CloudWatchLoggingOptionDescription Source # 
Show CloudWatchLoggingOptionDescription Source # 
Generic CloudWatchLoggingOptionDescription Source # 
Hashable CloudWatchLoggingOptionDescription Source # 
FromJSON CloudWatchLoggingOptionDescription Source # 
NFData CloudWatchLoggingOptionDescription Source # 
type Rep CloudWatchLoggingOptionDescription Source # 
type Rep CloudWatchLoggingOptionDescription = D1 * (MetaData "CloudWatchLoggingOptionDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "CloudWatchLoggingOptionDescription'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_cwlodCloudWatchLoggingOptionId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) ((:*:) * (S1 * (MetaSel (Just Symbol "_cwlodLogStreamARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_cwlodRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)))))

cloudWatchLoggingOptionDescription Source #

Creates a value of CloudWatchLoggingOptionDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • cwlodCloudWatchLoggingOptionId - ID of the CloudWatch logging option description.
  • cwlodLogStreamARN - ARN of the CloudWatch log to receive application messages.
  • cwlodRoleARN - IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role used must have the PutLogEvents policy action enabled.

cwlodCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionDescription (Maybe Text) Source #

ID of the CloudWatch logging option description.

cwlodLogStreamARN :: Lens' CloudWatchLoggingOptionDescription Text Source #

ARN of the CloudWatch log to receive application messages.

cwlodRoleARN :: Lens' CloudWatchLoggingOptionDescription Text Source #

IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role used must have the PutLogEvents policy action enabled.

CloudWatchLoggingOptionUpdate

data CloudWatchLoggingOptionUpdate Source #

Describes CloudWatch logging option updates.

See: cloudWatchLoggingOptionUpdate smart constructor.

Instances

Eq CloudWatchLoggingOptionUpdate Source # 
Data CloudWatchLoggingOptionUpdate Source # 

Methods

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

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

toConstr :: CloudWatchLoggingOptionUpdate -> Constr #

dataTypeOf :: CloudWatchLoggingOptionUpdate -> DataType #

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

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

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

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

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

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

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

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

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

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

Read CloudWatchLoggingOptionUpdate Source # 
Show CloudWatchLoggingOptionUpdate Source # 
Generic CloudWatchLoggingOptionUpdate Source # 
Hashable CloudWatchLoggingOptionUpdate Source # 
ToJSON CloudWatchLoggingOptionUpdate Source # 
NFData CloudWatchLoggingOptionUpdate Source # 
type Rep CloudWatchLoggingOptionUpdate Source # 
type Rep CloudWatchLoggingOptionUpdate = D1 * (MetaData "CloudWatchLoggingOptionUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "CloudWatchLoggingOptionUpdate'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_cwlouRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) ((:*:) * (S1 * (MetaSel (Just Symbol "_cwlouLogStreamARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "_cwlouCloudWatchLoggingOptionId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)))))

cloudWatchLoggingOptionUpdate Source #

Creates a value of CloudWatchLoggingOptionUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • cwlouRoleARNUpdate - IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role used must have the PutLogEvents policy action enabled.
  • cwlouLogStreamARNUpdate - ARN of the CloudWatch log to receive application messages.
  • cwlouCloudWatchLoggingOptionId - ID of the CloudWatch logging option to update

cwlouRoleARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text) Source #

IAM ARN of the role to use to send application messages. Note: To write application messages to CloudWatch, the IAM role used must have the PutLogEvents policy action enabled.

cwlouLogStreamARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text) Source #

ARN of the CloudWatch log to receive application messages.

cwlouCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionUpdate Text Source #

ID of the CloudWatch logging option to update

DestinationSchema

data DestinationSchema Source #

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

See: destinationSchema smart constructor.

Instances

Eq DestinationSchema Source # 
Data DestinationSchema Source # 

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 Source # 
Show DestinationSchema Source # 
Generic DestinationSchema Source # 
Hashable DestinationSchema Source # 
ToJSON DestinationSchema Source # 
FromJSON DestinationSchema Source # 
NFData DestinationSchema Source # 

Methods

rnf :: DestinationSchema -> () #

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

destinationSchema :: DestinationSchema Source #

Creates a value of DestinationSchema with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

dsRecordFormatType :: Lens' DestinationSchema (Maybe RecordFormatType) Source #

Specifies the format of the records on the output stream.

Input

data Input Source #

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

Methods

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

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

Data Input Source # 

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 Source # 
Show Input Source # 

Methods

showsPrec :: Int -> Input -> ShowS #

show :: Input -> String #

showList :: [Input] -> ShowS #

Generic Input Source # 

Associated Types

type Rep Input :: * -> * #

Methods

from :: Input -> Rep Input x #

to :: Rep Input x -> Input #

Hashable Input Source # 

Methods

hashWithSalt :: Int -> Input -> Int #

hash :: Input -> Int #

ToJSON Input Source # 
NFData Input Source # 

Methods

rnf :: Input -> () #

type Rep Input Source # 
type Rep Input = D1 * (MetaData "Input" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "Input'" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_iInputParallelism") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe InputParallelism))) ((:*:) * (S1 * (MetaSel (Just Symbol "_iInputProcessingConfiguration") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe InputProcessingConfiguration))) (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 Source #

Creates a value of Input with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • iInputParallelism - Describes the number of in-application streams to create. Data from your source is routed to these in-application input streams. (see Configuring Application Input .
  • iInputProcessingConfiguration - The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor .
  • iKinesisStreamsInput - If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
  • iKinesisFirehoseInput - If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
  • iNamePrefix - Name prefix to use when creating an in-application stream. Suppose that you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the InputParallelism count you specified) in-application streams with names "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.
  • iInputSchema - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created. Also used to describe the format of the reference data source.

iInputParallelism :: Lens' Input (Maybe InputParallelism) Source #

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

iInputProcessingConfiguration :: Lens' Input (Maybe InputProcessingConfiguration) Source #

The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor .

iKinesisStreamsInput :: Lens' Input (Maybe KinesisStreamsInput) Source #

If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.

iKinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput) Source #

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

iNamePrefix :: Lens' Input Text Source #

Name prefix to use when creating an in-application stream. Suppose that you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the InputParallelism count you specified) in-application streams with names "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.

iInputSchema :: Lens' Input SourceSchema Source #

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created. Also used to describe the format of the reference data source.

InputConfiguration

data InputConfiguration Source #

When you start your application, you provide this configuration, which identifies the input source and the point in the input source at which you want the application to start processing records.

See: inputConfiguration smart constructor.

Instances

Eq InputConfiguration Source # 
Data InputConfiguration Source # 

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 Source # 
Show InputConfiguration Source # 
Generic InputConfiguration Source # 
Hashable InputConfiguration Source # 
ToJSON InputConfiguration Source # 
NFData InputConfiguration Source # 

Methods

rnf :: InputConfiguration -> () #

type Rep InputConfiguration Source # 
type Rep InputConfiguration = D1 * (MetaData "InputConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

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

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

icInputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration Source #

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

InputDescription

data InputDescription Source #

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

See: inputDescription smart constructor.

Instances

Eq InputDescription Source # 
Data InputDescription Source # 

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 Source # 
Show InputDescription Source # 
Generic InputDescription Source # 
Hashable InputDescription Source # 
FromJSON InputDescription Source # 
NFData InputDescription Source # 

Methods

rnf :: InputDescription -> () #

type Rep InputDescription Source # 
type Rep InputDescription = D1 * (MetaData "InputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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))) (S1 * (MetaSel (Just Symbol "_idInputProcessingConfigurationDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe InputProcessingConfigurationDescription))))))))

inputDescription :: InputDescription Source #

Creates a value of InputDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • idInputStartingPositionConfiguration - Point at which the application is configured to read from the input stream.
  • idInputParallelism - Describes the configured parallelism (number of in-application streams mapped to the streaming source).
  • idInputId - Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.
  • idInAppStreamNames - Returns the in-application stream names that are mapped to the stream source.
  • idKinesisFirehoseInputDescription - If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
  • idInputSchema - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
  • idKinesisStreamsInputDescription - If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
  • idNamePrefix - In-application name prefix.
  • idInputProcessingConfigurationDescription - The description of the preprocessor that executes on records in this input before the application's code is run.

idInputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration) Source #

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

idInputParallelism :: Lens' InputDescription (Maybe InputParallelism) Source #

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

idInputId :: Lens' InputDescription (Maybe Text) Source #

Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.

idInAppStreamNames :: Lens' InputDescription [Text] Source #

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

idKinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription) Source #

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

idInputSchema :: Lens' InputDescription (Maybe SourceSchema) Source #

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.

idKinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription) Source #

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

idNamePrefix :: Lens' InputDescription (Maybe Text) Source #

In-application name prefix.

idInputProcessingConfigurationDescription :: Lens' InputDescription (Maybe InputProcessingConfigurationDescription) Source #

The description of the preprocessor that executes on records in this input before the application's code is run.

InputLambdaProcessor

data InputLambdaProcessor Source #

An object that contains the Amazon Resource Name (ARN) of the AWS Lambda function that is used to preprocess records in the stream, and the ARN of the IAM role that is used to access the AWS Lambda function.

See: inputLambdaProcessor smart constructor.

Instances

Eq InputLambdaProcessor Source # 
Data InputLambdaProcessor Source # 

Methods

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

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

toConstr :: InputLambdaProcessor -> Constr #

dataTypeOf :: InputLambdaProcessor -> DataType #

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

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

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

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

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

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

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

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

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

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

Read InputLambdaProcessor Source # 
Show InputLambdaProcessor Source # 
Generic InputLambdaProcessor Source # 
Hashable InputLambdaProcessor Source # 
ToJSON InputLambdaProcessor Source # 
NFData InputLambdaProcessor Source # 

Methods

rnf :: InputLambdaProcessor -> () #

type Rep InputLambdaProcessor Source # 
type Rep InputLambdaProcessor = D1 * (MetaData "InputLambdaProcessor" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "InputLambdaProcessor'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_ilpResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_ilpRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text))))

inputLambdaProcessor Source #

Creates a value of InputLambdaProcessor with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ilpResourceARN - The ARN of the AWS Lambda function that operates on records in the stream.
  • ilpRoleARN - The ARN of the IAM role that is used to access the AWS Lambda function.

ilpResourceARN :: Lens' InputLambdaProcessor Text Source #

The ARN of the AWS Lambda function that operates on records in the stream.

ilpRoleARN :: Lens' InputLambdaProcessor Text Source #

The ARN of the IAM role that is used to access the AWS Lambda function.

InputLambdaProcessorDescription

data InputLambdaProcessorDescription Source #

An object that contains the Amazon Resource Name (ARN) of the AWS Lambda function that is used to preprocess records in the stream, and the ARN of the IAM role that is used to access the AWS Lambda expression.

See: inputLambdaProcessorDescription smart constructor.

Instances

Eq InputLambdaProcessorDescription Source # 
Data InputLambdaProcessorDescription Source # 

Methods

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

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

toConstr :: InputLambdaProcessorDescription -> Constr #

dataTypeOf :: InputLambdaProcessorDescription -> DataType #

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

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

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

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

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

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

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

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

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

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

Read InputLambdaProcessorDescription Source # 
Show InputLambdaProcessorDescription Source # 
Generic InputLambdaProcessorDescription Source # 
Hashable InputLambdaProcessorDescription Source # 
FromJSON InputLambdaProcessorDescription Source # 
NFData InputLambdaProcessorDescription Source # 
type Rep InputLambdaProcessorDescription Source # 
type Rep InputLambdaProcessorDescription = D1 * (MetaData "InputLambdaProcessorDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "InputLambdaProcessorDescription'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_ilpdResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "_ilpdRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text)))))

inputLambdaProcessorDescription :: InputLambdaProcessorDescription Source #

Creates a value of InputLambdaProcessorDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ilpdResourceARN - The ARN of the AWS Lambda function that is used to preprocess the records in the stream.
  • ilpdRoleARN - The ARN of the IAM role that is used to access the AWS Lambda function.

ilpdResourceARN :: Lens' InputLambdaProcessorDescription (Maybe Text) Source #

The ARN of the AWS Lambda function that is used to preprocess the records in the stream.

ilpdRoleARN :: Lens' InputLambdaProcessorDescription (Maybe Text) Source #

The ARN of the IAM role that is used to access the AWS Lambda function.

InputLambdaProcessorUpdate

data InputLambdaProcessorUpdate Source #

Represents an update to the InputLambdaProcessor that is used to preprocess the records in the stream.

See: inputLambdaProcessorUpdate smart constructor.

Instances

Eq InputLambdaProcessorUpdate Source # 
Data InputLambdaProcessorUpdate Source # 

Methods

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

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

toConstr :: InputLambdaProcessorUpdate -> Constr #

dataTypeOf :: InputLambdaProcessorUpdate -> DataType #

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

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

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

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

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

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

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

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

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

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

Read InputLambdaProcessorUpdate Source # 
Show InputLambdaProcessorUpdate Source # 
Generic InputLambdaProcessorUpdate Source # 
Hashable InputLambdaProcessorUpdate Source # 
ToJSON InputLambdaProcessorUpdate Source # 
NFData InputLambdaProcessorUpdate Source # 
type Rep InputLambdaProcessorUpdate Source # 
type Rep InputLambdaProcessorUpdate = D1 * (MetaData "InputLambdaProcessorUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "InputLambdaProcessorUpdate'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_ilpuRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "_ilpuResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text)))))

inputLambdaProcessorUpdate :: InputLambdaProcessorUpdate Source #

Creates a value of InputLambdaProcessorUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ilpuRoleARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text) Source #

The ARN of the new IAM role that is used to access the AWS Lambda function.

ilpuResourceARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text) Source #

The Amazon Resource Name (ARN) of the new AWS Lambda function that is used to preprocess the records in the stream.

InputParallelism

data InputParallelism Source #

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

See: inputParallelism smart constructor.

Instances

Eq InputParallelism Source # 
Data InputParallelism Source # 

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 Source # 
Show InputParallelism Source # 
Generic InputParallelism Source # 
Hashable InputParallelism Source # 
ToJSON InputParallelism Source # 
FromJSON InputParallelism Source # 
NFData InputParallelism Source # 

Methods

rnf :: InputParallelism -> () #

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

inputParallelism :: InputParallelism Source #

Creates a value of InputParallelism with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

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

ipCount :: Lens' InputParallelism (Maybe Natural) Source #

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

InputParallelismUpdate

data InputParallelismUpdate Source #

Provides updates to the parallelism count.

See: inputParallelismUpdate smart constructor.

Instances

Eq InputParallelismUpdate Source # 
Data InputParallelismUpdate Source # 

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 Source # 
Show InputParallelismUpdate Source # 
Generic InputParallelismUpdate Source # 
Hashable InputParallelismUpdate Source # 
ToJSON InputParallelismUpdate Source # 
NFData InputParallelismUpdate Source # 

Methods

rnf :: InputParallelismUpdate -> () #

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

inputParallelismUpdate :: InputParallelismUpdate Source #

Creates a value of InputParallelismUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

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

ipuCountUpdate :: Lens' InputParallelismUpdate (Maybe Natural) Source #

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

InputProcessingConfiguration

data InputProcessingConfiguration Source #

Provides a description of a processor that is used to preprocess the records in the stream before being processed by your application code. Currently, the only input processor available is AWS Lambda .

See: inputProcessingConfiguration smart constructor.

Instances

Eq InputProcessingConfiguration Source # 
Data InputProcessingConfiguration Source # 

Methods

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

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

toConstr :: InputProcessingConfiguration -> Constr #

dataTypeOf :: InputProcessingConfiguration -> DataType #

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

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

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

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

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

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

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

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

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

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

Read InputProcessingConfiguration Source # 
Show InputProcessingConfiguration Source # 
Generic InputProcessingConfiguration Source # 
Hashable InputProcessingConfiguration Source # 
ToJSON InputProcessingConfiguration Source # 
NFData InputProcessingConfiguration Source # 
type Rep InputProcessingConfiguration Source # 
type Rep InputProcessingConfiguration = D1 * (MetaData "InputProcessingConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" True) (C1 * (MetaCons "InputProcessingConfiguration'" PrefixI True) (S1 * (MetaSel (Just Symbol "_ipcInputLambdaProcessor") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * InputLambdaProcessor)))

inputProcessingConfiguration Source #

Creates a value of InputProcessingConfiguration with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

ipcInputLambdaProcessor :: Lens' InputProcessingConfiguration InputLambdaProcessor Source #

The InputLambdaProcessor that is used to preprocess the records in the stream before being processed by your application code.

InputProcessingConfigurationDescription

data InputProcessingConfigurationDescription Source #

Provides configuration information about an input processor. Currently, the only input processor available is AWS Lambda .

See: inputProcessingConfigurationDescription smart constructor.

Instances

Eq InputProcessingConfigurationDescription Source # 
Data InputProcessingConfigurationDescription Source # 

Methods

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

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

toConstr :: InputProcessingConfigurationDescription -> Constr #

dataTypeOf :: InputProcessingConfigurationDescription -> DataType #

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

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

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

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

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

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

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

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

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

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

Read InputProcessingConfigurationDescription Source # 
Show InputProcessingConfigurationDescription Source # 
Generic InputProcessingConfigurationDescription Source # 
Hashable InputProcessingConfigurationDescription Source # 
FromJSON InputProcessingConfigurationDescription Source # 
NFData InputProcessingConfigurationDescription Source # 
type Rep InputProcessingConfigurationDescription Source # 
type Rep InputProcessingConfigurationDescription = D1 * (MetaData "InputProcessingConfigurationDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" True) (C1 * (MetaCons "InputProcessingConfigurationDescription'" PrefixI True) (S1 * (MetaSel (Just Symbol "_ipcdInputLambdaProcessorDescription") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Maybe InputLambdaProcessorDescription))))

inputProcessingConfigurationDescription :: InputProcessingConfigurationDescription Source #

Creates a value of InputProcessingConfigurationDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

InputProcessingConfigurationUpdate

data InputProcessingConfigurationUpdate Source #

Describes updates to an InputProcessingConfiguration .

See: inputProcessingConfigurationUpdate smart constructor.

Instances

Eq InputProcessingConfigurationUpdate Source # 
Data InputProcessingConfigurationUpdate Source # 

Methods

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

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

toConstr :: InputProcessingConfigurationUpdate -> Constr #

dataTypeOf :: InputProcessingConfigurationUpdate -> DataType #

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

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

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

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

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

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

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

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

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

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

Read InputProcessingConfigurationUpdate Source # 
Show InputProcessingConfigurationUpdate Source # 
Generic InputProcessingConfigurationUpdate Source # 
Hashable InputProcessingConfigurationUpdate Source # 
ToJSON InputProcessingConfigurationUpdate Source # 
NFData InputProcessingConfigurationUpdate Source # 
type Rep InputProcessingConfigurationUpdate Source # 
type Rep InputProcessingConfigurationUpdate = D1 * (MetaData "InputProcessingConfigurationUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" True) (C1 * (MetaCons "InputProcessingConfigurationUpdate'" PrefixI True) (S1 * (MetaSel (Just Symbol "_ipcuInputLambdaProcessorUpdate") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * InputLambdaProcessorUpdate)))

inputProcessingConfigurationUpdate Source #

Creates a value of InputProcessingConfigurationUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

InputSchemaUpdate

data InputSchemaUpdate Source #

Describes updates for the application's input schema.

See: inputSchemaUpdate smart constructor.

Instances

Eq InputSchemaUpdate Source # 
Data InputSchemaUpdate Source # 

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 Source # 
Show InputSchemaUpdate Source # 
Generic InputSchemaUpdate Source # 
Hashable InputSchemaUpdate Source # 
ToJSON InputSchemaUpdate Source # 
NFData InputSchemaUpdate Source # 

Methods

rnf :: InputSchemaUpdate -> () #

type Rep InputSchemaUpdate Source # 
type Rep InputSchemaUpdate = D1 * (MetaData "InputSchemaUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of InputSchemaUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • isuRecordFormatUpdate - Specifies the format of the records on the streaming source.
  • isuRecordEncodingUpdate - Specifies the encoding of the records in the streaming source. For example, UTF-8.
  • isuRecordColumnUpdates - A list 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) Source #

Specifies the format of the records on the streaming source.

isuRecordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text) Source #

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

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

A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.

InputStartingPositionConfiguration

data InputStartingPositionConfiguration Source #

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

See: inputStartingPositionConfiguration smart constructor.

Instances

Eq InputStartingPositionConfiguration Source # 
Data InputStartingPositionConfiguration Source # 

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 Source # 
Show InputStartingPositionConfiguration Source # 
Generic InputStartingPositionConfiguration Source # 
Hashable InputStartingPositionConfiguration Source # 
ToJSON InputStartingPositionConfiguration Source # 
FromJSON InputStartingPositionConfiguration Source # 
NFData InputStartingPositionConfiguration Source # 
type Rep InputStartingPositionConfiguration Source # 
type Rep InputStartingPositionConfiguration = D1 * (MetaData "InputStartingPositionConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" True) (C1 * (MetaCons "InputStartingPositionConfiguration'" PrefixI True) (S1 * (MetaSel (Just Symbol "_ispcInputStartingPosition") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Maybe InputStartingPosition))))

inputStartingPositionConfiguration :: InputStartingPositionConfiguration Source #

Creates a value of InputStartingPositionConfiguration with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ispcInputStartingPosition - The starting position on the stream. * NOW - Start reading just after the most recent record in the stream, start at the request time stamp that the customer issued. * TRIM_HORIZON - Start reading at the last untrimmed record in the stream, which is the oldest record available in the stream. This option is not available for an Amazon Kinesis Firehose delivery stream. * LAST_STOPPED_POINT - Resume reading from where the application last stopped reading.

ispcInputStartingPosition :: Lens' InputStartingPositionConfiguration (Maybe InputStartingPosition) Source #

The starting position on the stream. * NOW - Start reading just after the most recent record in the stream, start at the request time stamp that the customer issued. * TRIM_HORIZON - Start reading at the last untrimmed record in the stream, which is the oldest record available in the stream. This option is not available for an Amazon Kinesis Firehose delivery stream. * LAST_STOPPED_POINT - Resume reading from where the application last stopped reading.

InputUpdate

data InputUpdate Source #

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

See: inputUpdate smart constructor.

Instances

Eq InputUpdate Source # 
Data InputUpdate Source # 

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 Source # 
Show InputUpdate Source # 
Generic InputUpdate Source # 

Associated Types

type Rep InputUpdate :: * -> * #

Hashable InputUpdate Source # 
ToJSON InputUpdate Source # 
NFData InputUpdate Source # 

Methods

rnf :: InputUpdate -> () #

type Rep InputUpdate Source # 
type Rep InputUpdate = D1 * (MetaData "InputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "InputUpdate'" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_iuInputProcessingConfigurationUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe InputProcessingConfigurationUpdate))) ((:*:) * (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 Source #

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:

  • iuInputProcessingConfigurationUpdate - Describes updates for an input processing configuration.
  • iuKinesisStreamsInputUpdate - If an Amazon Kinesis stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN) and IAM role ARN.
  • iuInputParallelismUpdate - Describes the parallelism updates (the number in-application streams Amazon Kinesis Analytics creates for the specific streaming source).
  • iuNamePrefixUpdate - Name prefix for in-application streams that Amazon Kinesis Analytics creates for the specific streaming source.
  • iuInputSchemaUpdate - Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.
  • iuKinesisFirehoseInputUpdate - If an Amazon Kinesis Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.
  • iuInputId - Input ID of the application input to be updated.

iuInputProcessingConfigurationUpdate :: Lens' InputUpdate (Maybe InputProcessingConfigurationUpdate) Source #

Describes updates for an input processing configuration.

iuKinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate) Source #

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

iuInputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate) Source #

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

iuNamePrefixUpdate :: Lens' InputUpdate (Maybe Text) Source #

Name prefix for in-application streams that Amazon Kinesis Analytics creates for the specific streaming source.

iuInputSchemaUpdate :: Lens' InputUpdate (Maybe InputSchemaUpdate) Source #

Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.

iuKinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate) Source #

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

iuInputId :: Lens' InputUpdate Text Source #

Input ID of the application input to be updated.

JSONMappingParameters

data JSONMappingParameters Source #

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

See: jsonMappingParameters smart constructor.

Instances

Eq JSONMappingParameters Source # 
Data JSONMappingParameters Source # 

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 Source # 
Show JSONMappingParameters Source # 
Generic JSONMappingParameters Source # 
Hashable JSONMappingParameters Source # 
ToJSON JSONMappingParameters Source # 
FromJSON JSONMappingParameters Source # 
NFData JSONMappingParameters Source # 

Methods

rnf :: JSONMappingParameters -> () #

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

jsonMappingParameters Source #

Creates a value of JSONMappingParameters with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

jmpRecordRowPath :: Lens' JSONMappingParameters Text Source #

Path to the top-level parent that contains the records.

KinesisFirehoseInput

data KinesisFirehoseInput Source #

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

See: kinesisFirehoseInput smart constructor.

Instances

Eq KinesisFirehoseInput Source # 
Data KinesisFirehoseInput Source # 

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 Source # 
Show KinesisFirehoseInput Source # 
Generic KinesisFirehoseInput Source # 
Hashable KinesisFirehoseInput Source # 
ToJSON KinesisFirehoseInput Source # 
NFData KinesisFirehoseInput Source # 

Methods

rnf :: KinesisFirehoseInput -> () #

type Rep KinesisFirehoseInput Source # 
type Rep KinesisFirehoseInput = D1 * (MetaData "KinesisFirehoseInput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisFirehoseInput with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • kfiResourceARN - ARN of the input delivery stream.
  • kfiRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to make sure the role has necessary permissions to access the stream.

kfiResourceARN :: Lens' KinesisFirehoseInput Text Source #

ARN of the input delivery stream.

kfiRoleARN :: Lens' KinesisFirehoseInput Text Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to make sure the role has necessary permissions to access the stream.

KinesisFirehoseInputDescription

data KinesisFirehoseInputDescription Source #

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

See: kinesisFirehoseInputDescription smart constructor.

Instances

Eq KinesisFirehoseInputDescription Source # 
Data KinesisFirehoseInputDescription Source # 

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 Source # 
Show KinesisFirehoseInputDescription Source # 
Generic KinesisFirehoseInputDescription Source # 
Hashable KinesisFirehoseInputDescription Source # 
FromJSON KinesisFirehoseInputDescription Source # 
NFData KinesisFirehoseInputDescription Source # 
type Rep KinesisFirehoseInputDescription Source # 
type Rep KinesisFirehoseInputDescription = D1 * (MetaData "KinesisFirehoseInputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisFirehoseInputDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • kfidResourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.
  • kfidRoleARN - ARN of the IAM role that Amazon Kinesis Analytics assumes to access the stream.

kfidResourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text) Source #

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

kfidRoleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text) Source #

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

KinesisFirehoseInputUpdate

data KinesisFirehoseInputUpdate Source #

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

See: kinesisFirehoseInputUpdate smart constructor.

Instances

Eq KinesisFirehoseInputUpdate Source # 
Data KinesisFirehoseInputUpdate Source # 

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 Source # 
Show KinesisFirehoseInputUpdate Source # 
Generic KinesisFirehoseInputUpdate Source # 
Hashable KinesisFirehoseInputUpdate Source # 
ToJSON KinesisFirehoseInputUpdate Source # 
NFData KinesisFirehoseInputUpdate Source # 
type Rep KinesisFirehoseInputUpdate Source # 
type Rep KinesisFirehoseInputUpdate = D1 * (MetaData "KinesisFirehoseInputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisFirehoseInputUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • kfiuRoleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant necessary permissions to this role.
  • kfiuResourceARNUpdate - Amazon Resource Name (ARN) of the input Amazon Kinesis Firehose delivery stream to read.

kfiuRoleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text) Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant necessary permissions to this role.

kfiuResourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text) Source #

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

KinesisFirehoseOutput

data KinesisFirehoseOutput Source #

When configuring application output, identifies an Amazon Kinesis Firehose delivery stream as the destination. You provide the stream Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to write to the stream on your behalf.

See: kinesisFirehoseOutput smart constructor.

Instances

Eq KinesisFirehoseOutput Source # 
Data KinesisFirehoseOutput Source # 

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 Source # 
Show KinesisFirehoseOutput Source # 
Generic KinesisFirehoseOutput Source # 
Hashable KinesisFirehoseOutput Source # 
ToJSON KinesisFirehoseOutput Source # 
NFData KinesisFirehoseOutput Source # 

Methods

rnf :: KinesisFirehoseOutput -> () #

type Rep KinesisFirehoseOutput Source # 
type Rep KinesisFirehoseOutput = D1 * (MetaData "KinesisFirehoseOutput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisFirehoseOutput with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • kfoResourceARN - ARN of the destination Amazon Kinesis Firehose delivery stream to write to.
  • kfoRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. You need to grant the necessary permissions to this role.

kfoResourceARN :: Lens' KinesisFirehoseOutput Text Source #

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

kfoRoleARN :: Lens' KinesisFirehoseOutput Text Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. You need to grant the necessary permissions to this role.

KinesisFirehoseOutputDescription

data KinesisFirehoseOutputDescription Source #

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

See: kinesisFirehoseOutputDescription smart constructor.

Instances

Eq KinesisFirehoseOutputDescription Source # 
Data KinesisFirehoseOutputDescription Source # 

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 Source # 
Show KinesisFirehoseOutputDescription Source # 
Generic KinesisFirehoseOutputDescription Source # 
Hashable KinesisFirehoseOutputDescription Source # 
FromJSON KinesisFirehoseOutputDescription Source # 
NFData KinesisFirehoseOutputDescription Source # 
type Rep KinesisFirehoseOutputDescription Source # 
type Rep KinesisFirehoseOutputDescription = D1 * (MetaData "KinesisFirehoseOutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisFirehoseOutputDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • kfodResourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.
  • kfodRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.

kfodResourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text) Source #

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

kfodRoleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text) Source #

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

KinesisFirehoseOutputUpdate

data KinesisFirehoseOutputUpdate Source #

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

See: kinesisFirehoseOutputUpdate smart constructor.

Instances

Eq KinesisFirehoseOutputUpdate Source # 
Data KinesisFirehoseOutputUpdate Source # 

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 Source # 
Show KinesisFirehoseOutputUpdate Source # 
Generic KinesisFirehoseOutputUpdate Source # 
Hashable KinesisFirehoseOutputUpdate Source # 
ToJSON KinesisFirehoseOutputUpdate Source # 
NFData KinesisFirehoseOutputUpdate Source # 
type Rep KinesisFirehoseOutputUpdate Source # 
type Rep KinesisFirehoseOutputUpdate = D1 * (MetaData "KinesisFirehoseOutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisFirehoseOutputUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • kfouRoleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant necessary permissions to this role.
  • kfouResourceARNUpdate - Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream to write to.

kfouRoleARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text) Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant necessary permissions to this role.

kfouResourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text) Source #

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

KinesisStreamsInput

data KinesisStreamsInput Source #

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

See: kinesisStreamsInput smart constructor.

Instances

Eq KinesisStreamsInput Source # 
Data KinesisStreamsInput Source # 

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 Source # 
Show KinesisStreamsInput Source # 
Generic KinesisStreamsInput Source # 
Hashable KinesisStreamsInput Source # 
ToJSON KinesisStreamsInput Source # 
NFData KinesisStreamsInput Source # 

Methods

rnf :: KinesisStreamsInput -> () #

type Rep KinesisStreamsInput Source # 
type Rep KinesisStreamsInput = D1 * (MetaData "KinesisStreamsInput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisStreamsInput with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ksiResourceARN - ARN of the input Amazon Kinesis stream to read.
  • ksiRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.

ksiResourceARN :: Lens' KinesisStreamsInput Text Source #

ARN of the input Amazon Kinesis stream to read.

ksiRoleARN :: Lens' KinesisStreamsInput Text Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.

KinesisStreamsInputDescription

data KinesisStreamsInputDescription Source #

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

See: kinesisStreamsInputDescription smart constructor.

Instances

Eq KinesisStreamsInputDescription Source # 
Data KinesisStreamsInputDescription Source # 

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 Source # 
Show KinesisStreamsInputDescription Source # 
Generic KinesisStreamsInputDescription Source # 
Hashable KinesisStreamsInputDescription Source # 
FromJSON KinesisStreamsInputDescription Source # 
NFData KinesisStreamsInputDescription Source # 
type Rep KinesisStreamsInputDescription Source # 
type Rep KinesisStreamsInputDescription = D1 * (MetaData "KinesisStreamsInputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisStreamsInputDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ksidResourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis stream.
  • ksidRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.

ksidResourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text) Source #

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

ksidRoleARN :: Lens' KinesisStreamsInputDescription (Maybe Text) Source #

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

KinesisStreamsInputUpdate

data KinesisStreamsInputUpdate Source #

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

See: kinesisStreamsInputUpdate smart constructor.

Instances

Eq KinesisStreamsInputUpdate Source # 
Data KinesisStreamsInputUpdate Source # 

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 Source # 
Show KinesisStreamsInputUpdate Source # 
Generic KinesisStreamsInputUpdate Source # 
Hashable KinesisStreamsInputUpdate Source # 
ToJSON KinesisStreamsInputUpdate Source # 
NFData KinesisStreamsInputUpdate Source # 
type Rep KinesisStreamsInputUpdate Source # 
type Rep KinesisStreamsInputUpdate = D1 * (MetaData "KinesisStreamsInputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisStreamsInputUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ksiuRoleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.
  • ksiuResourceARNUpdate - Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.

ksiuRoleARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text) Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.

ksiuResourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text) Source #

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

KinesisStreamsOutput

data KinesisStreamsOutput Source #

When configuring application output, identifies an Amazon Kinesis stream as the destination. You provide the stream Amazon Resource Name (ARN) and also an IAM role ARN that Amazon Kinesis Analytics can use to write to the stream on your behalf.

See: kinesisStreamsOutput smart constructor.

Instances

Eq KinesisStreamsOutput Source # 
Data KinesisStreamsOutput Source # 

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 Source # 
Show KinesisStreamsOutput Source # 
Generic KinesisStreamsOutput Source # 
Hashable KinesisStreamsOutput Source # 
ToJSON KinesisStreamsOutput Source # 
NFData KinesisStreamsOutput Source # 

Methods

rnf :: KinesisStreamsOutput -> () #

type Rep KinesisStreamsOutput Source # 
type Rep KinesisStreamsOutput = D1 * (MetaData "KinesisStreamsOutput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisStreamsOutput with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ksoResourceARN - ARN of the destination Amazon Kinesis stream to write to.
  • ksoRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. You need to grant the necessary permissions to this role.

ksoResourceARN :: Lens' KinesisStreamsOutput Text Source #

ARN of the destination Amazon Kinesis stream to write to.

ksoRoleARN :: Lens' KinesisStreamsOutput Text Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. You need to grant the necessary permissions to this role.

KinesisStreamsOutputDescription

data KinesisStreamsOutputDescription Source #

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

See: kinesisStreamsOutputDescription smart constructor.

Instances

Eq KinesisStreamsOutputDescription Source # 
Data KinesisStreamsOutputDescription Source # 

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 Source # 
Show KinesisStreamsOutputDescription Source # 
Generic KinesisStreamsOutputDescription Source # 
Hashable KinesisStreamsOutputDescription Source # 
FromJSON KinesisStreamsOutputDescription Source # 
NFData KinesisStreamsOutputDescription Source # 
type Rep KinesisStreamsOutputDescription Source # 
type Rep KinesisStreamsOutputDescription = D1 * (MetaData "KinesisStreamsOutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisStreamsOutputDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ksodResourceARN - Amazon Resource Name (ARN) of the Amazon Kinesis stream.
  • ksodRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.

ksodResourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text) Source #

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

ksodRoleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text) Source #

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

KinesisStreamsOutputUpdate

data KinesisStreamsOutputUpdate Source #

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

See: kinesisStreamsOutputUpdate smart constructor.

Instances

Eq KinesisStreamsOutputUpdate Source # 
Data KinesisStreamsOutputUpdate Source # 

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 Source # 
Show KinesisStreamsOutputUpdate Source # 
Generic KinesisStreamsOutputUpdate Source # 
Hashable KinesisStreamsOutputUpdate Source # 
ToJSON KinesisStreamsOutputUpdate Source # 
NFData KinesisStreamsOutputUpdate Source # 
type Rep KinesisStreamsOutputUpdate Source # 
type Rep KinesisStreamsOutputUpdate = D1 * (MetaData "KinesisStreamsOutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of KinesisStreamsOutputUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • ksouRoleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.
  • ksouResourceARNUpdate - Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want to write the output.

ksouRoleARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text) Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf. You need to grant the necessary permissions to this role.

ksouResourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text) Source #

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

LambdaOutput

data LambdaOutput Source #

When configuring application output, identifies an AWS Lambda function as the destination. You provide the function Amazon Resource Name (ARN) and also an IAM role ARN that Amazon Kinesis Analytics can use to write to the function on your behalf.

See: lambdaOutput smart constructor.

Instances

Eq LambdaOutput Source # 
Data LambdaOutput Source # 

Methods

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

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

toConstr :: LambdaOutput -> Constr #

dataTypeOf :: LambdaOutput -> DataType #

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

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

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

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

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

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

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

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

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

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

Read LambdaOutput Source # 
Show LambdaOutput Source # 
Generic LambdaOutput Source # 

Associated Types

type Rep LambdaOutput :: * -> * #

Hashable LambdaOutput Source # 
ToJSON LambdaOutput Source # 
NFData LambdaOutput Source # 

Methods

rnf :: LambdaOutput -> () #

type Rep LambdaOutput Source # 
type Rep LambdaOutput = D1 * (MetaData "LambdaOutput" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "LambdaOutput'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_loResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_loRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text))))

lambdaOutput Source #

Creates a value of LambdaOutput with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • loResourceARN - Amazon Resource Name (ARN) of the destination Lambda function to write to.
  • loRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function on your behalf. You need to grant the necessary permissions to this role.

loResourceARN :: Lens' LambdaOutput Text Source #

Amazon Resource Name (ARN) of the destination Lambda function to write to.

loRoleARN :: Lens' LambdaOutput Text Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function on your behalf. You need to grant the necessary permissions to this role.

LambdaOutputDescription

data LambdaOutputDescription Source #

For an application output, describes the AWS Lambda function configured as its destination.

See: lambdaOutputDescription smart constructor.

Instances

Eq LambdaOutputDescription Source # 
Data LambdaOutputDescription Source # 

Methods

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

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

toConstr :: LambdaOutputDescription -> Constr #

dataTypeOf :: LambdaOutputDescription -> DataType #

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

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

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

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

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

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

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

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

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

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

Read LambdaOutputDescription Source # 
Show LambdaOutputDescription Source # 
Generic LambdaOutputDescription Source # 
Hashable LambdaOutputDescription Source # 
FromJSON LambdaOutputDescription Source # 
NFData LambdaOutputDescription Source # 

Methods

rnf :: LambdaOutputDescription -> () #

type Rep LambdaOutputDescription Source # 
type Rep LambdaOutputDescription = D1 * (MetaData "LambdaOutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "LambdaOutputDescription'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_lodResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "_lodRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text)))))

lambdaOutputDescription :: LambdaOutputDescription Source #

Creates a value of LambdaOutputDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • lodResourceARN - Amazon Resource Name (ARN) of the destination Lambda function.
  • lodRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function.

lodResourceARN :: Lens' LambdaOutputDescription (Maybe Text) Source #

Amazon Resource Name (ARN) of the destination Lambda function.

lodRoleARN :: Lens' LambdaOutputDescription (Maybe Text) Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function.

LambdaOutputUpdate

data LambdaOutputUpdate Source #

When updating an output configuration using the UpdateApplication operation, provides information about an AWS Lambda function configured as the destination.

See: lambdaOutputUpdate smart constructor.

Instances

Eq LambdaOutputUpdate Source # 
Data LambdaOutputUpdate Source # 

Methods

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

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

toConstr :: LambdaOutputUpdate -> Constr #

dataTypeOf :: LambdaOutputUpdate -> DataType #

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

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

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

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

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

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

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

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

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

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

Read LambdaOutputUpdate Source # 
Show LambdaOutputUpdate Source # 
Generic LambdaOutputUpdate Source # 
Hashable LambdaOutputUpdate Source # 
ToJSON LambdaOutputUpdate Source # 
NFData LambdaOutputUpdate Source # 

Methods

rnf :: LambdaOutputUpdate -> () #

type Rep LambdaOutputUpdate Source # 
type Rep LambdaOutputUpdate = D1 * (MetaData "LambdaOutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "LambdaOutputUpdate'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_louRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "_louResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe Text)))))

lambdaOutputUpdate :: LambdaOutputUpdate Source #

Creates a value of LambdaOutputUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • louRoleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function on your behalf. You need to grant the necessary permissions to this role.
  • louResourceARNUpdate - Amazon Resource Name (ARN) of the destination Lambda function.

louRoleARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text) Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to write to the destination function on your behalf. You need to grant the necessary permissions to this role.

louResourceARNUpdate :: Lens' LambdaOutputUpdate (Maybe Text) Source #

Amazon Resource Name (ARN) of the destination Lambda function.

MappingParameters

data MappingParameters Source #

When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

See: mappingParameters smart constructor.

Instances

Eq MappingParameters Source # 
Data MappingParameters Source # 

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 Source # 
Show MappingParameters Source # 
Generic MappingParameters Source # 
Hashable MappingParameters Source # 
ToJSON MappingParameters Source # 
FromJSON MappingParameters Source # 
NFData MappingParameters Source # 

Methods

rnf :: MappingParameters -> () #

type Rep MappingParameters Source # 
type Rep MappingParameters = D1 * (MetaData "MappingParameters" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of MappingParameters with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • mpCSVMappingParameters - Provides additional mapping information when the record format uses delimiters (for example, CSV).
  • mpJSONMappingParameters - Provides additional mapping information when JSON is the record format on the streaming source.

mpCSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters) Source #

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

mpJSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters) Source #

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

Output

data Output Source #

Describes application output configuration in which you identify an in-application stream and a destination where you want the in-application stream data to be written. The destination can be an Amazon Kinesis stream or an Amazon Kinesis Firehose delivery stream.

For limits on how many destinations an application can write and other limitations, see Limits .

See: output smart constructor.

Instances

Eq Output Source # 

Methods

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

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

Data Output Source # 

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 Source # 
Show Output Source # 
Generic Output Source # 

Associated Types

type Rep Output :: * -> * #

Methods

from :: Output -> Rep Output x #

to :: Rep Output x -> Output #

Hashable Output Source # 

Methods

hashWithSalt :: Int -> Output -> Int #

hash :: Output -> Int #

ToJSON Output Source # 
NFData Output Source # 

Methods

rnf :: Output -> () #

type Rep Output Source # 
type Rep Output = D1 * (MetaData "Output" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "Output'" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_oLambdaOutput") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe LambdaOutput))) (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 Source #

Creates a value of Output with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

oLambdaOutput :: Lens' Output (Maybe LambdaOutput) Source #

Identifies an AWS Lambda function as the destination.

oKinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput) Source #

Identifies an Amazon Kinesis stream as the destination.

oKinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput) Source #

Identifies an Amazon Kinesis Firehose delivery stream as the destination.

oName :: Lens' Output Text Source #

Name of the in-application stream.

oDestinationSchema :: Lens' Output DestinationSchema Source #

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

OutputDescription

data OutputDescription Source #

Describes the application output configuration, which includes the in-application stream name and the destination where the stream data is written. The destination can be an Amazon Kinesis stream or an Amazon Kinesis Firehose delivery stream.

See: outputDescription smart constructor.

Instances

Eq OutputDescription Source # 
Data OutputDescription Source # 

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 Source # 
Show OutputDescription Source # 
Generic OutputDescription Source # 
Hashable OutputDescription Source # 
FromJSON OutputDescription Source # 
NFData OutputDescription Source # 

Methods

rnf :: OutputDescription -> () #

type Rep OutputDescription Source # 
type Rep OutputDescription = D1 * (MetaData "OutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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))) (S1 * (MetaSel (Just Symbol "_odLambdaOutputDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe LambdaOutputDescription)))))))

outputDescription :: OutputDescription Source #

Creates a value of OutputDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

odOutputId :: Lens' OutputDescription (Maybe Text) Source #

A unique identifier for the output configuration.

odDestinationSchema :: Lens' OutputDescription (Maybe DestinationSchema) Source #

Data format used for writing data to the destination.

odKinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription) Source #

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

odKinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription) Source #

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

odName :: Lens' OutputDescription (Maybe Text) Source #

Name of the in-application stream configured as output.

odLambdaOutputDescription :: Lens' OutputDescription (Maybe LambdaOutputDescription) Source #

Describes the AWS Lambda function configured as the destination where output is written.

OutputUpdate

data OutputUpdate Source #

Describes updates to the output configuration identified by the OutputId .

See: outputUpdate smart constructor.

Instances

Eq OutputUpdate Source # 
Data OutputUpdate Source # 

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 Source # 
Show OutputUpdate Source # 
Generic OutputUpdate Source # 

Associated Types

type Rep OutputUpdate :: * -> * #

Hashable OutputUpdate Source # 
ToJSON OutputUpdate Source # 
NFData OutputUpdate Source # 

Methods

rnf :: OutputUpdate -> () #

type Rep OutputUpdate Source # 
type Rep OutputUpdate = D1 * (MetaData "OutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 "_ouLambdaOutputUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * (Maybe LambdaOutputUpdate))) (S1 * (MetaSel (Just Symbol "_ouOutputId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text))))))

outputUpdate Source #

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

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

ouDestinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema) Source #

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

ouKinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate) Source #

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

ouNameUpdate :: Lens' OutputUpdate (Maybe Text) Source #

If you want to specify a different in-application stream for this output configuration, use this field to specify the new in-application stream name.

ouLambdaOutputUpdate :: Lens' OutputUpdate (Maybe LambdaOutputUpdate) Source #

Describes an AWS Lambda function as the destination for the output.

ouOutputId :: Lens' OutputUpdate Text Source #

Identifies the specific output configuration that you want to update.

RecordColumn

data RecordColumn Source #

Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.

Also used to describe the format of the reference data source.

See: recordColumn smart constructor.

Instances

Eq RecordColumn Source # 
Data RecordColumn Source # 

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 Source # 
Show RecordColumn Source # 
Generic RecordColumn Source # 

Associated Types

type Rep RecordColumn :: * -> * #

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

Methods

rnf :: RecordColumn -> () #

type Rep RecordColumn Source # 
type Rep RecordColumn = D1 * (MetaData "RecordColumn" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

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

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

rcName :: Lens' RecordColumn Text Source #

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

rcSqlType :: Lens' RecordColumn Text Source #

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

RecordFormat

data RecordFormat Source #

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

See: recordFormat smart constructor.

Instances

Eq RecordFormat Source # 
Data RecordFormat Source # 

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 Source # 
Show RecordFormat Source # 
Generic RecordFormat Source # 

Associated Types

type Rep RecordFormat :: * -> * #

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

Methods

rnf :: RecordFormat -> () #

type Rep RecordFormat Source # 
type Rep RecordFormat = D1 * (MetaData "RecordFormat" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of RecordFormat with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • rfMappingParameters - When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
  • rfRecordFormatType - The type of record format.

rfMappingParameters :: Lens' RecordFormat (Maybe MappingParameters) Source #

When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.

ReferenceDataSource

data ReferenceDataSource Source #

Describes the reference data source by providing the source information (S3 bucket name and object key name), the resulting in-application table name that is created, and the necessary schema to map the data elements in the Amazon S3 object to the in-application table.

See: referenceDataSource smart constructor.

Instances

Eq ReferenceDataSource Source # 
Data ReferenceDataSource Source # 

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 Source # 
Show ReferenceDataSource Source # 
Generic ReferenceDataSource Source # 
Hashable ReferenceDataSource Source # 
ToJSON ReferenceDataSource Source # 
NFData ReferenceDataSource Source # 

Methods

rnf :: ReferenceDataSource -> () #

type Rep ReferenceDataSource Source # 
type Rep ReferenceDataSource = D1 * (MetaData "ReferenceDataSource" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of ReferenceDataSource with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • rdsS3ReferenceDataSource - Identifies the S3 bucket and object that contains the reference data. Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf. An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.
  • rdsTableName - Name of the in-application table to create.
  • rdsReferenceSchema - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

rdsS3ReferenceDataSource :: Lens' ReferenceDataSource (Maybe S3ReferenceDataSource) Source #

Identifies the S3 bucket and object that contains the reference data. Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf. An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

rdsTableName :: Lens' ReferenceDataSource Text Source #

Name of the in-application table to create.

rdsReferenceSchema :: Lens' ReferenceDataSource SourceSchema Source #

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

ReferenceDataSourceDescription

data ReferenceDataSourceDescription Source #

Describes the reference data source configured for an application.

See: referenceDataSourceDescription smart constructor.

Instances

Eq ReferenceDataSourceDescription Source # 
Data ReferenceDataSourceDescription Source # 

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 Source # 
Show ReferenceDataSourceDescription Source # 
Generic ReferenceDataSourceDescription Source # 
Hashable ReferenceDataSourceDescription Source # 
FromJSON ReferenceDataSourceDescription Source # 
NFData ReferenceDataSourceDescription Source # 
type Rep ReferenceDataSourceDescription Source # 
type Rep ReferenceDataSourceDescription = D1 * (MetaData "ReferenceDataSourceDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of ReferenceDataSourceDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • rdsdReferenceSchema - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
  • rdsdReferenceId - ID of the reference data source. This is the ID that Amazon Kinesis Analytics assigns when you add the reference data source to your application using 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.

rdsdReferenceSchema :: Lens' ReferenceDataSourceDescription (Maybe SourceSchema) Source #

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

rdsdReferenceId :: Lens' ReferenceDataSourceDescription Text Source #

ID of the reference data source. This is the ID that Amazon Kinesis Analytics assigns when you add the reference data source to your application using the AddApplicationReferenceDataSource operation.

rdsdTableName :: Lens' ReferenceDataSourceDescription Text Source #

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

rdsdS3ReferenceDataSourceDescription :: Lens' ReferenceDataSourceDescription S3ReferenceDataSourceDescription Source #

Provides the S3 bucket name, the object key name that contains the reference data. It also provides the Amazon Resource Name (ARN) of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application reference table.

ReferenceDataSourceUpdate

data ReferenceDataSourceUpdate Source #

When you update a reference data source configuration for an application, this object provides all the updated values (such as the source bucket name and object key name), the in-application table name that is created, and updated mapping information that maps the data in the Amazon S3 object to the in-application reference table that is created.

See: referenceDataSourceUpdate smart constructor.

Instances

Eq ReferenceDataSourceUpdate Source # 
Data ReferenceDataSourceUpdate Source # 

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 Source # 
Show ReferenceDataSourceUpdate Source # 
Generic ReferenceDataSourceUpdate Source # 
Hashable ReferenceDataSourceUpdate Source # 
ToJSON ReferenceDataSourceUpdate Source # 
NFData ReferenceDataSourceUpdate Source # 
type Rep ReferenceDataSourceUpdate Source # 
type Rep ReferenceDataSourceUpdate = D1 * (MetaData "ReferenceDataSourceUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of ReferenceDataSourceUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • rdsuTableNameUpdate - In-application table name that is created by this update.
  • rdsuS3ReferenceDataSourceUpdate - Describes the S3 bucket name, object key name, and IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf and populate the in-application reference table.
  • rdsuReferenceSchemaUpdate - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
  • rdsuReferenceId - ID of the reference data source being updated. You can use the DescribeApplication operation to get this value.

rdsuTableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text) Source #

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

rdsuS3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe S3ReferenceDataSourceUpdate) Source #

Describes the S3 bucket name, object key name, and IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf and populate the in-application reference table.

rdsuReferenceSchemaUpdate :: Lens' ReferenceDataSourceUpdate (Maybe SourceSchema) Source #

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

rdsuReferenceId :: Lens' ReferenceDataSourceUpdate Text Source #

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

S3Configuration

data S3Configuration Source #

Provides a description of an Amazon S3 data source, including the Amazon Resource Name (ARN) of the S3 bucket, the ARN of the IAM role that is used to access the bucket, and the name of the S3 object that contains the data.

See: s3Configuration smart constructor.

Instances

Eq S3Configuration Source # 
Data S3Configuration Source # 

Methods

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

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

toConstr :: S3Configuration -> Constr #

dataTypeOf :: S3Configuration -> DataType #

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

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

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

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

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

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

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

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

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

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

Read S3Configuration Source # 
Show S3Configuration Source # 
Generic S3Configuration Source # 
Hashable S3Configuration Source # 
ToJSON S3Configuration Source # 
NFData S3Configuration Source # 

Methods

rnf :: S3Configuration -> () #

type Rep S3Configuration Source # 
type Rep S3Configuration = D1 * (MetaData "S3Configuration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" False) (C1 * (MetaCons "S3Configuration'" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_scRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)) ((:*:) * (S1 * (MetaSel (Just Symbol "_scBucketARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_scFileKey") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 * Text)))))

s3Configuration Source #

Creates a value of S3Configuration with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • scRoleARN - IAM ARN of the role used to access the data.
  • scBucketARN - ARN of the S3 bucket that contains the data.
  • scFileKey - The name of the object that contains the data.

scRoleARN :: Lens' S3Configuration Text Source #

IAM ARN of the role used to access the data.

scBucketARN :: Lens' S3Configuration Text Source #

ARN of the S3 bucket that contains the data.

scFileKey :: Lens' S3Configuration Text Source #

The name of the object that contains the data.

S3ReferenceDataSource

data S3ReferenceDataSource Source #

Identifies the S3 bucket and object that contains the reference data. Also identifies the IAM role Amazon Kinesis Analytics can assume to read this object on your behalf.

An Amazon Kinesis Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

See: s3ReferenceDataSource smart constructor.

Instances

Eq S3ReferenceDataSource Source # 
Data S3ReferenceDataSource Source # 

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 Source # 
Show S3ReferenceDataSource Source # 
Generic S3ReferenceDataSource Source # 
Hashable S3ReferenceDataSource Source # 
ToJSON S3ReferenceDataSource Source # 
NFData S3ReferenceDataSource Source # 

Methods

rnf :: S3ReferenceDataSource -> () #

type Rep S3ReferenceDataSource Source # 
type Rep S3ReferenceDataSource = D1 * (MetaData "S3ReferenceDataSource" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of S3ReferenceDataSource with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • srdsBucketARN - Amazon Resource Name (ARN) of the S3 bucket.
  • srdsFileKey - Object key name containing reference data.
  • srdsReferenceRoleARN - ARN of the IAM role that the service can assume to read data on your behalf. This role must have permission for 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 Source #

Amazon Resource Name (ARN) of the S3 bucket.

srdsFileKey :: Lens' S3ReferenceDataSource Text Source #

Object key name containing reference data.

srdsReferenceRoleARN :: Lens' S3ReferenceDataSource Text Source #

ARN of the IAM role that the service can assume to read data on your behalf. This role must have permission for the s3:GetObject action on the object and trust policy that allows Amazon Kinesis Analytics service principal to assume this role.

S3ReferenceDataSourceDescription

data S3ReferenceDataSourceDescription Source #

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

See: s3ReferenceDataSourceDescription smart constructor.

Instances

Eq S3ReferenceDataSourceDescription Source # 
Data S3ReferenceDataSourceDescription Source # 

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 Source # 
Show S3ReferenceDataSourceDescription Source # 
Generic S3ReferenceDataSourceDescription Source # 
Hashable S3ReferenceDataSourceDescription Source # 
FromJSON S3ReferenceDataSourceDescription Source # 
NFData S3ReferenceDataSourceDescription Source # 
type Rep S3ReferenceDataSourceDescription Source # 
type Rep S3ReferenceDataSourceDescription = D1 * (MetaData "S3ReferenceDataSourceDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of S3ReferenceDataSourceDescription with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

  • srdsdBucketARN - Amazon Resource Name (ARN) of the S3 bucket.
  • srdsdFileKey - Amazon S3 object key name.
  • srdsdReferenceRoleARN - ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf to populate the in-application reference table.

srdsdBucketARN :: Lens' S3ReferenceDataSourceDescription Text Source #

Amazon Resource Name (ARN) of the S3 bucket.

srdsdReferenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf to populate the in-application reference table.

S3ReferenceDataSourceUpdate

data S3ReferenceDataSourceUpdate Source #

Describes the S3 bucket name, object key name, and IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object on your behalf and populate the in-application reference table.

See: s3ReferenceDataSourceUpdate smart constructor.

Instances

Eq S3ReferenceDataSourceUpdate Source # 
Data S3ReferenceDataSourceUpdate Source # 

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 Source # 
Show S3ReferenceDataSourceUpdate Source # 
Generic S3ReferenceDataSourceUpdate Source # 
Hashable S3ReferenceDataSourceUpdate Source # 
ToJSON S3ReferenceDataSourceUpdate Source # 
NFData S3ReferenceDataSourceUpdate Source # 
type Rep S3ReferenceDataSourceUpdate Source # 
type Rep S3ReferenceDataSourceUpdate = D1 * (MetaData "S3ReferenceDataSourceUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

Creates a value of S3ReferenceDataSourceUpdate with the minimum fields required to make a request.

Use one of the following lenses to modify other fields as desired:

srdsuBucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) Source #

Amazon Resource Name (ARN) of the S3 bucket.

srdsuReferenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text) Source #

ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application.

SourceSchema

data SourceSchema Source #

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

See: sourceSchema smart constructor.

Instances

Eq SourceSchema Source # 
Data SourceSchema Source # 

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 Source # 
Show SourceSchema Source # 
Generic SourceSchema Source # 

Associated Types

type Rep SourceSchema :: * -> * #

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

Methods

rnf :: SourceSchema -> () #

type Rep SourceSchema Source # 
type Rep SourceSchema = D1 * (MetaData "SourceSchema" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.0-J4ryjAMBIYIwnq1ki15YT" 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 Source #

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

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

ssRecordFormat :: Lens' SourceSchema RecordFormat Source #

Specifies the format of the records on the streaming source.

ssRecordColumns :: Lens' SourceSchema (NonEmpty RecordColumn) Source #

A list of RecordColumn objects.