amazonka-kinesis-analytics-1.6.1: 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

Contents

Description

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

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

Synopsis

Service Configuration

kinesisAnalytics :: Service Source #

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

Errors

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

InvalidApplicationConfigurationException

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

User-provided application configuration is not valid.

ResourceProvisionedThroughputExceededException

_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

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

Specified input parameter value is invalid.

CodeValidationException

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

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

ConcurrentModificationException

_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

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

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

UnableToDetectSchemaException

_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

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

Specified application can't be found.

LimitExceededException

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

Exceeded the number of applications allowed.

ResourceInUseException

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

Application is not available for this operation.

Waiters

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

Operations

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

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

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

AddApplicationOutput

DiscoverInputSchema

DescribeApplication

StartApplication

DeleteApplicationReferenceDataSource

DeleteApplication

UpdateApplication

DeleteApplicationCloudWatchLoggingOption

AddApplicationInputProcessingConfiguration

CreateApplication

DeleteApplicationOutput

StopApplication

AddApplicationReferenceDataSource

AddApplicationInput

AddApplicationCloudWatchLoggingOption

ListApplications

DeleteApplicationInputProcessingConfiguration

Types

ApplicationStatus

data ApplicationStatus Source #

Instances
Bounded ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Enum ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Eq ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Data ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Read ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Show ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Generic ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Associated Types

type Rep ApplicationStatus :: Type -> Type #

Hashable ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

FromJSON ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToHeader ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToQuery ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToByteString ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

FromText ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToText ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

NFData ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Methods

rnf :: ApplicationStatus -> () #

type Rep ApplicationStatus Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

type Rep ApplicationStatus = D1 (MetaData "ApplicationStatus" "Network.AWS.KinesisAnalytics.Types.Sum" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) ((C1 (MetaCons "Deleting" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "Ready" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Running" PrefixI False) (U1 :: Type -> Type))) :+: (C1 (MetaCons "Starting" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "Stopping" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Updating" PrefixI False) (U1 :: Type -> Type))))

InputStartingPosition

data InputStartingPosition Source #

Instances
Bounded InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Enum InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Eq InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Data InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Read InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Show InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Generic InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Associated Types

type Rep InputStartingPosition :: Type -> Type #

Hashable InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToJSON InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

FromJSON InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToHeader InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToQuery InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToByteString InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

FromText InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToText InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

NFData InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Methods

rnf :: InputStartingPosition -> () #

type Rep InputStartingPosition Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

type Rep InputStartingPosition = D1 (MetaData "InputStartingPosition" "Network.AWS.KinesisAnalytics.Types.Sum" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "LastStoppedPoint" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "Now" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "TrimHorizon" PrefixI False) (U1 :: Type -> Type)))

RecordFormatType

data RecordFormatType Source #

Constructors

CSV 
JSON 
Instances
Bounded RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Enum RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Eq RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Data RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Read RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Show RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Generic RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Associated Types

type Rep RecordFormatType :: Type -> Type #

Hashable RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToJSON RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

FromJSON RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToHeader RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToQuery RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToByteString RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

FromText RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

ToText RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

NFData RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

Methods

rnf :: RecordFormatType -> () #

type Rep RecordFormatType Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Sum

type Rep RecordFormatType = D1 (MetaData "RecordFormatType" "Network.AWS.KinesisAnalytics.Types.Sum" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "CSV" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "JSON" PrefixI False) (U1 :: Type -> Type))

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data ApplicationDetail Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show ApplicationDetail Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic ApplicationDetail Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep ApplicationDetail :: Type -> Type #

Hashable ApplicationDetail Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON ApplicationDetail Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData ApplicationDetail Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: ApplicationDetail -> () #

type Rep ApplicationDetail Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep ApplicationDetail = D1 (MetaData "ApplicationDetail" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "ApplicationDetail'" PrefixI True) (((S1 (MetaSel (Just "_adApplicationDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_adOutputDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [OutputDescription])) :*: S1 (MetaSel (Just "_adCloudWatchLoggingOptionDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [CloudWatchLoggingOptionDescription])))) :*: (S1 (MetaSel (Just "_adReferenceDataSourceDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [ReferenceDataSourceDescription])) :*: (S1 (MetaSel (Just "_adInputDescriptions") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [InputDescription])) :*: S1 (MetaSel (Just "_adApplicationCode") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))) :*: ((S1 (MetaSel (Just "_adCreateTimestamp") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe POSIX)) :*: (S1 (MetaSel (Just "_adLastUpdateTimestamp") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe POSIX)) :*: S1 (MetaSel (Just "_adApplicationName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))) :*: (S1 (MetaSel (Just "_adApplicationARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text) :*: (S1 (MetaSel (Just "_adApplicationStatus") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ApplicationStatus) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data ApplicationSummary Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show ApplicationSummary Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic ApplicationSummary Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep ApplicationSummary :: Type -> Type #

Hashable ApplicationSummary Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON ApplicationSummary Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData ApplicationSummary Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: ApplicationSummary -> () #

type Rep ApplicationSummary Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data ApplicationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show ApplicationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic ApplicationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep ApplicationUpdate :: Type -> Type #

Hashable ApplicationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON ApplicationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData ApplicationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: ApplicationUpdate -> () #

type Rep ApplicationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep ApplicationUpdate = D1 (MetaData "ApplicationUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "ApplicationUpdate'" PrefixI True) ((S1 (MetaSel (Just "_auReferenceDataSourceUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [ReferenceDataSourceUpdate])) :*: S1 (MetaSel (Just "_auInputUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [InputUpdate]))) :*: (S1 (MetaSel (Just "_auCloudWatchLoggingOptionUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [CloudWatchLoggingOptionUpdate])) :*: (S1 (MetaSel (Just "_auOutputUpdates") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [OutputUpdate])) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep CSVMappingParameters :: Type -> Type #

Hashable CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: CSVMappingParameters -> () #

type Rep CSVMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep CSVMappingParameters = D1 (MetaData "CSVMappingParameters" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "CSVMappingParameters'" PrefixI True) (S1 (MetaSel (Just "_cmpRecordRowDelimiter") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data CloudWatchLoggingOption Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show CloudWatchLoggingOption Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic CloudWatchLoggingOption Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep CloudWatchLoggingOption :: Type -> Type #

Hashable CloudWatchLoggingOption Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON CloudWatchLoggingOption Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData CloudWatchLoggingOption Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: CloudWatchLoggingOption -> () #

type Rep CloudWatchLoggingOption Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep CloudWatchLoggingOption = D1 (MetaData "CloudWatchLoggingOption" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "CloudWatchLoggingOption'" PrefixI True) (S1 (MetaSel (Just "_cwloLogStreamARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data CloudWatchLoggingOptionDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show CloudWatchLoggingOptionDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic CloudWatchLoggingOptionDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep CloudWatchLoggingOptionDescription :: Type -> Type #

Hashable CloudWatchLoggingOptionDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON CloudWatchLoggingOptionDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData CloudWatchLoggingOptionDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep CloudWatchLoggingOptionDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep CloudWatchLoggingOptionDescription = D1 (MetaData "CloudWatchLoggingOptionDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "CloudWatchLoggingOptionDescription'" PrefixI True) (S1 (MetaSel (Just "_cwlodCloudWatchLoggingOptionId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_cwlodLogStreamARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data CloudWatchLoggingOptionUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show CloudWatchLoggingOptionUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic CloudWatchLoggingOptionUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep CloudWatchLoggingOptionUpdate :: Type -> Type #

Hashable CloudWatchLoggingOptionUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON CloudWatchLoggingOptionUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData CloudWatchLoggingOptionUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep CloudWatchLoggingOptionUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep CloudWatchLoggingOptionUpdate = D1 (MetaData "CloudWatchLoggingOptionUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "CloudWatchLoggingOptionUpdate'" PrefixI True) (S1 (MetaSel (Just "_cwlouRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: (S1 (MetaSel (Just "_cwlouLogStreamARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep DestinationSchema :: Type -> Type #

Hashable DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: DestinationSchema -> () #

type Rep DestinationSchema Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep DestinationSchema = D1 (MetaData "DestinationSchema" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" True) (C1 (MetaCons "DestinationSchema'" PrefixI True) (S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

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

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

Data Input Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show Input Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

showsPrec :: Int -> Input -> ShowS #

show :: Input -> String #

showList :: [Input] -> ShowS #

Generic Input Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep Input :: Type -> Type #

Methods

from :: Input -> Rep Input x #

to :: Rep Input x -> Input #

Hashable Input Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

hashWithSalt :: Int -> Input -> Int #

hash :: Input -> Int #

ToJSON Input Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData Input Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: Input -> () #

type Rep Input Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep Input = D1 (MetaData "Input" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "Input'" PrefixI True) ((S1 (MetaSel (Just "_iInputParallelism") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputParallelism)) :*: (S1 (MetaSel (Just "_iInputProcessingConfiguration") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputProcessingConfiguration)) :*: S1 (MetaSel (Just "_iKinesisStreamsInput") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsInput)))) :*: (S1 (MetaSel (Just "_iKinesisFirehoseInput") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseInput)) :*: (S1 (MetaSel (Just "_iNamePrefix") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputConfiguration :: Type -> Type #

Hashable InputConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: InputConfiguration -> () #

type Rep InputConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputConfiguration = D1 (MetaData "InputConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "InputConfiguration'" PrefixI True) (S1 (MetaSel (Just "_icId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputDescription :: Type -> Type #

Hashable InputDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON InputDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: InputDescription -> () #

type Rep InputDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputDescription = D1 (MetaData "InputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "InputDescription'" PrefixI True) (((S1 (MetaSel (Just "_idInputStartingPositionConfiguration") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputStartingPositionConfiguration)) :*: S1 (MetaSel (Just "_idInputParallelism") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputParallelism))) :*: (S1 (MetaSel (Just "_idInputId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_idInAppStreamNames") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe [Text])))) :*: ((S1 (MetaSel (Just "_idKinesisFirehoseInputDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseInputDescription)) :*: S1 (MetaSel (Just "_idInputSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceSchema))) :*: (S1 (MetaSel (Just "_idKinesisStreamsInputDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsInputDescription)) :*: (S1 (MetaSel (Just "_idNamePrefix") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputLambdaProcessor Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputLambdaProcessor Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputLambdaProcessor Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputLambdaProcessor :: Type -> Type #

Hashable InputLambdaProcessor Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputLambdaProcessor Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputLambdaProcessor Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: InputLambdaProcessor -> () #

type Rep InputLambdaProcessor Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputLambdaProcessor = D1 (MetaData "InputLambdaProcessor" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "InputLambdaProcessor'" PrefixI True) (S1 (MetaSel (Just "_ilpResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputLambdaProcessorDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputLambdaProcessorDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputLambdaProcessorDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputLambdaProcessorDescription :: Type -> Type #

Hashable InputLambdaProcessorDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON InputLambdaProcessorDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputLambdaProcessorDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputLambdaProcessorDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputLambdaProcessorDescription = D1 (MetaData "InputLambdaProcessorDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "InputLambdaProcessorDescription'" PrefixI True) (S1 (MetaSel (Just "_ilpdResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputLambdaProcessorUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputLambdaProcessorUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputLambdaProcessorUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputLambdaProcessorUpdate :: Type -> Type #

Hashable InputLambdaProcessorUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputLambdaProcessorUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputLambdaProcessorUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputLambdaProcessorUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputLambdaProcessorUpdate = D1 (MetaData "InputLambdaProcessorUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "InputLambdaProcessorUpdate'" PrefixI True) (S1 (MetaSel (Just "_ilpuRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputParallelism :: Type -> Type #

Hashable InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: InputParallelism -> () #

type Rep InputParallelism Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputParallelism = D1 (MetaData "InputParallelism" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" True) (C1 (MetaCons "InputParallelism'" PrefixI True) (S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputParallelismUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputParallelismUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputParallelismUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputParallelismUpdate :: Type -> Type #

Hashable InputParallelismUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputParallelismUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputParallelismUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: InputParallelismUpdate -> () #

type Rep InputParallelismUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputParallelismUpdate = D1 (MetaData "InputParallelismUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" True) (C1 (MetaCons "InputParallelismUpdate'" PrefixI True) (S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputProcessingConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputProcessingConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputProcessingConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputProcessingConfiguration :: Type -> Type #

Hashable InputProcessingConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputProcessingConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputProcessingConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputProcessingConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputProcessingConfiguration = D1 (MetaData "InputProcessingConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" True) (C1 (MetaCons "InputProcessingConfiguration'" PrefixI True) (S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputProcessingConfigurationDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputProcessingConfigurationDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputProcessingConfigurationDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Hashable InputProcessingConfigurationDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON InputProcessingConfigurationDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputProcessingConfigurationDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputProcessingConfigurationDescription Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputProcessingConfigurationDescription = D1 (MetaData "InputProcessingConfigurationDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" True) (C1 (MetaCons "InputProcessingConfigurationDescription'" PrefixI True) (S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputProcessingConfigurationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputProcessingConfigurationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputProcessingConfigurationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputProcessingConfigurationUpdate :: Type -> Type #

Hashable InputProcessingConfigurationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputProcessingConfigurationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputProcessingConfigurationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputProcessingConfigurationUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputProcessingConfigurationUpdate = D1 (MetaData "InputProcessingConfigurationUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" True) (C1 (MetaCons "InputProcessingConfigurationUpdate'" PrefixI True) (S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputSchemaUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputSchemaUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputSchemaUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputSchemaUpdate :: Type -> Type #

Hashable InputSchemaUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputSchemaUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputSchemaUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: InputSchemaUpdate -> () #

type Rep InputSchemaUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputSchemaUpdate = D1 (MetaData "InputSchemaUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "InputSchemaUpdate'" PrefixI True) (S1 (MetaSel (Just "_isuRecordFormatUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe RecordFormat)) :*: (S1 (MetaSel (Just "_isuRecordEncodingUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputStartingPositionConfiguration :: Type -> Type #

Hashable InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputStartingPositionConfiguration Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputStartingPositionConfiguration = D1 (MetaData "InputStartingPositionConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" True) (C1 (MetaCons "InputStartingPositionConfiguration'" PrefixI True) (S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data InputUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show InputUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic InputUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep InputUpdate :: Type -> Type #

Hashable InputUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON InputUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

NFData InputUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Methods

rnf :: InputUpdate -> () #

type Rep InputUpdate Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

type Rep InputUpdate = D1 (MetaData "InputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.6.1-2ypQISJOXcDAxCkmUKrTv4" False) (C1 (MetaCons "InputUpdate'" PrefixI True) ((S1 (MetaSel (Just "_iuInputProcessingConfigurationUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputProcessingConfigurationUpdate)) :*: (S1 (MetaSel (Just "_iuKinesisStreamsInputUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisStreamsInputUpdate)) :*: S1 (MetaSel (Just "_iuInputParallelismUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputParallelismUpdate)))) :*: ((S1 (MetaSel (Just "_iuNamePrefixUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)) :*: S1 (MetaSel (Just "_iuInputSchemaUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe InputSchemaUpdate))) :*: (S1 (MetaSel (Just "_iuKinesisFirehoseInputUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe KinesisFirehoseInputUpdate)) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Data JSONMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

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 # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Show JSONMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Generic JSONMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

Associated Types

type Rep JSONMappingParameters :: Type -> Type #

Hashable JSONMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

ToJSON JSONMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product

FromJSON JSONMappingParameters Source # 
Instance details

Defined in Network.AWS.KinesisAnalytics.Types.Product