Network.AWS.KinesisAnalytics

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.

Service Configuration

kinesisAnalytics :: Service

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

Errors

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

InvalidApplicationConfigurationException

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

User-provided application configuration is not valid.

ResourceProvisionedThroughputExceededException

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

Discovery failed to get a record from the streaming source because of the 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

Specified input parameter value is invalid.

CodeValidationException

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

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

ConcurrentModificationException

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

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

ServiceUnavailableException

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

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

UnableToDetectSchemaException

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

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

Specified application can't be found.

LimitExceededException

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

Exceeded the number of applications allowed.

ResourceInUseException

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

Application is not available for this operation.

Waiters

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

Operations

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

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

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

AddApplicationOutput

module Network.AWS.KinesisAnalytics.AddApplicationOutput

DiscoverInputSchema

module Network.AWS.KinesisAnalytics.DiscoverInputSchema

DescribeApplication

module Network.AWS.KinesisAnalytics.DescribeApplication

StartApplication

module Network.AWS.KinesisAnalytics.StartApplication

DeleteApplicationReferenceDataSource

module Network.AWS.KinesisAnalytics.DeleteApplicationReferenceDataSource

DeleteApplication

module Network.AWS.KinesisAnalytics.DeleteApplication

UpdateApplication

module Network.AWS.KinesisAnalytics.UpdateApplication

DeleteApplicationCloudWatchLoggingOption

module Network.AWS.KinesisAnalytics.DeleteApplicationCloudWatchLoggingOption

AddApplicationInputProcessingConfiguration

module Network.AWS.KinesisAnalytics.AddApplicationInputProcessingConfiguration

CreateApplication

module Network.AWS.KinesisAnalytics.CreateApplication

DeleteApplicationOutput

module Network.AWS.KinesisAnalytics.DeleteApplicationOutput

StopApplication

module Network.AWS.KinesisAnalytics.StopApplication

AddApplicationReferenceDataSource

module Network.AWS.KinesisAnalytics.AddApplicationReferenceDataSource

AddApplicationInput

module Network.AWS.KinesisAnalytics.AddApplicationInput

AddApplicationCloudWatchLoggingOption

module Network.AWS.KinesisAnalytics.AddApplicationCloudWatchLoggingOption

ListApplications

module Network.AWS.KinesisAnalytics.ListApplications

DeleteApplicationInputProcessingConfiguration

module Network.AWS.KinesisAnalytics.DeleteApplicationInputProcessingConfiguration

Types

ApplicationStatus

data ApplicationStatus

Constructors

Deleting

Ready

Running

Starting

Stopping

Updating

Instances

Bounded ApplicationStatus

Methods

minBound :: ApplicationStatus

maxBound :: ApplicationStatus

Enum ApplicationStatus

Methods

succ :: ApplicationStatus -> ApplicationStatus

pred :: ApplicationStatus -> ApplicationStatus

toEnum :: Int -> ApplicationStatus

fromEnum :: ApplicationStatus -> Int

enumFrom :: ApplicationStatus -> [ApplicationStatus]

enumFromThen :: ApplicationStatus -> ApplicationStatus -> [ApplicationStatus]

enumFromTo :: ApplicationStatus -> ApplicationStatus -> [ApplicationStatus]

enumFromThenTo :: ApplicationStatus -> ApplicationStatus -> ApplicationStatus -> [ApplicationStatus]

Eq ApplicationStatus

Methods

(==) :: ApplicationStatus -> ApplicationStatus -> Bool

(/=) :: ApplicationStatus -> ApplicationStatus -> Bool

Data ApplicationStatus

Methods

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

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

toConstr :: ApplicationStatus -> Constr

dataTypeOf :: ApplicationStatus -> DataType

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

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

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

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

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

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

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

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

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

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

Ord ApplicationStatus

Methods

compare :: ApplicationStatus -> ApplicationStatus -> Ordering

(<) :: ApplicationStatus -> ApplicationStatus -> Bool

(<=) :: ApplicationStatus -> ApplicationStatus -> Bool

(>) :: ApplicationStatus -> ApplicationStatus -> Bool

(>=) :: ApplicationStatus -> ApplicationStatus -> Bool

max :: ApplicationStatus -> ApplicationStatus -> ApplicationStatus

min :: ApplicationStatus -> ApplicationStatus -> ApplicationStatus

Read ApplicationStatus

Methods

readsPrec :: Int -> ReadS ApplicationStatus

readList :: ReadS [ApplicationStatus]

readPrec :: ReadPrec ApplicationStatus

readListPrec :: ReadPrec [ApplicationStatus]

Show ApplicationStatus

Methods

showsPrec :: Int -> ApplicationStatus -> ShowS

show :: ApplicationStatus -> String

showList :: [ApplicationStatus] -> ShowS

Generic ApplicationStatus

Associated Types

type Rep ApplicationStatus :: * -> *

Methods

from :: ApplicationStatus -> Rep ApplicationStatus x

to :: Rep ApplicationStatus x -> ApplicationStatus

Hashable ApplicationStatus

Methods

hashWithSalt :: Int -> ApplicationStatus -> Int

hash :: ApplicationStatus -> Int

FromJSON ApplicationStatus

Methods

parseJSON :: Value -> Parser ApplicationStatus

parseJSONList :: Value -> Parser [ApplicationStatus]

NFData ApplicationStatus

Methods

rnf :: ApplicationStatus -> ()

ToQuery ApplicationStatus

Methods

toQuery :: ApplicationStatus -> QueryString

ToHeader ApplicationStatus

Methods

toHeader :: HeaderName -> ApplicationStatus -> [Header]

ToByteString ApplicationStatus

Methods

toBS :: ApplicationStatus -> ByteString

FromText ApplicationStatus

Methods

parser :: Parser ApplicationStatus

ToText ApplicationStatus

Methods

toText :: ApplicationStatus -> Text

type Rep ApplicationStatus

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

InputStartingPosition

data InputStartingPosition

Constructors

LastStoppedPoint

Now

TrimHorizon

Instances

Bounded InputStartingPosition

Methods

minBound :: InputStartingPosition

maxBound :: InputStartingPosition

Enum InputStartingPosition

Methods

succ :: InputStartingPosition -> InputStartingPosition

pred :: InputStartingPosition -> InputStartingPosition

toEnum :: Int -> InputStartingPosition

fromEnum :: InputStartingPosition -> Int

enumFrom :: InputStartingPosition -> [InputStartingPosition]

enumFromThen :: InputStartingPosition -> InputStartingPosition -> [InputStartingPosition]

enumFromTo :: InputStartingPosition -> InputStartingPosition -> [InputStartingPosition]

enumFromThenTo :: InputStartingPosition -> InputStartingPosition -> InputStartingPosition -> [InputStartingPosition]

Eq InputStartingPosition

Methods

(==) :: InputStartingPosition -> InputStartingPosition -> Bool

(/=) :: InputStartingPosition -> InputStartingPosition -> Bool

Data InputStartingPosition

Methods

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

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

toConstr :: InputStartingPosition -> Constr

dataTypeOf :: InputStartingPosition -> DataType

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

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

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

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

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

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

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

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

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

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

Ord InputStartingPosition

Methods

compare :: InputStartingPosition -> InputStartingPosition -> Ordering

(<) :: InputStartingPosition -> InputStartingPosition -> Bool

(<=) :: InputStartingPosition -> InputStartingPosition -> Bool

(>) :: InputStartingPosition -> InputStartingPosition -> Bool

(>=) :: InputStartingPosition -> InputStartingPosition -> Bool

max :: InputStartingPosition -> InputStartingPosition -> InputStartingPosition

min :: InputStartingPosition -> InputStartingPosition -> InputStartingPosition

Read InputStartingPosition

Methods

readsPrec :: Int -> ReadS InputStartingPosition

readList :: ReadS [InputStartingPosition]

readPrec :: ReadPrec InputStartingPosition

readListPrec :: ReadPrec [InputStartingPosition]

Show InputStartingPosition

Methods

showsPrec :: Int -> InputStartingPosition -> ShowS

show :: InputStartingPosition -> String

showList :: [InputStartingPosition] -> ShowS

Generic InputStartingPosition

Associated Types

type Rep InputStartingPosition :: * -> *

Methods

from :: InputStartingPosition -> Rep InputStartingPosition x

to :: Rep InputStartingPosition x -> InputStartingPosition

Hashable InputStartingPosition

Methods

hashWithSalt :: Int -> InputStartingPosition -> Int

hash :: InputStartingPosition -> Int

FromJSON InputStartingPosition

Methods

parseJSON :: Value -> Parser InputStartingPosition

parseJSONList :: Value -> Parser [InputStartingPosition]

ToJSON InputStartingPosition

Methods

toJSON :: InputStartingPosition -> Value

toEncoding :: InputStartingPosition -> Encoding

toJSONList :: [InputStartingPosition] -> Value

toEncodingList :: [InputStartingPosition] -> Encoding

NFData InputStartingPosition

Methods

rnf :: InputStartingPosition -> ()

ToQuery InputStartingPosition

Methods

toQuery :: InputStartingPosition -> QueryString

ToHeader InputStartingPosition

Methods

toHeader :: HeaderName -> InputStartingPosition -> [Header]

ToByteString InputStartingPosition

Methods

toBS :: InputStartingPosition -> ByteString

FromText InputStartingPosition

Methods

parser :: Parser InputStartingPosition

ToText InputStartingPosition

Methods

toText :: InputStartingPosition -> Text

type Rep InputStartingPosition

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

RecordFormatType

data RecordFormatType

Constructors

CSV

JSON

Instances

Bounded RecordFormatType

Methods

minBound :: RecordFormatType

maxBound :: RecordFormatType

Enum RecordFormatType

Methods

succ :: RecordFormatType -> RecordFormatType

pred :: RecordFormatType -> RecordFormatType

toEnum :: Int -> RecordFormatType

fromEnum :: RecordFormatType -> Int

enumFrom :: RecordFormatType -> [RecordFormatType]

enumFromThen :: RecordFormatType -> RecordFormatType -> [RecordFormatType]

enumFromTo :: RecordFormatType -> RecordFormatType -> [RecordFormatType]

enumFromThenTo :: RecordFormatType -> RecordFormatType -> RecordFormatType -> [RecordFormatType]

Eq RecordFormatType

Methods

(==) :: RecordFormatType -> RecordFormatType -> Bool

(/=) :: RecordFormatType -> RecordFormatType -> Bool

Data RecordFormatType

Methods

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

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

toConstr :: RecordFormatType -> Constr

dataTypeOf :: RecordFormatType -> DataType

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

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

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

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

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

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

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

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

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

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

Ord RecordFormatType

Methods

compare :: RecordFormatType -> RecordFormatType -> Ordering

(<) :: RecordFormatType -> RecordFormatType -> Bool

(<=) :: RecordFormatType -> RecordFormatType -> Bool

(>) :: RecordFormatType -> RecordFormatType -> Bool

(>=) :: RecordFormatType -> RecordFormatType -> Bool

max :: RecordFormatType -> RecordFormatType -> RecordFormatType

min :: RecordFormatType -> RecordFormatType -> RecordFormatType

Read RecordFormatType

Methods

readsPrec :: Int -> ReadS RecordFormatType

readList :: ReadS [RecordFormatType]

readPrec :: ReadPrec RecordFormatType

readListPrec :: ReadPrec [RecordFormatType]

Show RecordFormatType

Methods

showsPrec :: Int -> RecordFormatType -> ShowS

show :: RecordFormatType -> String

showList :: [RecordFormatType] -> ShowS

Generic RecordFormatType

Associated Types

type Rep RecordFormatType :: * -> *

Methods

from :: RecordFormatType -> Rep RecordFormatType x

to :: Rep RecordFormatType x -> RecordFormatType

Hashable RecordFormatType

Methods

hashWithSalt :: Int -> RecordFormatType -> Int

hash :: RecordFormatType -> Int

FromJSON RecordFormatType

Methods

parseJSON :: Value -> Parser RecordFormatType

parseJSONList :: Value -> Parser [RecordFormatType]

ToJSON RecordFormatType

Methods

toJSON :: RecordFormatType -> Value

toEncoding :: RecordFormatType -> Encoding

toJSONList :: [RecordFormatType] -> Value

toEncodingList :: [RecordFormatType] -> Encoding

NFData RecordFormatType

Methods

rnf :: RecordFormatType -> ()

ToQuery RecordFormatType

Methods

toQuery :: RecordFormatType -> QueryString

ToHeader RecordFormatType

Methods

toHeader :: HeaderName -> RecordFormatType -> [Header]

ToByteString RecordFormatType

Methods

toBS :: RecordFormatType -> ByteString

FromText RecordFormatType

Methods

parser :: Parser RecordFormatType

ToText RecordFormatType

Methods

toText :: RecordFormatType -> Text

type Rep RecordFormatType

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

ApplicationDetail

data ApplicationDetail

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

See: applicationDetail smart constructor.

Instances

Eq ApplicationDetail

Methods

(==) :: ApplicationDetail -> ApplicationDetail -> Bool

(/=) :: ApplicationDetail -> ApplicationDetail -> Bool

Data ApplicationDetail

Methods

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

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

toConstr :: ApplicationDetail -> Constr

dataTypeOf :: ApplicationDetail -> DataType

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

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

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

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

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

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

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

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

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

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

Read ApplicationDetail

Methods

readsPrec :: Int -> ReadS ApplicationDetail

readList :: ReadS [ApplicationDetail]

readPrec :: ReadPrec ApplicationDetail

readListPrec :: ReadPrec [ApplicationDetail]

Show ApplicationDetail

Methods

showsPrec :: Int -> ApplicationDetail -> ShowS

show :: ApplicationDetail -> String

showList :: [ApplicationDetail] -> ShowS

Generic ApplicationDetail

Associated Types

type Rep ApplicationDetail :: * -> *

Methods

from :: ApplicationDetail -> Rep ApplicationDetail x

to :: Rep ApplicationDetail x -> ApplicationDetail

Hashable ApplicationDetail

Methods

hashWithSalt :: Int -> ApplicationDetail -> Int

hash :: ApplicationDetail -> Int

FromJSON ApplicationDetail

Methods

parseJSON :: Value -> Parser ApplicationDetail

parseJSONList :: Value -> Parser [ApplicationDetail]

NFData ApplicationDetail

Methods

rnf :: ApplicationDetail -> ()

type Rep ApplicationDetail

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

applicationDetail

Arguments

:: Text

adApplicationName

-> Text

adApplicationARN

-> ApplicationStatus

adApplicationStatus

-> Natural

adApplicationVersionId

-> ApplicationDetail

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

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

• adApplicationDescription - Description of the application.
• adOutputDescriptions - Describes the application output configuration. For more information, see Configuring Application Output .
• adCloudWatchLoggingOptionDescriptions - Describes the CloudWatch log streams that are configured to receive application messages. For more information about using CloudWatch log streams with Amazon Kinesis Analytics applications, see Working with Amazon CloudWatch Logs .
• adReferenceDataSourceDescriptions - Describes reference data sources configured for the application. For more information, see Configuring Application Input .
• adInputDescriptions - Describes the application input configuration. For more information, see Configuring Application Input .
• adApplicationCode - Returns the application code that you provided to perform data analysis on any of the in-application streams in your application.
• adCreateTimestamp - Timestamp when the application version was created.
• adLastUpdateTimestamp - Timestamp when the application was last updated.
• adApplicationName - Name of the application.
• adApplicationARN - ARN of the application.
• adApplicationStatus - Status of the application.
• adApplicationVersionId - Provides the current application version.

adApplicationDescription :: Lens' ApplicationDetail (Maybe Text)

Description of the application.

adOutputDescriptions :: Lens' ApplicationDetail [OutputDescription]

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

adCloudWatchLoggingOptionDescriptions :: Lens' ApplicationDetail [CloudWatchLoggingOptionDescription]

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]

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

adInputDescriptions :: Lens' ApplicationDetail [InputDescription]

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

adApplicationCode :: Lens' ApplicationDetail (Maybe Text)

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

adCreateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)

Timestamp when the application version was created.

adLastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)

Timestamp when the application was last updated.

adApplicationName :: Lens' ApplicationDetail Text

Name of the application.

adApplicationARN :: Lens' ApplicationDetail Text

ARN of the application.

adApplicationStatus :: Lens' ApplicationDetail ApplicationStatus

Status of the application.

adApplicationVersionId :: Lens' ApplicationDetail Natural

Provides the current application version.

ApplicationSummary

data ApplicationSummary

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

See: applicationSummary smart constructor.

Instances

Eq ApplicationSummary

Methods

(==) :: ApplicationSummary -> ApplicationSummary -> Bool

(/=) :: ApplicationSummary -> ApplicationSummary -> Bool

Data ApplicationSummary

Methods

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

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

toConstr :: ApplicationSummary -> Constr

dataTypeOf :: ApplicationSummary -> DataType

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

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

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

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

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

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

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

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

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

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

Read ApplicationSummary

Methods

readsPrec :: Int -> ReadS ApplicationSummary

readList :: ReadS [ApplicationSummary]

readPrec :: ReadPrec ApplicationSummary

readListPrec :: ReadPrec [ApplicationSummary]

Show ApplicationSummary

Methods

showsPrec :: Int -> ApplicationSummary -> ShowS

show :: ApplicationSummary -> String

showList :: [ApplicationSummary] -> ShowS

Generic ApplicationSummary

Associated Types

type Rep ApplicationSummary :: * -> *

Methods

from :: ApplicationSummary -> Rep ApplicationSummary x

to :: Rep ApplicationSummary x -> ApplicationSummary

Hashable ApplicationSummary

Methods

hashWithSalt :: Int -> ApplicationSummary -> Int

hash :: ApplicationSummary -> Int

FromJSON ApplicationSummary

Methods

parseJSON :: Value -> Parser ApplicationSummary

parseJSONList :: Value -> Parser [ApplicationSummary]

NFData ApplicationSummary

Methods

rnf :: ApplicationSummary -> ()

type Rep ApplicationSummary

type Rep ApplicationSummary = D1 (MetaData "ApplicationSummary" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "ApplicationSummary'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_asApplicationName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) ((:*:) (S1 (MetaSel (Just Symbol "_asApplicationARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_asApplicationStatus") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ApplicationStatus)))))

applicationSummary

Arguments

:: Text

asApplicationName

-> Text

asApplicationARN

-> ApplicationStatus

asApplicationStatus

-> ApplicationSummary

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

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

• asApplicationName - Name of the application.
• asApplicationARN - ARN of the application.
• asApplicationStatus - Status of the application.

asApplicationName :: Lens' ApplicationSummary Text

Name of the application.

asApplicationARN :: Lens' ApplicationSummary Text

ARN of the application.

asApplicationStatus :: Lens' ApplicationSummary ApplicationStatus

Status of the application.

ApplicationUpdate

data ApplicationUpdate

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

See: applicationUpdate smart constructor.

Instances

Eq ApplicationUpdate

Methods

(==) :: ApplicationUpdate -> ApplicationUpdate -> Bool

(/=) :: ApplicationUpdate -> ApplicationUpdate -> Bool

Data ApplicationUpdate

Methods

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

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

toConstr :: ApplicationUpdate -> Constr

dataTypeOf :: ApplicationUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read ApplicationUpdate

Methods

readsPrec :: Int -> ReadS ApplicationUpdate

readList :: ReadS [ApplicationUpdate]

readPrec :: ReadPrec ApplicationUpdate

readListPrec :: ReadPrec [ApplicationUpdate]

Show ApplicationUpdate

Methods

showsPrec :: Int -> ApplicationUpdate -> ShowS

show :: ApplicationUpdate -> String

showList :: [ApplicationUpdate] -> ShowS

Generic ApplicationUpdate

Associated Types

type Rep ApplicationUpdate :: * -> *

Methods

from :: ApplicationUpdate -> Rep ApplicationUpdate x

to :: Rep ApplicationUpdate x -> ApplicationUpdate

Hashable ApplicationUpdate

Methods

hashWithSalt :: Int -> ApplicationUpdate -> Int

hash :: ApplicationUpdate -> Int

ToJSON ApplicationUpdate

Methods

toJSON :: ApplicationUpdate -> Value

toEncoding :: ApplicationUpdate -> Encoding

toJSONList :: [ApplicationUpdate] -> Value

toEncodingList :: [ApplicationUpdate] -> Encoding

NFData ApplicationUpdate

Methods

rnf :: ApplicationUpdate -> ()

type Rep ApplicationUpdate

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

applicationUpdate :: ApplicationUpdate

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

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

• auReferenceDataSourceUpdates - Describes application reference data source updates.
• auInputUpdates - Describes application input configuration updates.
• auCloudWatchLoggingOptionUpdates - Describes application CloudWatch logging option updates.
• auOutputUpdates - Describes application output configuration updates.
• auApplicationCodeUpdate - Describes application code updates.

auReferenceDataSourceUpdates :: Lens' ApplicationUpdate [ReferenceDataSourceUpdate]

Describes application reference data source updates.

auInputUpdates :: Lens' ApplicationUpdate [InputUpdate]

Describes application input configuration updates.

auCloudWatchLoggingOptionUpdates :: Lens' ApplicationUpdate [CloudWatchLoggingOptionUpdate]

Describes application CloudWatch logging option updates.

auOutputUpdates :: Lens' ApplicationUpdate [OutputUpdate]

Describes application output configuration updates.

auApplicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text)

Describes application code updates.

CSVMappingParameters

data CSVMappingParameters

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

"name1", "address1"

"name2, "address2"

See: csvMappingParameters smart constructor.

Instances

Eq CSVMappingParameters

Methods

(==) :: CSVMappingParameters -> CSVMappingParameters -> Bool

(/=) :: CSVMappingParameters -> CSVMappingParameters -> Bool

Data CSVMappingParameters

Methods

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

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

toConstr :: CSVMappingParameters -> Constr

dataTypeOf :: CSVMappingParameters -> DataType

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

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

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

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

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

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

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

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

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

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

Read CSVMappingParameters

Methods

readsPrec :: Int -> ReadS CSVMappingParameters

readList :: ReadS [CSVMappingParameters]

readPrec :: ReadPrec CSVMappingParameters

readListPrec :: ReadPrec [CSVMappingParameters]

Show CSVMappingParameters

Methods

showsPrec :: Int -> CSVMappingParameters -> ShowS

show :: CSVMappingParameters -> String

showList :: [CSVMappingParameters] -> ShowS

Generic CSVMappingParameters

Associated Types

type Rep CSVMappingParameters :: * -> *

Methods

from :: CSVMappingParameters -> Rep CSVMappingParameters x

to :: Rep CSVMappingParameters x -> CSVMappingParameters

Hashable CSVMappingParameters

Methods

hashWithSalt :: Int -> CSVMappingParameters -> Int

hash :: CSVMappingParameters -> Int

FromJSON CSVMappingParameters

Methods

parseJSON :: Value -> Parser CSVMappingParameters

parseJSONList :: Value -> Parser [CSVMappingParameters]

ToJSON CSVMappingParameters

Methods

toJSON :: CSVMappingParameters -> Value

toEncoding :: CSVMappingParameters -> Encoding

toJSONList :: [CSVMappingParameters] -> Value

toEncodingList :: [CSVMappingParameters] -> Encoding

NFData CSVMappingParameters

Methods

rnf :: CSVMappingParameters -> ()

type Rep CSVMappingParameters

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

csvMappingParameters

Arguments

:: Text

cmpRecordRowDelimiter

-> Text

cmpRecordColumnDelimiter

-> CSVMappingParameters

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

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

• cmpRecordRowDelimiter - Row delimiter. For example, in a CSV format, '\n' is the typical row delimiter.
• cmpRecordColumnDelimiter - Column delimiter. For example, in a CSV format, a comma (",") is the typical column delimiter.

cmpRecordRowDelimiter :: Lens' CSVMappingParameters Text

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

cmpRecordColumnDelimiter :: Lens' CSVMappingParameters Text

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

CloudWatchLoggingOption

data CloudWatchLoggingOption

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

Methods

(==) :: CloudWatchLoggingOption -> CloudWatchLoggingOption -> Bool

(/=) :: CloudWatchLoggingOption -> CloudWatchLoggingOption -> Bool

Data CloudWatchLoggingOption

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

Methods

readsPrec :: Int -> ReadS CloudWatchLoggingOption

readList :: ReadS [CloudWatchLoggingOption]

readPrec :: ReadPrec CloudWatchLoggingOption

readListPrec :: ReadPrec [CloudWatchLoggingOption]

Show CloudWatchLoggingOption

Methods

showsPrec :: Int -> CloudWatchLoggingOption -> ShowS

show :: CloudWatchLoggingOption -> String

showList :: [CloudWatchLoggingOption] -> ShowS

Generic CloudWatchLoggingOption

Associated Types

type Rep CloudWatchLoggingOption :: * -> *

Methods

from :: CloudWatchLoggingOption -> Rep CloudWatchLoggingOption x

to :: Rep CloudWatchLoggingOption x -> CloudWatchLoggingOption

Hashable CloudWatchLoggingOption

Methods

hashWithSalt :: Int -> CloudWatchLoggingOption -> Int

hash :: CloudWatchLoggingOption -> Int

ToJSON CloudWatchLoggingOption

Methods

toJSON :: CloudWatchLoggingOption -> Value

toEncoding :: CloudWatchLoggingOption -> Encoding

toJSONList :: [CloudWatchLoggingOption] -> Value

toEncodingList :: [CloudWatchLoggingOption] -> Encoding

NFData CloudWatchLoggingOption

Methods

rnf :: CloudWatchLoggingOption -> ()

type Rep CloudWatchLoggingOption

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

cloudWatchLoggingOption

Arguments

:: Text

cwloLogStreamARN

-> Text

cwloRoleARN

-> CloudWatchLoggingOption

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

ARN of the CloudWatch log to receive application messages.

cwloRoleARN :: Lens' CloudWatchLoggingOption Text

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

Description of the CloudWatch logging option.

See: cloudWatchLoggingOptionDescription smart constructor.

Instances

Eq CloudWatchLoggingOptionDescription

Methods

(==) :: CloudWatchLoggingOptionDescription -> CloudWatchLoggingOptionDescription -> Bool

(/=) :: CloudWatchLoggingOptionDescription -> CloudWatchLoggingOptionDescription -> Bool

Data CloudWatchLoggingOptionDescription

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

Methods

readsPrec :: Int -> ReadS CloudWatchLoggingOptionDescription

readList :: ReadS [CloudWatchLoggingOptionDescription]

readPrec :: ReadPrec CloudWatchLoggingOptionDescription

readListPrec :: ReadPrec [CloudWatchLoggingOptionDescription]

Show CloudWatchLoggingOptionDescription

Methods

showsPrec :: Int -> CloudWatchLoggingOptionDescription -> ShowS

show :: CloudWatchLoggingOptionDescription -> String

showList :: [CloudWatchLoggingOptionDescription] -> ShowS

Generic CloudWatchLoggingOptionDescription

Associated Types

type Rep CloudWatchLoggingOptionDescription :: * -> *

Methods

from :: CloudWatchLoggingOptionDescription -> Rep CloudWatchLoggingOptionDescription x

to :: Rep CloudWatchLoggingOptionDescription x -> CloudWatchLoggingOptionDescription

Hashable CloudWatchLoggingOptionDescription

Methods

hashWithSalt :: Int -> CloudWatchLoggingOptionDescription -> Int

hash :: CloudWatchLoggingOptionDescription -> Int

FromJSON CloudWatchLoggingOptionDescription

Methods

parseJSON :: Value -> Parser CloudWatchLoggingOptionDescription

parseJSONList :: Value -> Parser [CloudWatchLoggingOptionDescription]

NFData CloudWatchLoggingOptionDescription

Methods

rnf :: CloudWatchLoggingOptionDescription -> ()

type Rep CloudWatchLoggingOptionDescription

type Rep CloudWatchLoggingOptionDescription = D1 (MetaData "CloudWatchLoggingOptionDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "CloudWatchLoggingOptionDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_cwlodCloudWatchLoggingOptionId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) ((:*:) (S1 (MetaSel (Just Symbol "_cwlodLogStreamARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_cwlodRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))))

cloudWatchLoggingOptionDescription

Arguments

:: Text

cwlodLogStreamARN

-> Text

cwlodRoleARN

-> CloudWatchLoggingOptionDescription

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)

ID of the CloudWatch logging option description.

cwlodLogStreamARN :: Lens' CloudWatchLoggingOptionDescription Text

ARN of the CloudWatch log to receive application messages.

cwlodRoleARN :: Lens' CloudWatchLoggingOptionDescription Text

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

Describes CloudWatch logging option updates.

See: cloudWatchLoggingOptionUpdate smart constructor.

Instances

Eq CloudWatchLoggingOptionUpdate

Methods

(==) :: CloudWatchLoggingOptionUpdate -> CloudWatchLoggingOptionUpdate -> Bool

(/=) :: CloudWatchLoggingOptionUpdate -> CloudWatchLoggingOptionUpdate -> Bool

Data CloudWatchLoggingOptionUpdate

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

Methods

readsPrec :: Int -> ReadS CloudWatchLoggingOptionUpdate

readList :: ReadS [CloudWatchLoggingOptionUpdate]

readPrec :: ReadPrec CloudWatchLoggingOptionUpdate

readListPrec :: ReadPrec [CloudWatchLoggingOptionUpdate]

Show CloudWatchLoggingOptionUpdate

Methods

showsPrec :: Int -> CloudWatchLoggingOptionUpdate -> ShowS

show :: CloudWatchLoggingOptionUpdate -> String

showList :: [CloudWatchLoggingOptionUpdate] -> ShowS

Generic CloudWatchLoggingOptionUpdate

Associated Types

type Rep CloudWatchLoggingOptionUpdate :: * -> *

Methods

from :: CloudWatchLoggingOptionUpdate -> Rep CloudWatchLoggingOptionUpdate x

to :: Rep CloudWatchLoggingOptionUpdate x -> CloudWatchLoggingOptionUpdate

Hashable CloudWatchLoggingOptionUpdate

Methods

hashWithSalt :: Int -> CloudWatchLoggingOptionUpdate -> Int

hash :: CloudWatchLoggingOptionUpdate -> Int

ToJSON CloudWatchLoggingOptionUpdate

Methods

toJSON :: CloudWatchLoggingOptionUpdate -> Value

toEncoding :: CloudWatchLoggingOptionUpdate -> Encoding

toJSONList :: [CloudWatchLoggingOptionUpdate] -> Value

toEncodingList :: [CloudWatchLoggingOptionUpdate] -> Encoding

NFData CloudWatchLoggingOptionUpdate

Methods

rnf :: CloudWatchLoggingOptionUpdate -> ()

type Rep CloudWatchLoggingOptionUpdate

type Rep CloudWatchLoggingOptionUpdate = D1 (MetaData "CloudWatchLoggingOptionUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "CloudWatchLoggingOptionUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_cwlouRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) ((:*:) (S1 (MetaSel (Just Symbol "_cwlouLogStreamARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_cwlouCloudWatchLoggingOptionId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))))

cloudWatchLoggingOptionUpdate

Arguments

:: Text

cwlouCloudWatchLoggingOptionId

-> CloudWatchLoggingOptionUpdate

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)

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)

ARN of the CloudWatch log to receive application messages.

cwlouCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionUpdate Text

ID of the CloudWatch logging option to update

DestinationSchema

data DestinationSchema

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

See: destinationSchema smart constructor.

Instances

Eq DestinationSchema

Methods

(==) :: DestinationSchema -> DestinationSchema -> Bool

(/=) :: DestinationSchema -> DestinationSchema -> Bool

Data DestinationSchema

Methods

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

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

toConstr :: DestinationSchema -> Constr

dataTypeOf :: DestinationSchema -> DataType

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

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

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

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

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

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

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

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

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

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

Read DestinationSchema

Methods

readsPrec :: Int -> ReadS DestinationSchema

readList :: ReadS [DestinationSchema]

readPrec :: ReadPrec DestinationSchema

readListPrec :: ReadPrec [DestinationSchema]

Show DestinationSchema

Methods

showsPrec :: Int -> DestinationSchema -> ShowS

show :: DestinationSchema -> String

showList :: [DestinationSchema] -> ShowS

Generic DestinationSchema

Associated Types

type Rep DestinationSchema :: * -> *

Methods

from :: DestinationSchema -> Rep DestinationSchema x

to :: Rep DestinationSchema x -> DestinationSchema

Hashable DestinationSchema

Methods

hashWithSalt :: Int -> DestinationSchema -> Int

hash :: DestinationSchema -> Int

FromJSON DestinationSchema

Methods

parseJSON :: Value -> Parser DestinationSchema

parseJSONList :: Value -> Parser [DestinationSchema]

ToJSON DestinationSchema

Methods

toJSON :: DestinationSchema -> Value

toEncoding :: DestinationSchema -> Encoding

toJSONList :: [DestinationSchema] -> Value

toEncodingList :: [DestinationSchema] -> Encoding

NFData DestinationSchema

Methods

rnf :: DestinationSchema -> ()

type Rep DestinationSchema

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

destinationSchema :: DestinationSchema

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

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

• dsRecordFormatType - Specifies the format of the records on the output stream.

dsRecordFormatType :: Lens' DestinationSchema (Maybe RecordFormatType)

Specifies the format of the records on the output stream.

Input

data Input

When you configure the application input, you specify the streaming source, the in-application stream name that is created, and the mapping between the two. For more information, see Configuring Application Input .

See: input smart constructor.

Instances

Eq Input

Methods

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

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

Data Input

Methods

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

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

toConstr :: Input -> Constr

dataTypeOf :: Input -> DataType

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

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

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

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

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

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

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

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

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

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

Read Input

Methods

readsPrec :: Int -> ReadS Input

readList :: ReadS [Input]

readPrec :: ReadPrec Input

readListPrec :: ReadPrec [Input]

Show Input

Methods

showsPrec :: Int -> Input -> ShowS

show :: Input -> String

showList :: [Input] -> ShowS

Generic Input

Associated Types

type Rep Input :: * -> *

Methods

from :: Input -> Rep Input x

to :: Rep Input x -> Input

Hashable Input

Methods

hashWithSalt :: Int -> Input -> Int

hash :: Input -> Int

ToJSON Input

Methods

toJSON :: Input -> Value

toEncoding :: Input -> Encoding

toJSONList :: [Input] -> Value

toEncodingList :: [Input] -> Encoding

NFData Input

Methods

rnf :: Input -> ()

type Rep Input

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

input

Arguments

:: Text

iNamePrefix

-> SourceSchema

iInputSchema

-> Input

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

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

• iInputParallelism - Describes the number of in-application streams to create. Data from your source will be routed to these in-application input streams. (see Configuring Application Input .
• 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 Firehose 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 in-application stream. Suppose you specify a prefix MyInApplicationStream. Amazon Kinesis Analytics will then create one or more (as per the InputParallelism count you specified) in-application streams with names MyInApplicationStream_001, MyInApplicationStream_002 and so on.
• iInputSchema - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created. Also used to describe the format of the reference data source.

iInputParallelism :: Lens' Input (Maybe InputParallelism)

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

iInputProcessingConfiguration :: Lens' Input (Maybe InputProcessingConfiguration)

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

iKinesisStreamsInput :: Lens' Input (Maybe KinesisStreamsInput)

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

iKinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput)

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

iNamePrefix :: Lens' Input Text

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

iInputSchema :: Lens' Input SourceSchema

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

InputConfiguration

data InputConfiguration

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

See: inputConfiguration smart constructor.

Instances

Eq InputConfiguration

Methods

(==) :: InputConfiguration -> InputConfiguration -> Bool

(/=) :: InputConfiguration -> InputConfiguration -> Bool

Data InputConfiguration

Methods

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

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

toConstr :: InputConfiguration -> Constr

dataTypeOf :: InputConfiguration -> DataType

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

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

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

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

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

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

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

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

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

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

Read InputConfiguration

Methods

readsPrec :: Int -> ReadS InputConfiguration

readList :: ReadS [InputConfiguration]

readPrec :: ReadPrec InputConfiguration

readListPrec :: ReadPrec [InputConfiguration]

Show InputConfiguration

Methods

showsPrec :: Int -> InputConfiguration -> ShowS

show :: InputConfiguration -> String

showList :: [InputConfiguration] -> ShowS

Generic InputConfiguration

Associated Types

type Rep InputConfiguration :: * -> *

Methods

from :: InputConfiguration -> Rep InputConfiguration x

to :: Rep InputConfiguration x -> InputConfiguration

Hashable InputConfiguration

Methods

hashWithSalt :: Int -> InputConfiguration -> Int

hash :: InputConfiguration -> Int

ToJSON InputConfiguration

Methods

toJSON :: InputConfiguration -> Value

toEncoding :: InputConfiguration -> Encoding

toJSONList :: [InputConfiguration] -> Value

toEncodingList :: [InputConfiguration] -> Encoding

NFData InputConfiguration

Methods

rnf :: InputConfiguration -> ()

type Rep InputConfiguration

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

inputConfiguration

Arguments

:: Text

icId

-> InputStartingPositionConfiguration

icInputStartingPositionConfiguration

-> InputConfiguration

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

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

• icId - Input source ID. You can get this ID by calling the DescribeApplication operation.
• icInputStartingPositionConfiguration - Point at which you want the application to start processing records from the streaming source.

icId :: Lens' InputConfiguration Text

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

icInputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration

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

InputDescription

data InputDescription

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

See: inputDescription smart constructor.

Instances

Eq InputDescription

Methods

(==) :: InputDescription -> InputDescription -> Bool

(/=) :: InputDescription -> InputDescription -> Bool

Data InputDescription

Methods

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

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

toConstr :: InputDescription -> Constr

dataTypeOf :: InputDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read InputDescription

Methods

readsPrec :: Int -> ReadS InputDescription

readList :: ReadS [InputDescription]

readPrec :: ReadPrec InputDescription

readListPrec :: ReadPrec [InputDescription]

Show InputDescription

Methods

showsPrec :: Int -> InputDescription -> ShowS

show :: InputDescription -> String

showList :: [InputDescription] -> ShowS

Generic InputDescription

Associated Types

type Rep InputDescription :: * -> *

Methods

from :: InputDescription -> Rep InputDescription x

to :: Rep InputDescription x -> InputDescription

Hashable InputDescription

Methods

hashWithSalt :: Int -> InputDescription -> Int

hash :: InputDescription -> Int

FromJSON InputDescription

Methods

parseJSON :: Value -> Parser InputDescription

parseJSONList :: Value -> Parser [InputDescription]

NFData InputDescription

Methods

rnf :: InputDescription -> ()

type Rep InputDescription

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

inputDescription :: InputDescription

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

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

• idInputStartingPositionConfiguration - Point at which the application is configured to read from the input stream.
• idInputParallelism - Describes the configured parallelism (number of in-application streams mapped to the streaming source).
• idInputId - Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.
• idInAppStreamNames - Returns the in-application stream names that are mapped to the stream source.
• idKinesisFirehoseInputDescription - If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the Firehose delivery stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
• idInputSchema - 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 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)

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

idInputParallelism :: Lens' InputDescription (Maybe InputParallelism)

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

idInputId :: Lens' InputDescription (Maybe Text)

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

idInAppStreamNames :: Lens' InputDescription [Text]

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

idKinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription)

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

idInputSchema :: Lens' InputDescription (Maybe SourceSchema)

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

idKinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription)

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

idNamePrefix :: Lens' InputDescription (Maybe Text)

In-application name prefix.

idInputProcessingConfigurationDescription :: Lens' InputDescription (Maybe InputProcessingConfigurationDescription)

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

InputLambdaProcessor

data InputLambdaProcessor

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

See: inputLambdaProcessor smart constructor.

Instances

Eq InputLambdaProcessor

Methods

(==) :: InputLambdaProcessor -> InputLambdaProcessor -> Bool

(/=) :: InputLambdaProcessor -> InputLambdaProcessor -> Bool

Data InputLambdaProcessor

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

Methods

readsPrec :: Int -> ReadS InputLambdaProcessor

readList :: ReadS [InputLambdaProcessor]

readPrec :: ReadPrec InputLambdaProcessor

readListPrec :: ReadPrec [InputLambdaProcessor]

Show InputLambdaProcessor

Methods

showsPrec :: Int -> InputLambdaProcessor -> ShowS

show :: InputLambdaProcessor -> String

showList :: [InputLambdaProcessor] -> ShowS

Generic InputLambdaProcessor

Associated Types

type Rep InputLambdaProcessor :: * -> *

Methods

from :: InputLambdaProcessor -> Rep InputLambdaProcessor x

to :: Rep InputLambdaProcessor x -> InputLambdaProcessor

Hashable InputLambdaProcessor

Methods

hashWithSalt :: Int -> InputLambdaProcessor -> Int

hash :: InputLambdaProcessor -> Int

ToJSON InputLambdaProcessor

Methods

toJSON :: InputLambdaProcessor -> Value

toEncoding :: InputLambdaProcessor -> Encoding

toJSONList :: [InputLambdaProcessor] -> Value

toEncodingList :: [InputLambdaProcessor] -> Encoding

NFData InputLambdaProcessor

Methods

rnf :: InputLambdaProcessor -> ()

type Rep InputLambdaProcessor

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

inputLambdaProcessor

Arguments

:: Text

ilpResourceARN

-> Text

ilpRoleARN

-> InputLambdaProcessor

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 used to access the AWS Lambda function.

ilpResourceARN :: Lens' InputLambdaProcessor Text

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

ilpRoleARN :: Lens' InputLambdaProcessor Text

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

InputLambdaProcessorDescription

data InputLambdaProcessorDescription

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

See: inputLambdaProcessorDescription smart constructor.

Instances

Eq InputLambdaProcessorDescription

Methods

(==) :: InputLambdaProcessorDescription -> InputLambdaProcessorDescription -> Bool

(/=) :: InputLambdaProcessorDescription -> InputLambdaProcessorDescription -> Bool

Data InputLambdaProcessorDescription

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

Methods

readsPrec :: Int -> ReadS InputLambdaProcessorDescription

readList :: ReadS [InputLambdaProcessorDescription]

readPrec :: ReadPrec InputLambdaProcessorDescription

readListPrec :: ReadPrec [InputLambdaProcessorDescription]

Show InputLambdaProcessorDescription

Methods

showsPrec :: Int -> InputLambdaProcessorDescription -> ShowS

show :: InputLambdaProcessorDescription -> String

showList :: [InputLambdaProcessorDescription] -> ShowS

Generic InputLambdaProcessorDescription

Associated Types

type Rep InputLambdaProcessorDescription :: * -> *

Methods

from :: InputLambdaProcessorDescription -> Rep InputLambdaProcessorDescription x

to :: Rep InputLambdaProcessorDescription x -> InputLambdaProcessorDescription

Hashable InputLambdaProcessorDescription

Methods

hashWithSalt :: Int -> InputLambdaProcessorDescription -> Int

hash :: InputLambdaProcessorDescription -> Int

FromJSON InputLambdaProcessorDescription

Methods

parseJSON :: Value -> Parser InputLambdaProcessorDescription

parseJSONList :: Value -> Parser [InputLambdaProcessorDescription]

NFData InputLambdaProcessorDescription

Methods

rnf :: InputLambdaProcessorDescription -> ()

type Rep InputLambdaProcessorDescription

type Rep InputLambdaProcessorDescription = D1 (MetaData "InputLambdaProcessorDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "InputLambdaProcessorDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ilpdResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ilpdRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

inputLambdaProcessorDescription :: InputLambdaProcessorDescription

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 used to access the AWS Lambda function.

ilpdResourceARN :: Lens' InputLambdaProcessorDescription (Maybe Text)

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

ilpdRoleARN :: Lens' InputLambdaProcessorDescription (Maybe Text)

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

InputLambdaProcessorUpdate

data InputLambdaProcessorUpdate

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

See: inputLambdaProcessorUpdate smart constructor.

Instances

Eq InputLambdaProcessorUpdate

Methods

(==) :: InputLambdaProcessorUpdate -> InputLambdaProcessorUpdate -> Bool

(/=) :: InputLambdaProcessorUpdate -> InputLambdaProcessorUpdate -> Bool

Data InputLambdaProcessorUpdate

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

Methods

readsPrec :: Int -> ReadS InputLambdaProcessorUpdate

readList :: ReadS [InputLambdaProcessorUpdate]

readPrec :: ReadPrec InputLambdaProcessorUpdate

readListPrec :: ReadPrec [InputLambdaProcessorUpdate]

Show InputLambdaProcessorUpdate

Methods

showsPrec :: Int -> InputLambdaProcessorUpdate -> ShowS

show :: InputLambdaProcessorUpdate -> String

showList :: [InputLambdaProcessorUpdate] -> ShowS

Generic InputLambdaProcessorUpdate

Associated Types

type Rep InputLambdaProcessorUpdate :: * -> *

Methods

from :: InputLambdaProcessorUpdate -> Rep InputLambdaProcessorUpdate x

to :: Rep InputLambdaProcessorUpdate x -> InputLambdaProcessorUpdate

Hashable InputLambdaProcessorUpdate

Methods

hashWithSalt :: Int -> InputLambdaProcessorUpdate -> Int

hash :: InputLambdaProcessorUpdate -> Int

ToJSON InputLambdaProcessorUpdate

Methods

toJSON :: InputLambdaProcessorUpdate -> Value

toEncoding :: InputLambdaProcessorUpdate -> Encoding

toJSONList :: [InputLambdaProcessorUpdate] -> Value

toEncodingList :: [InputLambdaProcessorUpdate] -> Encoding

NFData InputLambdaProcessorUpdate

Methods

rnf :: InputLambdaProcessorUpdate -> ()

type Rep InputLambdaProcessorUpdate

type Rep InputLambdaProcessorUpdate = D1 (MetaData "InputLambdaProcessorUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "InputLambdaProcessorUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ilpuRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ilpuResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

inputLambdaProcessorUpdate :: InputLambdaProcessorUpdate

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

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

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

ilpuRoleARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)

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

ilpuResourceARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)

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

InputParallelism

data InputParallelism

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

Methods

(==) :: InputParallelism -> InputParallelism -> Bool

(/=) :: InputParallelism -> InputParallelism -> Bool

Data InputParallelism

Methods

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

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

toConstr :: InputParallelism -> Constr

dataTypeOf :: InputParallelism -> DataType

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

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

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

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

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

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

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

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

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

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

Read InputParallelism

Methods

readsPrec :: Int -> ReadS InputParallelism

readList :: ReadS [InputParallelism]

readPrec :: ReadPrec InputParallelism

readListPrec :: ReadPrec [InputParallelism]

Show InputParallelism

Methods

showsPrec :: Int -> InputParallelism -> ShowS

show :: InputParallelism -> String

showList :: [InputParallelism] -> ShowS

Generic InputParallelism

Associated Types

type Rep InputParallelism :: * -> *

Methods

from :: InputParallelism -> Rep InputParallelism x

to :: Rep InputParallelism x -> InputParallelism

Hashable InputParallelism

Methods

hashWithSalt :: Int -> InputParallelism -> Int

hash :: InputParallelism -> Int

FromJSON InputParallelism

Methods

parseJSON :: Value -> Parser InputParallelism

parseJSONList :: Value -> Parser [InputParallelism]

ToJSON InputParallelism

Methods

toJSON :: InputParallelism -> Value

toEncoding :: InputParallelism -> Encoding

toJSONList :: [InputParallelism] -> Value

toEncodingList :: [InputParallelism] -> Encoding

NFData InputParallelism

Methods

rnf :: InputParallelism -> ()

type Rep InputParallelism

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

inputParallelism :: InputParallelism

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

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

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

ipCount :: Lens' InputParallelism (Maybe Natural)

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

InputParallelismUpdate

data InputParallelismUpdate

Provides updates to the parallelism count.

See: inputParallelismUpdate smart constructor.

Instances

Eq InputParallelismUpdate

Methods

(==) :: InputParallelismUpdate -> InputParallelismUpdate -> Bool

(/=) :: InputParallelismUpdate -> InputParallelismUpdate -> Bool

Data InputParallelismUpdate

Methods

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

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

toConstr :: InputParallelismUpdate -> Constr

dataTypeOf :: InputParallelismUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read InputParallelismUpdate

Methods

readsPrec :: Int -> ReadS InputParallelismUpdate

readList :: ReadS [InputParallelismUpdate]

readPrec :: ReadPrec InputParallelismUpdate

readListPrec :: ReadPrec [InputParallelismUpdate]

Show InputParallelismUpdate

Methods

showsPrec :: Int -> InputParallelismUpdate -> ShowS

show :: InputParallelismUpdate -> String

showList :: [InputParallelismUpdate] -> ShowS

Generic InputParallelismUpdate

Associated Types

type Rep InputParallelismUpdate :: * -> *

Methods

from :: InputParallelismUpdate -> Rep InputParallelismUpdate x

to :: Rep InputParallelismUpdate x -> InputParallelismUpdate

Hashable InputParallelismUpdate

Methods

hashWithSalt :: Int -> InputParallelismUpdate -> Int

hash :: InputParallelismUpdate -> Int

ToJSON InputParallelismUpdate

Methods

toJSON :: InputParallelismUpdate -> Value

toEncoding :: InputParallelismUpdate -> Encoding

toJSONList :: [InputParallelismUpdate] -> Value

toEncodingList :: [InputParallelismUpdate] -> Encoding

NFData InputParallelismUpdate

Methods

rnf :: InputParallelismUpdate -> ()

type Rep InputParallelismUpdate

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

inputParallelismUpdate :: InputParallelismUpdate

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

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

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

ipuCountUpdate :: Lens' InputParallelismUpdate (Maybe Natural)

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

InputProcessingConfiguration

data InputProcessingConfiguration

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

See: inputProcessingConfiguration smart constructor.

Instances

Eq InputProcessingConfiguration

Methods

(==) :: InputProcessingConfiguration -> InputProcessingConfiguration -> Bool

(/=) :: InputProcessingConfiguration -> InputProcessingConfiguration -> Bool

Data InputProcessingConfiguration

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

Methods

readsPrec :: Int -> ReadS InputProcessingConfiguration

readList :: ReadS [InputProcessingConfiguration]

readPrec :: ReadPrec InputProcessingConfiguration

readListPrec :: ReadPrec [InputProcessingConfiguration]

Show InputProcessingConfiguration

Methods

showsPrec :: Int -> InputProcessingConfiguration -> ShowS

show :: InputProcessingConfiguration -> String

showList :: [InputProcessingConfiguration] -> ShowS

Generic InputProcessingConfiguration

Associated Types

type Rep InputProcessingConfiguration :: * -> *

Methods

from :: InputProcessingConfiguration -> Rep InputProcessingConfiguration x

to :: Rep InputProcessingConfiguration x -> InputProcessingConfiguration

Hashable InputProcessingConfiguration

Methods

hashWithSalt :: Int -> InputProcessingConfiguration -> Int

hash :: InputProcessingConfiguration -> Int

ToJSON InputProcessingConfiguration

Methods

toJSON :: InputProcessingConfiguration -> Value

toEncoding :: InputProcessingConfiguration -> Encoding

toJSONList :: [InputProcessingConfiguration] -> Value

toEncodingList :: [InputProcessingConfiguration] -> Encoding

NFData InputProcessingConfiguration

Methods

rnf :: InputProcessingConfiguration -> ()

type Rep InputProcessingConfiguration

type Rep InputProcessingConfiguration = D1 (MetaData "InputProcessingConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" True) (C1 (MetaCons "InputProcessingConfiguration'" PrefixI True) (S1 (MetaSel (Just Symbol "_ipcInputLambdaProcessor") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 InputLambdaProcessor)))

inputProcessingConfiguration

Arguments

:: InputLambdaProcessor

ipcInputLambdaProcessor

-> InputProcessingConfiguration

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 - The InputLambdaProcessor that is used to preprocess the records in the stream prior to being processed by your application code.

ipcInputLambdaProcessor :: Lens' InputProcessingConfiguration InputLambdaProcessor

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

InputProcessingConfigurationDescription

data InputProcessingConfigurationDescription

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

See: inputProcessingConfigurationDescription smart constructor.

Instances

Eq InputProcessingConfigurationDescription

Methods

(==) :: InputProcessingConfigurationDescription -> InputProcessingConfigurationDescription -> Bool

(/=) :: InputProcessingConfigurationDescription -> InputProcessingConfigurationDescription -> Bool

Data InputProcessingConfigurationDescription

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

Methods

readsPrec :: Int -> ReadS InputProcessingConfigurationDescription

readList :: ReadS [InputProcessingConfigurationDescription]

readPrec :: ReadPrec InputProcessingConfigurationDescription

readListPrec :: ReadPrec [InputProcessingConfigurationDescription]

Show InputProcessingConfigurationDescription

Methods

showsPrec :: Int -> InputProcessingConfigurationDescription -> ShowS

show :: InputProcessingConfigurationDescription -> String

showList :: [InputProcessingConfigurationDescription] -> ShowS

Generic InputProcessingConfigurationDescription

Associated Types

type Rep InputProcessingConfigurationDescription :: * -> *

Methods

from :: InputProcessingConfigurationDescription -> Rep InputProcessingConfigurationDescription x

to :: Rep InputProcessingConfigurationDescription x -> InputProcessingConfigurationDescription

Hashable InputProcessingConfigurationDescription

Methods

hashWithSalt :: Int -> InputProcessingConfigurationDescription -> Int

hash :: InputProcessingConfigurationDescription -> Int

FromJSON InputProcessingConfigurationDescription

Methods

parseJSON :: Value -> Parser InputProcessingConfigurationDescription

parseJSONList :: Value -> Parser [InputProcessingConfigurationDescription]

NFData InputProcessingConfigurationDescription

Methods

rnf :: InputProcessingConfigurationDescription -> ()

type Rep InputProcessingConfigurationDescription

type Rep InputProcessingConfigurationDescription = D1 (MetaData "InputProcessingConfigurationDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" True) (C1 (MetaCons "InputProcessingConfigurationDescription'" PrefixI True) (S1 (MetaSel (Just Symbol "_ipcdInputLambdaProcessorDescription") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe InputLambdaProcessorDescription))))

inputProcessingConfigurationDescription :: InputProcessingConfigurationDescription

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

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

• ipcdInputLambdaProcessorDescription - Provides configuration information about the associated InputLambdaProcessorDescription .

ipcdInputLambdaProcessorDescription :: Lens' InputProcessingConfigurationDescription (Maybe InputLambdaProcessorDescription)

Provides configuration information about the associated InputLambdaProcessorDescription .

InputProcessingConfigurationUpdate

data InputProcessingConfigurationUpdate

Describes updates to an InputProcessingConfiguration .

See: inputProcessingConfigurationUpdate smart constructor.

Instances

Eq InputProcessingConfigurationUpdate

Methods

(==) :: InputProcessingConfigurationUpdate -> InputProcessingConfigurationUpdate -> Bool

(/=) :: InputProcessingConfigurationUpdate -> InputProcessingConfigurationUpdate -> Bool

Data InputProcessingConfigurationUpdate

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

Methods

readsPrec :: Int -> ReadS InputProcessingConfigurationUpdate

readList :: ReadS [InputProcessingConfigurationUpdate]

readPrec :: ReadPrec InputProcessingConfigurationUpdate

readListPrec :: ReadPrec [InputProcessingConfigurationUpdate]

Show InputProcessingConfigurationUpdate

Methods

showsPrec :: Int -> InputProcessingConfigurationUpdate -> ShowS

show :: InputProcessingConfigurationUpdate -> String

showList :: [InputProcessingConfigurationUpdate] -> ShowS

Generic InputProcessingConfigurationUpdate

Associated Types

type Rep InputProcessingConfigurationUpdate :: * -> *

Methods

from :: InputProcessingConfigurationUpdate -> Rep InputProcessingConfigurationUpdate x

to :: Rep InputProcessingConfigurationUpdate x -> InputProcessingConfigurationUpdate

Hashable InputProcessingConfigurationUpdate

Methods

hashWithSalt :: Int -> InputProcessingConfigurationUpdate -> Int

hash :: InputProcessingConfigurationUpdate -> Int

ToJSON InputProcessingConfigurationUpdate

Methods

toJSON :: InputProcessingConfigurationUpdate -> Value

toEncoding :: InputProcessingConfigurationUpdate -> Encoding

toJSONList :: [InputProcessingConfigurationUpdate] -> Value

toEncodingList :: [InputProcessingConfigurationUpdate] -> Encoding

NFData InputProcessingConfigurationUpdate

Methods

rnf :: InputProcessingConfigurationUpdate -> ()

type Rep InputProcessingConfigurationUpdate

type Rep InputProcessingConfigurationUpdate = D1 (MetaData "InputProcessingConfigurationUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" True) (C1 (MetaCons "InputProcessingConfigurationUpdate'" PrefixI True) (S1 (MetaSel (Just Symbol "_ipcuInputLambdaProcessorUpdate") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 InputLambdaProcessorUpdate)))

inputProcessingConfigurationUpdate

Arguments

:: InputLambdaProcessorUpdate

ipcuInputLambdaProcessorUpdate

-> InputProcessingConfigurationUpdate

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

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

• ipcuInputLambdaProcessorUpdate - Provides update information for an InputLambdaProcessor .

ipcuInputLambdaProcessorUpdate :: Lens' InputProcessingConfigurationUpdate InputLambdaProcessorUpdate

Provides update information for an InputLambdaProcessor .

InputSchemaUpdate

data InputSchemaUpdate

Describes updates for the application's input schema.

See: inputSchemaUpdate smart constructor.

Instances

Eq InputSchemaUpdate

Methods

(==) :: InputSchemaUpdate -> InputSchemaUpdate -> Bool

(/=) :: InputSchemaUpdate -> InputSchemaUpdate -> Bool

Data InputSchemaUpdate

Methods

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

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

toConstr :: InputSchemaUpdate -> Constr

dataTypeOf :: InputSchemaUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read InputSchemaUpdate

Methods

readsPrec :: Int -> ReadS InputSchemaUpdate

readList :: ReadS [InputSchemaUpdate]

readPrec :: ReadPrec InputSchemaUpdate

readListPrec :: ReadPrec [InputSchemaUpdate]

Show InputSchemaUpdate

Methods

showsPrec :: Int -> InputSchemaUpdate -> ShowS

show :: InputSchemaUpdate -> String

showList :: [InputSchemaUpdate] -> ShowS

Generic InputSchemaUpdate

Associated Types

type Rep InputSchemaUpdate :: * -> *

Methods

from :: InputSchemaUpdate -> Rep InputSchemaUpdate x

to :: Rep InputSchemaUpdate x -> InputSchemaUpdate

Hashable InputSchemaUpdate

Methods

hashWithSalt :: Int -> InputSchemaUpdate -> Int

hash :: InputSchemaUpdate -> Int

ToJSON InputSchemaUpdate

Methods

toJSON :: InputSchemaUpdate -> Value

toEncoding :: InputSchemaUpdate -> Encoding

toJSONList :: [InputSchemaUpdate] -> Value

toEncodingList :: [InputSchemaUpdate] -> Encoding

NFData InputSchemaUpdate

Methods

rnf :: InputSchemaUpdate -> ()

type Rep InputSchemaUpdate

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

inputSchemaUpdate :: InputSchemaUpdate

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

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

• isuRecordFormatUpdate - Specifies the format of the records on the streaming source.
• isuRecordEncodingUpdate - Specifies the encoding of the records in the streaming source. For example, UTF-8.
• isuRecordColumnUpdates - A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.

isuRecordFormatUpdate :: Lens' InputSchemaUpdate (Maybe RecordFormat)

Specifies the format of the records on the streaming source.

isuRecordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text)

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

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

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

InputStartingPositionConfiguration

data InputStartingPositionConfiguration

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

See: inputStartingPositionConfiguration smart constructor.

Instances

Eq InputStartingPositionConfiguration

Methods

(==) :: InputStartingPositionConfiguration -> InputStartingPositionConfiguration -> Bool

(/=) :: InputStartingPositionConfiguration -> InputStartingPositionConfiguration -> Bool

Data InputStartingPositionConfiguration

Methods

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

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

toConstr :: InputStartingPositionConfiguration -> Constr

dataTypeOf :: InputStartingPositionConfiguration -> DataType

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

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

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

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

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

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

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

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

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

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

Read InputStartingPositionConfiguration

Methods

readsPrec :: Int -> ReadS InputStartingPositionConfiguration

readList :: ReadS [InputStartingPositionConfiguration]

readPrec :: ReadPrec InputStartingPositionConfiguration

readListPrec :: ReadPrec [InputStartingPositionConfiguration]

Show InputStartingPositionConfiguration

Methods

showsPrec :: Int -> InputStartingPositionConfiguration -> ShowS

show :: InputStartingPositionConfiguration -> String

showList :: [InputStartingPositionConfiguration] -> ShowS

Generic InputStartingPositionConfiguration

Associated Types

type Rep InputStartingPositionConfiguration :: * -> *

Methods

from :: InputStartingPositionConfiguration -> Rep InputStartingPositionConfiguration x

to :: Rep InputStartingPositionConfiguration x -> InputStartingPositionConfiguration

Hashable InputStartingPositionConfiguration

Methods

hashWithSalt :: Int -> InputStartingPositionConfiguration -> Int

hash :: InputStartingPositionConfiguration -> Int

FromJSON InputStartingPositionConfiguration

Methods

parseJSON :: Value -> Parser InputStartingPositionConfiguration

parseJSONList :: Value -> Parser [InputStartingPositionConfiguration]

ToJSON InputStartingPositionConfiguration

Methods

toJSON :: InputStartingPositionConfiguration -> Value

toEncoding :: InputStartingPositionConfiguration -> Encoding

toJSONList :: [InputStartingPositionConfiguration] -> Value

toEncodingList :: [InputStartingPositionConfiguration] -> Encoding

NFData InputStartingPositionConfiguration

Methods

rnf :: InputStartingPositionConfiguration -> ()

type Rep InputStartingPositionConfiguration

type Rep InputStartingPositionConfiguration = D1 (MetaData "InputStartingPositionConfiguration" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" True) (C1 (MetaCons "InputStartingPositionConfiguration'" PrefixI True) (S1 (MetaSel (Just Symbol "_ispcInputStartingPosition") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe InputStartingPosition))))

inputStartingPositionConfiguration :: InputStartingPositionConfiguration

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

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

• ispcInputStartingPosition - The starting position on the stream. * NOW - Start reading just after the most recent record in the stream, start at the request timestamp 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)

The starting position on the stream. * NOW - Start reading just after the most recent record in the stream, start at the request timestamp 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

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

See: inputUpdate smart constructor.

Instances

Eq InputUpdate

Methods

(==) :: InputUpdate -> InputUpdate -> Bool

(/=) :: InputUpdate -> InputUpdate -> Bool

Data InputUpdate

Methods

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

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

toConstr :: InputUpdate -> Constr

dataTypeOf :: InputUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read InputUpdate

Methods

readsPrec :: Int -> ReadS InputUpdate

readList :: ReadS [InputUpdate]

readPrec :: ReadPrec InputUpdate

readListPrec :: ReadPrec [InputUpdate]

Show InputUpdate

Methods

showsPrec :: Int -> InputUpdate -> ShowS

show :: InputUpdate -> String

showList :: [InputUpdate] -> ShowS

Generic InputUpdate

Associated Types

type Rep InputUpdate :: * -> *

Methods

from :: InputUpdate -> Rep InputUpdate x

to :: Rep InputUpdate x -> InputUpdate

Hashable InputUpdate

Methods

hashWithSalt :: Int -> InputUpdate -> Int

hash :: InputUpdate -> Int

ToJSON InputUpdate

Methods

toJSON :: InputUpdate -> Value

toEncoding :: InputUpdate -> Encoding

toJSONList :: [InputUpdate] -> Value

toEncodingList :: [InputUpdate] -> Encoding

NFData InputUpdate

Methods

rnf :: InputUpdate -> ()

type Rep InputUpdate

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

inputUpdate

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

iuInputProcessingConfigurationUpdate :: Lens' InputUpdate (Maybe InputProcessingConfigurationUpdate)

Describes updates for an input processing configuration.

iuKinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate)

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

iuInputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate)

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

iuNamePrefixUpdate :: Lens' InputUpdate (Maybe Text)

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

iuInputSchemaUpdate :: Lens' InputUpdate (Maybe InputSchemaUpdate)

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

iuKinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate)

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

iuInputId :: Lens' InputUpdate Text

Input ID of the application input to be updated.

JSONMappingParameters

data JSONMappingParameters

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

See: jsonMappingParameters smart constructor.

Instances

Eq JSONMappingParameters

Methods

(==) :: JSONMappingParameters -> JSONMappingParameters -> Bool

(/=) :: JSONMappingParameters -> JSONMappingParameters -> Bool

Data JSONMappingParameters

Methods

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

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

toConstr :: JSONMappingParameters -> Constr

dataTypeOf :: JSONMappingParameters -> DataType

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

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

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

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

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

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

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

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

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

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

Read JSONMappingParameters

Methods

readsPrec :: Int -> ReadS JSONMappingParameters

readList :: ReadS [JSONMappingParameters]

readPrec :: ReadPrec JSONMappingParameters

readListPrec :: ReadPrec [JSONMappingParameters]

Show JSONMappingParameters

Methods

showsPrec :: Int -> JSONMappingParameters -> ShowS

show :: JSONMappingParameters -> String

showList :: [JSONMappingParameters] -> ShowS

Generic JSONMappingParameters

Associated Types

type Rep JSONMappingParameters :: * -> *

Methods

from :: JSONMappingParameters -> Rep JSONMappingParameters x

to :: Rep JSONMappingParameters x -> JSONMappingParameters

Hashable JSONMappingParameters

Methods

hashWithSalt :: Int -> JSONMappingParameters -> Int

hash :: JSONMappingParameters -> Int

FromJSON JSONMappingParameters

Methods

parseJSON :: Value -> Parser JSONMappingParameters

parseJSONList :: Value -> Parser [JSONMappingParameters]

ToJSON JSONMappingParameters

Methods

toJSON :: JSONMappingParameters -> Value

toEncoding :: JSONMappingParameters -> Encoding

toJSONList :: [JSONMappingParameters] -> Value

toEncodingList :: [JSONMappingParameters] -> Encoding

NFData JSONMappingParameters

Methods

rnf :: JSONMappingParameters -> ()

type Rep JSONMappingParameters

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

jsonMappingParameters

Arguments

:: Text

jmpRecordRowPath

-> JSONMappingParameters

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

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

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

jmpRecordRowPath :: Lens' JSONMappingParameters Text

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

KinesisFirehoseInput

data KinesisFirehoseInput

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

See: kinesisFirehoseInput smart constructor.

Instances

Eq KinesisFirehoseInput

Methods

(==) :: KinesisFirehoseInput -> KinesisFirehoseInput -> Bool

(/=) :: KinesisFirehoseInput -> KinesisFirehoseInput -> Bool

Data KinesisFirehoseInput

Methods

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

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

toConstr :: KinesisFirehoseInput -> Constr

dataTypeOf :: KinesisFirehoseInput -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisFirehoseInput

Methods

readsPrec :: Int -> ReadS KinesisFirehoseInput

readList :: ReadS [KinesisFirehoseInput]

readPrec :: ReadPrec KinesisFirehoseInput

readListPrec :: ReadPrec [KinesisFirehoseInput]

Show KinesisFirehoseInput

Methods

showsPrec :: Int -> KinesisFirehoseInput -> ShowS

show :: KinesisFirehoseInput -> String

showList :: [KinesisFirehoseInput] -> ShowS

Generic KinesisFirehoseInput

Associated Types

type Rep KinesisFirehoseInput :: * -> *

Methods

from :: KinesisFirehoseInput -> Rep KinesisFirehoseInput x

to :: Rep KinesisFirehoseInput x -> KinesisFirehoseInput

Hashable KinesisFirehoseInput

Methods

hashWithSalt :: Int -> KinesisFirehoseInput -> Int

hash :: KinesisFirehoseInput -> Int

ToJSON KinesisFirehoseInput

Methods

toJSON :: KinesisFirehoseInput -> Value

toEncoding :: KinesisFirehoseInput -> Encoding

toJSONList :: [KinesisFirehoseInput] -> Value

toEncodingList :: [KinesisFirehoseInput] -> Encoding

NFData KinesisFirehoseInput

Methods

rnf :: KinesisFirehoseInput -> ()

type Rep KinesisFirehoseInput

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

kinesisFirehoseInput

Arguments

:: Text

kfiResourceARN

-> Text

kfiRoleARN

-> KinesisFirehoseInput

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

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

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

kfiResourceARN :: Lens' KinesisFirehoseInput Text

ARN of the input Firehose delivery stream.

kfiRoleARN :: Lens' KinesisFirehoseInput Text

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

KinesisFirehoseInputDescription

data KinesisFirehoseInputDescription

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

See: kinesisFirehoseInputDescription smart constructor.

Instances

Eq KinesisFirehoseInputDescription

Methods

(==) :: KinesisFirehoseInputDescription -> KinesisFirehoseInputDescription -> Bool

(/=) :: KinesisFirehoseInputDescription -> KinesisFirehoseInputDescription -> Bool

Data KinesisFirehoseInputDescription

Methods

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

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

toConstr :: KinesisFirehoseInputDescription -> Constr

dataTypeOf :: KinesisFirehoseInputDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisFirehoseInputDescription

Methods

readsPrec :: Int -> ReadS KinesisFirehoseInputDescription

readList :: ReadS [KinesisFirehoseInputDescription]

readPrec :: ReadPrec KinesisFirehoseInputDescription

readListPrec :: ReadPrec [KinesisFirehoseInputDescription]

Show KinesisFirehoseInputDescription

Methods

showsPrec :: Int -> KinesisFirehoseInputDescription -> ShowS

show :: KinesisFirehoseInputDescription -> String

showList :: [KinesisFirehoseInputDescription] -> ShowS

Generic KinesisFirehoseInputDescription

Associated Types

type Rep KinesisFirehoseInputDescription :: * -> *

Methods

from :: KinesisFirehoseInputDescription -> Rep KinesisFirehoseInputDescription x

to :: Rep KinesisFirehoseInputDescription x -> KinesisFirehoseInputDescription

Hashable KinesisFirehoseInputDescription

Methods

hashWithSalt :: Int -> KinesisFirehoseInputDescription -> Int

hash :: KinesisFirehoseInputDescription -> Int

FromJSON KinesisFirehoseInputDescription

Methods

parseJSON :: Value -> Parser KinesisFirehoseInputDescription

parseJSONList :: Value -> Parser [KinesisFirehoseInputDescription]

NFData KinesisFirehoseInputDescription

Methods

rnf :: KinesisFirehoseInputDescription -> ()

type Rep KinesisFirehoseInputDescription

type Rep KinesisFirehoseInputDescription = D1 (MetaData "KinesisFirehoseInputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisFirehoseInputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfidResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfidRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseInputDescription :: KinesisFirehoseInputDescription

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

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

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

kfidResourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)

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

kfidRoleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)

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

KinesisFirehoseInputUpdate

data KinesisFirehoseInputUpdate

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

See: kinesisFirehoseInputUpdate smart constructor.

Instances

Eq KinesisFirehoseInputUpdate

Methods

(==) :: KinesisFirehoseInputUpdate -> KinesisFirehoseInputUpdate -> Bool

(/=) :: KinesisFirehoseInputUpdate -> KinesisFirehoseInputUpdate -> Bool

Data KinesisFirehoseInputUpdate

Methods

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

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

toConstr :: KinesisFirehoseInputUpdate -> Constr

dataTypeOf :: KinesisFirehoseInputUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisFirehoseInputUpdate

Methods

readsPrec :: Int -> ReadS KinesisFirehoseInputUpdate

readList :: ReadS [KinesisFirehoseInputUpdate]

readPrec :: ReadPrec KinesisFirehoseInputUpdate

readListPrec :: ReadPrec [KinesisFirehoseInputUpdate]

Show KinesisFirehoseInputUpdate

Methods

showsPrec :: Int -> KinesisFirehoseInputUpdate -> ShowS

show :: KinesisFirehoseInputUpdate -> String

showList :: [KinesisFirehoseInputUpdate] -> ShowS

Generic KinesisFirehoseInputUpdate

Associated Types

type Rep KinesisFirehoseInputUpdate :: * -> *

Methods

from :: KinesisFirehoseInputUpdate -> Rep KinesisFirehoseInputUpdate x

to :: Rep KinesisFirehoseInputUpdate x -> KinesisFirehoseInputUpdate

Hashable KinesisFirehoseInputUpdate

Methods

hashWithSalt :: Int -> KinesisFirehoseInputUpdate -> Int

hash :: KinesisFirehoseInputUpdate -> Int

ToJSON KinesisFirehoseInputUpdate

Methods

toJSON :: KinesisFirehoseInputUpdate -> Value

toEncoding :: KinesisFirehoseInputUpdate -> Encoding

toJSONList :: [KinesisFirehoseInputUpdate] -> Value

toEncodingList :: [KinesisFirehoseInputUpdate] -> Encoding

NFData KinesisFirehoseInputUpdate

Methods

rnf :: KinesisFirehoseInputUpdate -> ()

type Rep KinesisFirehoseInputUpdate

type Rep KinesisFirehoseInputUpdate = D1 (MetaData "KinesisFirehoseInputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisFirehoseInputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfiuRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfiuResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseInputUpdate :: KinesisFirehoseInputUpdate

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

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

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

kfiuRoleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)

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

kfiuResourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)

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

KinesisFirehoseOutput

data KinesisFirehoseOutput

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

See: kinesisFirehoseOutput smart constructor.

Instances

Eq KinesisFirehoseOutput

Methods

(==) :: KinesisFirehoseOutput -> KinesisFirehoseOutput -> Bool

(/=) :: KinesisFirehoseOutput -> KinesisFirehoseOutput -> Bool

Data KinesisFirehoseOutput

Methods

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

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

toConstr :: KinesisFirehoseOutput -> Constr

dataTypeOf :: KinesisFirehoseOutput -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisFirehoseOutput

Methods

readsPrec :: Int -> ReadS KinesisFirehoseOutput

readList :: ReadS [KinesisFirehoseOutput]

readPrec :: ReadPrec KinesisFirehoseOutput

readListPrec :: ReadPrec [KinesisFirehoseOutput]

Show KinesisFirehoseOutput

Methods

showsPrec :: Int -> KinesisFirehoseOutput -> ShowS

show :: KinesisFirehoseOutput -> String

showList :: [KinesisFirehoseOutput] -> ShowS

Generic KinesisFirehoseOutput

Associated Types

type Rep KinesisFirehoseOutput :: * -> *

Methods

from :: KinesisFirehoseOutput -> Rep KinesisFirehoseOutput x

to :: Rep KinesisFirehoseOutput x -> KinesisFirehoseOutput

Hashable KinesisFirehoseOutput

Methods

hashWithSalt :: Int -> KinesisFirehoseOutput -> Int

hash :: KinesisFirehoseOutput -> Int

ToJSON KinesisFirehoseOutput

Methods

toJSON :: KinesisFirehoseOutput -> Value

toEncoding :: KinesisFirehoseOutput -> Encoding

toJSONList :: [KinesisFirehoseOutput] -> Value

toEncodingList :: [KinesisFirehoseOutput] -> Encoding

NFData KinesisFirehoseOutput

Methods

rnf :: KinesisFirehoseOutput -> ()

type Rep KinesisFirehoseOutput

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

kinesisFirehoseOutput

Arguments

:: Text

kfoResourceARN

-> Text

kfoRoleARN

-> KinesisFirehoseOutput

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

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

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

kfoResourceARN :: Lens' KinesisFirehoseOutput Text

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

kfoRoleARN :: Lens' KinesisFirehoseOutput Text

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

KinesisFirehoseOutputDescription

data KinesisFirehoseOutputDescription

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

See: kinesisFirehoseOutputDescription smart constructor.

Instances

Eq KinesisFirehoseOutputDescription

Methods

(==) :: KinesisFirehoseOutputDescription -> KinesisFirehoseOutputDescription -> Bool

(/=) :: KinesisFirehoseOutputDescription -> KinesisFirehoseOutputDescription -> Bool

Data KinesisFirehoseOutputDescription

Methods

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

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

toConstr :: KinesisFirehoseOutputDescription -> Constr

dataTypeOf :: KinesisFirehoseOutputDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisFirehoseOutputDescription

Methods

readsPrec :: Int -> ReadS KinesisFirehoseOutputDescription

readList :: ReadS [KinesisFirehoseOutputDescription]

readPrec :: ReadPrec KinesisFirehoseOutputDescription

readListPrec :: ReadPrec [KinesisFirehoseOutputDescription]

Show KinesisFirehoseOutputDescription

Methods

showsPrec :: Int -> KinesisFirehoseOutputDescription -> ShowS

show :: KinesisFirehoseOutputDescription -> String

showList :: [KinesisFirehoseOutputDescription] -> ShowS

Generic KinesisFirehoseOutputDescription

Associated Types

type Rep KinesisFirehoseOutputDescription :: * -> *

Methods

from :: KinesisFirehoseOutputDescription -> Rep KinesisFirehoseOutputDescription x

to :: Rep KinesisFirehoseOutputDescription x -> KinesisFirehoseOutputDescription

Hashable KinesisFirehoseOutputDescription

Methods

hashWithSalt :: Int -> KinesisFirehoseOutputDescription -> Int

hash :: KinesisFirehoseOutputDescription -> Int

FromJSON KinesisFirehoseOutputDescription

Methods

parseJSON :: Value -> Parser KinesisFirehoseOutputDescription

parseJSONList :: Value -> Parser [KinesisFirehoseOutputDescription]

NFData KinesisFirehoseOutputDescription

Methods

rnf :: KinesisFirehoseOutputDescription -> ()

type Rep KinesisFirehoseOutputDescription

type Rep KinesisFirehoseOutputDescription = D1 (MetaData "KinesisFirehoseOutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisFirehoseOutputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfodResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfodRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseOutputDescription :: KinesisFirehoseOutputDescription

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

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

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

kfodResourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)

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

kfodRoleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)

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

KinesisFirehoseOutputUpdate

data KinesisFirehoseOutputUpdate

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

See: kinesisFirehoseOutputUpdate smart constructor.

Instances

Eq KinesisFirehoseOutputUpdate

Methods

(==) :: KinesisFirehoseOutputUpdate -> KinesisFirehoseOutputUpdate -> Bool

(/=) :: KinesisFirehoseOutputUpdate -> KinesisFirehoseOutputUpdate -> Bool

Data KinesisFirehoseOutputUpdate

Methods

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

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

toConstr :: KinesisFirehoseOutputUpdate -> Constr

dataTypeOf :: KinesisFirehoseOutputUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisFirehoseOutputUpdate

Methods

readsPrec :: Int -> ReadS KinesisFirehoseOutputUpdate

readList :: ReadS [KinesisFirehoseOutputUpdate]

readPrec :: ReadPrec KinesisFirehoseOutputUpdate

readListPrec :: ReadPrec [KinesisFirehoseOutputUpdate]

Show KinesisFirehoseOutputUpdate

Methods

showsPrec :: Int -> KinesisFirehoseOutputUpdate -> ShowS

show :: KinesisFirehoseOutputUpdate -> String

showList :: [KinesisFirehoseOutputUpdate] -> ShowS

Generic KinesisFirehoseOutputUpdate

Associated Types

type Rep KinesisFirehoseOutputUpdate :: * -> *

Methods

from :: KinesisFirehoseOutputUpdate -> Rep KinesisFirehoseOutputUpdate x

to :: Rep KinesisFirehoseOutputUpdate x -> KinesisFirehoseOutputUpdate

Hashable KinesisFirehoseOutputUpdate

Methods

hashWithSalt :: Int -> KinesisFirehoseOutputUpdate -> Int

hash :: KinesisFirehoseOutputUpdate -> Int

ToJSON KinesisFirehoseOutputUpdate

Methods

toJSON :: KinesisFirehoseOutputUpdate -> Value

toEncoding :: KinesisFirehoseOutputUpdate -> Encoding

toJSONList :: [KinesisFirehoseOutputUpdate] -> Value

toEncodingList :: [KinesisFirehoseOutputUpdate] -> Encoding

NFData KinesisFirehoseOutputUpdate

Methods

rnf :: KinesisFirehoseOutputUpdate -> ()

type Rep KinesisFirehoseOutputUpdate

type Rep KinesisFirehoseOutputUpdate = D1 (MetaData "KinesisFirehoseOutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisFirehoseOutputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_kfouRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_kfouResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisFirehoseOutputUpdate :: KinesisFirehoseOutputUpdate

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

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

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

kfouRoleARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)

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

kfouResourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)

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

KinesisStreamsInput

data KinesisStreamsInput

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

See: kinesisStreamsInput smart constructor.

Instances

Eq KinesisStreamsInput

Methods

(==) :: KinesisStreamsInput -> KinesisStreamsInput -> Bool

(/=) :: KinesisStreamsInput -> KinesisStreamsInput -> Bool

Data KinesisStreamsInput

Methods

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

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

toConstr :: KinesisStreamsInput -> Constr

dataTypeOf :: KinesisStreamsInput -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisStreamsInput

Methods

readsPrec :: Int -> ReadS KinesisStreamsInput

readList :: ReadS [KinesisStreamsInput]

readPrec :: ReadPrec KinesisStreamsInput

readListPrec :: ReadPrec [KinesisStreamsInput]

Show KinesisStreamsInput

Methods

showsPrec :: Int -> KinesisStreamsInput -> ShowS

show :: KinesisStreamsInput -> String

showList :: [KinesisStreamsInput] -> ShowS

Generic KinesisStreamsInput

Associated Types

type Rep KinesisStreamsInput :: * -> *

Methods

from :: KinesisStreamsInput -> Rep KinesisStreamsInput x

to :: Rep KinesisStreamsInput x -> KinesisStreamsInput

Hashable KinesisStreamsInput

Methods

hashWithSalt :: Int -> KinesisStreamsInput -> Int

hash :: KinesisStreamsInput -> Int

ToJSON KinesisStreamsInput

Methods

toJSON :: KinesisStreamsInput -> Value

toEncoding :: KinesisStreamsInput -> Encoding

toJSONList :: [KinesisStreamsInput] -> Value

toEncodingList :: [KinesisStreamsInput] -> Encoding

NFData KinesisStreamsInput

Methods

rnf :: KinesisStreamsInput -> ()

type Rep KinesisStreamsInput

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

kinesisStreamsInput

Arguments

:: Text

ksiResourceARN

-> Text

ksiRoleARN

-> KinesisStreamsInput

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

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

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

ksiResourceARN :: Lens' KinesisStreamsInput Text

ARN of the input Amazon Kinesis stream to read.

ksiRoleARN :: Lens' KinesisStreamsInput Text

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

KinesisStreamsInputDescription

data KinesisStreamsInputDescription

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

See: kinesisStreamsInputDescription smart constructor.

Instances

Eq KinesisStreamsInputDescription

Methods

(==) :: KinesisStreamsInputDescription -> KinesisStreamsInputDescription -> Bool

(/=) :: KinesisStreamsInputDescription -> KinesisStreamsInputDescription -> Bool

Data KinesisStreamsInputDescription

Methods

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

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

toConstr :: KinesisStreamsInputDescription -> Constr

dataTypeOf :: KinesisStreamsInputDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisStreamsInputDescription

Methods

readsPrec :: Int -> ReadS KinesisStreamsInputDescription

readList :: ReadS [KinesisStreamsInputDescription]

readPrec :: ReadPrec KinesisStreamsInputDescription

readListPrec :: ReadPrec [KinesisStreamsInputDescription]

Show KinesisStreamsInputDescription

Methods

showsPrec :: Int -> KinesisStreamsInputDescription -> ShowS

show :: KinesisStreamsInputDescription -> String

showList :: [KinesisStreamsInputDescription] -> ShowS

Generic KinesisStreamsInputDescription

Associated Types

type Rep KinesisStreamsInputDescription :: * -> *

Methods

from :: KinesisStreamsInputDescription -> Rep KinesisStreamsInputDescription x

to :: Rep KinesisStreamsInputDescription x -> KinesisStreamsInputDescription

Hashable KinesisStreamsInputDescription

Methods

hashWithSalt :: Int -> KinesisStreamsInputDescription -> Int

hash :: KinesisStreamsInputDescription -> Int

FromJSON KinesisStreamsInputDescription

Methods

parseJSON :: Value -> Parser KinesisStreamsInputDescription

parseJSONList :: Value -> Parser [KinesisStreamsInputDescription]

NFData KinesisStreamsInputDescription

Methods

rnf :: KinesisStreamsInputDescription -> ()

type Rep KinesisStreamsInputDescription

type Rep KinesisStreamsInputDescription = D1 (MetaData "KinesisStreamsInputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisStreamsInputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksidResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksidRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsInputDescription :: KinesisStreamsInputDescription

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

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

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

ksidResourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text)

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

ksidRoleARN :: Lens' KinesisStreamsInputDescription (Maybe Text)

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

KinesisStreamsInputUpdate

data KinesisStreamsInputUpdate

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

See: kinesisStreamsInputUpdate smart constructor.

Instances

Eq KinesisStreamsInputUpdate

Methods

(==) :: KinesisStreamsInputUpdate -> KinesisStreamsInputUpdate -> Bool

(/=) :: KinesisStreamsInputUpdate -> KinesisStreamsInputUpdate -> Bool

Data KinesisStreamsInputUpdate

Methods

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

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

toConstr :: KinesisStreamsInputUpdate -> Constr

dataTypeOf :: KinesisStreamsInputUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisStreamsInputUpdate

Methods

readsPrec :: Int -> ReadS KinesisStreamsInputUpdate

readList :: ReadS [KinesisStreamsInputUpdate]

readPrec :: ReadPrec KinesisStreamsInputUpdate

readListPrec :: ReadPrec [KinesisStreamsInputUpdate]

Show KinesisStreamsInputUpdate

Methods

showsPrec :: Int -> KinesisStreamsInputUpdate -> ShowS

show :: KinesisStreamsInputUpdate -> String

showList :: [KinesisStreamsInputUpdate] -> ShowS

Generic KinesisStreamsInputUpdate

Associated Types

type Rep KinesisStreamsInputUpdate :: * -> *

Methods

from :: KinesisStreamsInputUpdate -> Rep KinesisStreamsInputUpdate x

to :: Rep KinesisStreamsInputUpdate x -> KinesisStreamsInputUpdate

Hashable KinesisStreamsInputUpdate

Methods

hashWithSalt :: Int -> KinesisStreamsInputUpdate -> Int

hash :: KinesisStreamsInputUpdate -> Int

ToJSON KinesisStreamsInputUpdate

Methods

toJSON :: KinesisStreamsInputUpdate -> Value

toEncoding :: KinesisStreamsInputUpdate -> Encoding

toJSONList :: [KinesisStreamsInputUpdate] -> Value

toEncodingList :: [KinesisStreamsInputUpdate] -> Encoding

NFData KinesisStreamsInputUpdate

Methods

rnf :: KinesisStreamsInputUpdate -> ()

type Rep KinesisStreamsInputUpdate

type Rep KinesisStreamsInputUpdate = D1 (MetaData "KinesisStreamsInputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisStreamsInputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksiuRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksiuResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsInputUpdate :: KinesisStreamsInputUpdate

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

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

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

ksiuRoleARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)

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

ksiuResourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)

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

KinesisStreamsOutput

data KinesisStreamsOutput

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

See: kinesisStreamsOutput smart constructor.

Instances

Eq KinesisStreamsOutput

Methods

(==) :: KinesisStreamsOutput -> KinesisStreamsOutput -> Bool

(/=) :: KinesisStreamsOutput -> KinesisStreamsOutput -> Bool

Data KinesisStreamsOutput

Methods

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

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

toConstr :: KinesisStreamsOutput -> Constr

dataTypeOf :: KinesisStreamsOutput -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisStreamsOutput

Methods

readsPrec :: Int -> ReadS KinesisStreamsOutput

readList :: ReadS [KinesisStreamsOutput]

readPrec :: ReadPrec KinesisStreamsOutput

readListPrec :: ReadPrec [KinesisStreamsOutput]

Show KinesisStreamsOutput

Methods

showsPrec :: Int -> KinesisStreamsOutput -> ShowS

show :: KinesisStreamsOutput -> String

showList :: [KinesisStreamsOutput] -> ShowS

Generic KinesisStreamsOutput

Associated Types

type Rep KinesisStreamsOutput :: * -> *

Methods

from :: KinesisStreamsOutput -> Rep KinesisStreamsOutput x

to :: Rep KinesisStreamsOutput x -> KinesisStreamsOutput

Hashable KinesisStreamsOutput

Methods

hashWithSalt :: Int -> KinesisStreamsOutput -> Int

hash :: KinesisStreamsOutput -> Int

ToJSON KinesisStreamsOutput

Methods

toJSON :: KinesisStreamsOutput -> Value

toEncoding :: KinesisStreamsOutput -> Encoding

toJSONList :: [KinesisStreamsOutput] -> Value

toEncodingList :: [KinesisStreamsOutput] -> Encoding

NFData KinesisStreamsOutput

Methods

rnf :: KinesisStreamsOutput -> ()

type Rep KinesisStreamsOutput

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

kinesisStreamsOutput

Arguments

:: Text

ksoResourceARN

-> Text

ksoRoleARN

-> KinesisStreamsOutput

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

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

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

ksoResourceARN :: Lens' KinesisStreamsOutput Text

ARN of the destination Amazon Kinesis stream to write to.

ksoRoleARN :: Lens' KinesisStreamsOutput Text

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

KinesisStreamsOutputDescription

data KinesisStreamsOutputDescription

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

See: kinesisStreamsOutputDescription smart constructor.

Instances

Eq KinesisStreamsOutputDescription

Methods

(==) :: KinesisStreamsOutputDescription -> KinesisStreamsOutputDescription -> Bool

(/=) :: KinesisStreamsOutputDescription -> KinesisStreamsOutputDescription -> Bool

Data KinesisStreamsOutputDescription

Methods

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

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

toConstr :: KinesisStreamsOutputDescription -> Constr

dataTypeOf :: KinesisStreamsOutputDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisStreamsOutputDescription

Methods

readsPrec :: Int -> ReadS KinesisStreamsOutputDescription

readList :: ReadS [KinesisStreamsOutputDescription]

readPrec :: ReadPrec KinesisStreamsOutputDescription

readListPrec :: ReadPrec [KinesisStreamsOutputDescription]

Show KinesisStreamsOutputDescription

Methods

showsPrec :: Int -> KinesisStreamsOutputDescription -> ShowS

show :: KinesisStreamsOutputDescription -> String

showList :: [KinesisStreamsOutputDescription] -> ShowS

Generic KinesisStreamsOutputDescription

Associated Types

type Rep KinesisStreamsOutputDescription :: * -> *

Methods

from :: KinesisStreamsOutputDescription -> Rep KinesisStreamsOutputDescription x

to :: Rep KinesisStreamsOutputDescription x -> KinesisStreamsOutputDescription

Hashable KinesisStreamsOutputDescription

Methods

hashWithSalt :: Int -> KinesisStreamsOutputDescription -> Int

hash :: KinesisStreamsOutputDescription -> Int

FromJSON KinesisStreamsOutputDescription

Methods

parseJSON :: Value -> Parser KinesisStreamsOutputDescription

parseJSONList :: Value -> Parser [KinesisStreamsOutputDescription]

NFData KinesisStreamsOutputDescription

Methods

rnf :: KinesisStreamsOutputDescription -> ()

type Rep KinesisStreamsOutputDescription

type Rep KinesisStreamsOutputDescription = D1 (MetaData "KinesisStreamsOutputDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisStreamsOutputDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksodResourceARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksodRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsOutputDescription :: KinesisStreamsOutputDescription

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

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

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

ksodResourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)

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

ksodRoleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)

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

KinesisStreamsOutputUpdate

data KinesisStreamsOutputUpdate

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

See: kinesisStreamsOutputUpdate smart constructor.

Instances

Eq KinesisStreamsOutputUpdate

Methods

(==) :: KinesisStreamsOutputUpdate -> KinesisStreamsOutputUpdate -> Bool

(/=) :: KinesisStreamsOutputUpdate -> KinesisStreamsOutputUpdate -> Bool

Data KinesisStreamsOutputUpdate

Methods

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

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

toConstr :: KinesisStreamsOutputUpdate -> Constr

dataTypeOf :: KinesisStreamsOutputUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read KinesisStreamsOutputUpdate

Methods

readsPrec :: Int -> ReadS KinesisStreamsOutputUpdate

readList :: ReadS [KinesisStreamsOutputUpdate]

readPrec :: ReadPrec KinesisStreamsOutputUpdate

readListPrec :: ReadPrec [KinesisStreamsOutputUpdate]

Show KinesisStreamsOutputUpdate

Methods

showsPrec :: Int -> KinesisStreamsOutputUpdate -> ShowS

show :: KinesisStreamsOutputUpdate -> String

showList :: [KinesisStreamsOutputUpdate] -> ShowS

Generic KinesisStreamsOutputUpdate

Associated Types

type Rep KinesisStreamsOutputUpdate :: * -> *

Methods

from :: KinesisStreamsOutputUpdate -> Rep KinesisStreamsOutputUpdate x

to :: Rep KinesisStreamsOutputUpdate x -> KinesisStreamsOutputUpdate

Hashable KinesisStreamsOutputUpdate

Methods

hashWithSalt :: Int -> KinesisStreamsOutputUpdate -> Int

hash :: KinesisStreamsOutputUpdate -> Int

ToJSON KinesisStreamsOutputUpdate

Methods

toJSON :: KinesisStreamsOutputUpdate -> Value

toEncoding :: KinesisStreamsOutputUpdate -> Encoding

toJSONList :: [KinesisStreamsOutputUpdate] -> Value

toEncodingList :: [KinesisStreamsOutputUpdate] -> Encoding

NFData KinesisStreamsOutputUpdate

Methods

rnf :: KinesisStreamsOutputUpdate -> ()

type Rep KinesisStreamsOutputUpdate

type Rep KinesisStreamsOutputUpdate = D1 (MetaData "KinesisStreamsOutputUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "KinesisStreamsOutputUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_ksouRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_ksouResourceARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text)))))

kinesisStreamsOutputUpdate :: KinesisStreamsOutputUpdate

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

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

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

ksouRoleARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)

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

ksouResourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)

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

MappingParameters

data MappingParameters

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

See: mappingParameters smart constructor.

Instances

Eq MappingParameters

Methods

(==) :: MappingParameters -> MappingParameters -> Bool

(/=) :: MappingParameters -> MappingParameters -> Bool

Data MappingParameters

Methods

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

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

toConstr :: MappingParameters -> Constr

dataTypeOf :: MappingParameters -> DataType

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

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

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

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

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

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

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

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

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

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

Read MappingParameters

Methods

readsPrec :: Int -> ReadS MappingParameters

readList :: ReadS [MappingParameters]

readPrec :: ReadPrec MappingParameters

readListPrec :: ReadPrec [MappingParameters]

Show MappingParameters

Methods

showsPrec :: Int -> MappingParameters -> ShowS

show :: MappingParameters -> String

showList :: [MappingParameters] -> ShowS

Generic MappingParameters

Associated Types

type Rep MappingParameters :: * -> *

Methods

from :: MappingParameters -> Rep MappingParameters x

to :: Rep MappingParameters x -> MappingParameters

Hashable MappingParameters

Methods

hashWithSalt :: Int -> MappingParameters -> Int

hash :: MappingParameters -> Int

FromJSON MappingParameters

Methods

parseJSON :: Value -> Parser MappingParameters

parseJSONList :: Value -> Parser [MappingParameters]

ToJSON MappingParameters

Methods

toJSON :: MappingParameters -> Value

toEncoding :: MappingParameters -> Encoding

toJSONList :: [MappingParameters] -> Value

toEncodingList :: [MappingParameters] -> Encoding

NFData MappingParameters

Methods

rnf :: MappingParameters -> ()

type Rep MappingParameters

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

mappingParameters :: MappingParameters

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

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

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

mpCSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters)

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

mpJSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters)

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

Output

data Output

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

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

See: output smart constructor.

Instances

Eq Output

Methods

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

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

Data Output

Methods

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

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

toConstr :: Output -> Constr

dataTypeOf :: Output -> DataType

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

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

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

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

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

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

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

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

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

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

Read Output

Methods

readsPrec :: Int -> ReadS Output

readList :: ReadS [Output]

readPrec :: ReadPrec Output

readListPrec :: ReadPrec [Output]

Show Output

Methods

showsPrec :: Int -> Output -> ShowS

show :: Output -> String

showList :: [Output] -> ShowS

Generic Output

Associated Types

type Rep Output :: * -> *

Methods

from :: Output -> Rep Output x

to :: Rep Output x -> Output

Hashable Output

Methods

hashWithSalt :: Int -> Output -> Int

hash :: Output -> Int

ToJSON Output

Methods

toJSON :: Output -> Value

toEncoding :: Output -> Encoding

toJSONList :: [Output] -> Value

toEncodingList :: [Output] -> Encoding

NFData Output

Methods

rnf :: Output -> ()

type Rep Output

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

output

Arguments

:: Text

oName

-> DestinationSchema

oDestinationSchema

-> Output

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

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

• oKinesisStreamsOutput - Identifies an Amazon Kinesis stream as the destination.
• oKinesisFirehoseOutput - Identifies an Amazon Kinesis Firehose delivery stream as the destination.
• oName - Name of the in-application stream.
• oDestinationSchema - Undocumented member.

oKinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput)

Identifies an Amazon Kinesis stream as the destination.

oKinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput)

Identifies an Amazon Kinesis Firehose delivery stream as the destination.

oName :: Lens' Output Text

Name of the in-application stream.

oDestinationSchema :: Lens' Output DestinationSchema

Undocumented member.

OutputDescription

data OutputDescription

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

See: outputDescription smart constructor.

Instances

Eq OutputDescription

Methods

(==) :: OutputDescription -> OutputDescription -> Bool

(/=) :: OutputDescription -> OutputDescription -> Bool

Data OutputDescription

Methods

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

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

toConstr :: OutputDescription -> Constr

dataTypeOf :: OutputDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read OutputDescription

Methods

readsPrec :: Int -> ReadS OutputDescription

readList :: ReadS [OutputDescription]

readPrec :: ReadPrec OutputDescription

readListPrec :: ReadPrec [OutputDescription]

Show OutputDescription

Methods

showsPrec :: Int -> OutputDescription -> ShowS

show :: OutputDescription -> String

showList :: [OutputDescription] -> ShowS

Generic OutputDescription

Associated Types

type Rep OutputDescription :: * -> *

Methods

from :: OutputDescription -> Rep OutputDescription x

to :: Rep OutputDescription x -> OutputDescription

Hashable OutputDescription

Methods

hashWithSalt :: Int -> OutputDescription -> Int

hash :: OutputDescription -> Int

FromJSON OutputDescription

Methods

parseJSON :: Value -> Parser OutputDescription

parseJSONList :: Value -> Parser [OutputDescription]

NFData OutputDescription

Methods

rnf :: OutputDescription -> ()

type Rep OutputDescription

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

outputDescription :: OutputDescription

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

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

• odOutputId - A unique identifier for the output configuration.
• odDestinationSchema - Data format used for writing data to the destination.
• odKinesisFirehoseOutputDescription - Describes the Amazon Kinesis Firehose delivery stream configured as the destination where output is written.
• odKinesisStreamsOutputDescription - Describes Amazon Kinesis stream configured as the destination where output is written.
• odName - Name of the in-application stream configured as output.

odOutputId :: Lens' OutputDescription (Maybe Text)

A unique identifier for the output configuration.

odDestinationSchema :: Lens' OutputDescription (Maybe DestinationSchema)

Data format used for writing data to the destination.

odKinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription)

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

odKinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription)

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

odName :: Lens' OutputDescription (Maybe Text)

Name of the in-application stream configured as output.

OutputUpdate

data OutputUpdate

Describes updates to the output configuration identified by the OutputId .

See: outputUpdate smart constructor.

Instances

Eq OutputUpdate

Methods

(==) :: OutputUpdate -> OutputUpdate -> Bool

(/=) :: OutputUpdate -> OutputUpdate -> Bool

Data OutputUpdate

Methods

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

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

toConstr :: OutputUpdate -> Constr

dataTypeOf :: OutputUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read OutputUpdate

Methods

readsPrec :: Int -> ReadS OutputUpdate

readList :: ReadS [OutputUpdate]

readPrec :: ReadPrec OutputUpdate

readListPrec :: ReadPrec [OutputUpdate]

Show OutputUpdate

Methods

showsPrec :: Int -> OutputUpdate -> ShowS

show :: OutputUpdate -> String

showList :: [OutputUpdate] -> ShowS

Generic OutputUpdate

Associated Types

type Rep OutputUpdate :: * -> *

Methods

from :: OutputUpdate -> Rep OutputUpdate x

to :: Rep OutputUpdate x -> OutputUpdate

Hashable OutputUpdate

Methods

hashWithSalt :: Int -> OutputUpdate -> Int

hash :: OutputUpdate -> Int

ToJSON OutputUpdate

Methods

toJSON :: OutputUpdate -> Value

toEncoding :: OutputUpdate -> Encoding

toJSONList :: [OutputUpdate] -> Value

toEncodingList :: [OutputUpdate] -> Encoding

NFData OutputUpdate

Methods

rnf :: OutputUpdate -> ()

type Rep OutputUpdate

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

outputUpdate

Arguments

:: Text

ouOutputId

-> OutputUpdate

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

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

• ouKinesisStreamsOutputUpdate - Describes an Amazon Kinesis stream as the destination for the output.
• ouDestinationSchemaUpdate - Undocumented member.
• ouKinesisFirehoseOutputUpdate - Describes a Amazon Kinesis Firehose delivery stream as the destination for the output.
• ouNameUpdate - If you want to specify a different in-application stream for this output configuration, use this field to specify the new in-application stream name.
• ouOutputId - Identifies the specific output configuration that you want to update.

ouKinesisStreamsOutputUpdate :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate)

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

ouDestinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema)

Undocumented member.

ouKinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate)

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

ouNameUpdate :: Lens' OutputUpdate (Maybe Text)

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

ouOutputId :: Lens' OutputUpdate Text

Identifies the specific output configuration that you want to update.

RecordColumn

data RecordColumn

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

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

See: recordColumn smart constructor.

Instances

Eq RecordColumn

Methods

(==) :: RecordColumn -> RecordColumn -> Bool

(/=) :: RecordColumn -> RecordColumn -> Bool

Data RecordColumn

Methods

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

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

toConstr :: RecordColumn -> Constr

dataTypeOf :: RecordColumn -> DataType

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

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

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

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

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

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

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

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

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

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

Read RecordColumn

Methods

readsPrec :: Int -> ReadS RecordColumn

readList :: ReadS [RecordColumn]

readPrec :: ReadPrec RecordColumn

readListPrec :: ReadPrec [RecordColumn]

Show RecordColumn

Methods

showsPrec :: Int -> RecordColumn -> ShowS

show :: RecordColumn -> String

showList :: [RecordColumn] -> ShowS

Generic RecordColumn

Associated Types

type Rep RecordColumn :: * -> *

Methods

from :: RecordColumn -> Rep RecordColumn x

to :: Rep RecordColumn x -> RecordColumn

Hashable RecordColumn

Methods

hashWithSalt :: Int -> RecordColumn -> Int

hash :: RecordColumn -> Int

FromJSON RecordColumn

Methods

parseJSON :: Value -> Parser RecordColumn

parseJSONList :: Value -> Parser [RecordColumn]

ToJSON RecordColumn

Methods

toJSON :: RecordColumn -> Value

toEncoding :: RecordColumn -> Encoding

toJSONList :: [RecordColumn] -> Value

toEncodingList :: [RecordColumn] -> Encoding

NFData RecordColumn

Methods

rnf :: RecordColumn -> ()

type Rep RecordColumn

type Rep RecordColumn = D1 (MetaData "RecordColumn" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "RecordColumn'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_rcMapping") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) ((:*:) (S1 (MetaSel (Just Symbol "_rcName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_rcSqlType") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))))

recordColumn

Arguments

:: Text

rcName

-> Text

rcSqlType

-> RecordColumn

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

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

• rcMapping - Reference to the data element in the streaming input of the reference data source.
• rcName - Name of the column created in the in-application input stream or reference table.
• rcSqlType - Type of column created in the in-application input stream or reference table.

rcMapping :: Lens' RecordColumn (Maybe Text)

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

rcName :: Lens' RecordColumn Text

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

rcSqlType :: Lens' RecordColumn Text

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

RecordFormat

data RecordFormat

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

See: recordFormat smart constructor.

Instances

Eq RecordFormat

Methods

(==) :: RecordFormat -> RecordFormat -> Bool

(/=) :: RecordFormat -> RecordFormat -> Bool

Data RecordFormat

Methods

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

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

toConstr :: RecordFormat -> Constr

dataTypeOf :: RecordFormat -> DataType

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

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

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

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

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

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

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

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

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

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

Read RecordFormat

Methods

readsPrec :: Int -> ReadS RecordFormat

readList :: ReadS [RecordFormat]

readPrec :: ReadPrec RecordFormat

readListPrec :: ReadPrec [RecordFormat]

Show RecordFormat

Methods

showsPrec :: Int -> RecordFormat -> ShowS

show :: RecordFormat -> String

showList :: [RecordFormat] -> ShowS

Generic RecordFormat

Associated Types

type Rep RecordFormat :: * -> *

Methods

from :: RecordFormat -> Rep RecordFormat x

to :: Rep RecordFormat x -> RecordFormat

Hashable RecordFormat

Methods

hashWithSalt :: Int -> RecordFormat -> Int

hash :: RecordFormat -> Int

FromJSON RecordFormat

Methods

parseJSON :: Value -> Parser RecordFormat

parseJSONList :: Value -> Parser [RecordFormat]

ToJSON RecordFormat

Methods

toJSON :: RecordFormat -> Value

toEncoding :: RecordFormat -> Encoding

toJSONList :: [RecordFormat] -> Value

toEncodingList :: [RecordFormat] -> Encoding

NFData RecordFormat

Methods

rnf :: RecordFormat -> ()

type Rep RecordFormat

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

recordFormat

Arguments

:: RecordFormatType

rfRecordFormatType

-> RecordFormat

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

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

• rfMappingParameters - Undocumented member.
• rfRecordFormatType - The type of record format.

rfMappingParameters :: Lens' RecordFormat (Maybe MappingParameters)

Undocumented member.

rfRecordFormatType :: Lens' RecordFormat RecordFormatType

The type of record format.

ReferenceDataSource

data ReferenceDataSource

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

See: referenceDataSource smart constructor.

Instances

Eq ReferenceDataSource

Methods

(==) :: ReferenceDataSource -> ReferenceDataSource -> Bool

(/=) :: ReferenceDataSource -> ReferenceDataSource -> Bool

Data ReferenceDataSource

Methods

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

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

toConstr :: ReferenceDataSource -> Constr

dataTypeOf :: ReferenceDataSource -> DataType

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

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

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

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

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

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

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

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

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

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

Read ReferenceDataSource

Methods

readsPrec :: Int -> ReadS ReferenceDataSource

readList :: ReadS [ReferenceDataSource]

readPrec :: ReadPrec ReferenceDataSource

readListPrec :: ReadPrec [ReferenceDataSource]

Show ReferenceDataSource

Methods

showsPrec :: Int -> ReferenceDataSource -> ShowS

show :: ReferenceDataSource -> String

showList :: [ReferenceDataSource] -> ShowS

Generic ReferenceDataSource

Associated Types

type Rep ReferenceDataSource :: * -> *

Methods

from :: ReferenceDataSource -> Rep ReferenceDataSource x

to :: Rep ReferenceDataSource x -> ReferenceDataSource

Hashable ReferenceDataSource

Methods

hashWithSalt :: Int -> ReferenceDataSource -> Int

hash :: ReferenceDataSource -> Int

ToJSON ReferenceDataSource

Methods

toJSON :: ReferenceDataSource -> Value

toEncoding :: ReferenceDataSource -> Encoding

toJSONList :: [ReferenceDataSource] -> Value

toEncodingList :: [ReferenceDataSource] -> Encoding

NFData ReferenceDataSource

Methods

rnf :: ReferenceDataSource -> ()

type Rep ReferenceDataSource

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

referenceDataSource

Arguments

:: Text

rdsTableName

-> SourceSchema

rdsReferenceSchema

-> ReferenceDataSource

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

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

• rdsS3ReferenceDataSource - Undocumented member.
• rdsTableName - Name of the in-application table to create.
• rdsReferenceSchema - Undocumented member.

rdsS3ReferenceDataSource :: Lens' ReferenceDataSource (Maybe S3ReferenceDataSource)

Undocumented member.

rdsTableName :: Lens' ReferenceDataSource Text

Name of the in-application table to create.

rdsReferenceSchema :: Lens' ReferenceDataSource SourceSchema

Undocumented member.

ReferenceDataSourceDescription

data ReferenceDataSourceDescription

Describes the reference data source configured for an application.

See: referenceDataSourceDescription smart constructor.

Instances

Eq ReferenceDataSourceDescription

Methods

(==) :: ReferenceDataSourceDescription -> ReferenceDataSourceDescription -> Bool

(/=) :: ReferenceDataSourceDescription -> ReferenceDataSourceDescription -> Bool

Data ReferenceDataSourceDescription

Methods

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

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

toConstr :: ReferenceDataSourceDescription -> Constr

dataTypeOf :: ReferenceDataSourceDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read ReferenceDataSourceDescription

Methods

readsPrec :: Int -> ReadS ReferenceDataSourceDescription

readList :: ReadS [ReferenceDataSourceDescription]

readPrec :: ReadPrec ReferenceDataSourceDescription

readListPrec :: ReadPrec [ReferenceDataSourceDescription]

Show ReferenceDataSourceDescription

Methods

showsPrec :: Int -> ReferenceDataSourceDescription -> ShowS

show :: ReferenceDataSourceDescription -> String

showList :: [ReferenceDataSourceDescription] -> ShowS

Generic ReferenceDataSourceDescription

Associated Types

type Rep ReferenceDataSourceDescription :: * -> *

Methods

from :: ReferenceDataSourceDescription -> Rep ReferenceDataSourceDescription x

to :: Rep ReferenceDataSourceDescription x -> ReferenceDataSourceDescription

Hashable ReferenceDataSourceDescription

Methods

hashWithSalt :: Int -> ReferenceDataSourceDescription -> Int

hash :: ReferenceDataSourceDescription -> Int

FromJSON ReferenceDataSourceDescription

Methods

parseJSON :: Value -> Parser ReferenceDataSourceDescription

parseJSONList :: Value -> Parser [ReferenceDataSourceDescription]

NFData ReferenceDataSourceDescription

Methods

rnf :: ReferenceDataSourceDescription -> ()

type Rep ReferenceDataSourceDescription

type Rep ReferenceDataSourceDescription = D1 (MetaData "ReferenceDataSourceDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "ReferenceDataSourceDescription'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_rdsdReferenceSchema") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceSchema))) (S1 (MetaSel (Just Symbol "_rdsdReferenceId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))) ((:*:) (S1 (MetaSel (Just Symbol "_rdsdTableName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_rdsdS3ReferenceDataSourceDescription") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 S3ReferenceDataSourceDescription)))))

referenceDataSourceDescription

Arguments

:: Text

rdsdReferenceId

-> Text

rdsdTableName

-> S3ReferenceDataSourceDescription

rdsdS3ReferenceDataSourceDescription

-> ReferenceDataSourceDescription

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

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

• rdsdReferenceSchema - Undocumented member.
• rdsdReferenceId - ID of the reference data source. This is the ID that Amazon Kinesis Analytics assigns when you add the reference data source to your application using the AddApplicationReferenceDataSource operation.
• rdsdTableName - The in-application table name created by the specific reference data source configuration.
• rdsdS3ReferenceDataSourceDescription - Provides the S3 bucket name, the object key name that contains the reference data. It also provides the Amazon Resource Name (ARN) of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application reference table.

rdsdReferenceSchema :: Lens' ReferenceDataSourceDescription (Maybe SourceSchema)

Undocumented member.

rdsdReferenceId :: Lens' ReferenceDataSourceDescription Text

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

rdsdTableName :: Lens' ReferenceDataSourceDescription Text

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

rdsdS3ReferenceDataSourceDescription :: Lens' ReferenceDataSourceDescription S3ReferenceDataSourceDescription

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

ReferenceDataSourceUpdate

data ReferenceDataSourceUpdate

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

See: referenceDataSourceUpdate smart constructor.

Instances

Eq ReferenceDataSourceUpdate

Methods

(==) :: ReferenceDataSourceUpdate -> ReferenceDataSourceUpdate -> Bool

(/=) :: ReferenceDataSourceUpdate -> ReferenceDataSourceUpdate -> Bool

Data ReferenceDataSourceUpdate

Methods

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

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

toConstr :: ReferenceDataSourceUpdate -> Constr

dataTypeOf :: ReferenceDataSourceUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read ReferenceDataSourceUpdate

Methods

readsPrec :: Int -> ReadS ReferenceDataSourceUpdate

readList :: ReadS [ReferenceDataSourceUpdate]

readPrec :: ReadPrec ReferenceDataSourceUpdate

readListPrec :: ReadPrec [ReferenceDataSourceUpdate]

Show ReferenceDataSourceUpdate

Methods

showsPrec :: Int -> ReferenceDataSourceUpdate -> ShowS

show :: ReferenceDataSourceUpdate -> String

showList :: [ReferenceDataSourceUpdate] -> ShowS

Generic ReferenceDataSourceUpdate

Associated Types

type Rep ReferenceDataSourceUpdate :: * -> *

Methods

from :: ReferenceDataSourceUpdate -> Rep ReferenceDataSourceUpdate x

to :: Rep ReferenceDataSourceUpdate x -> ReferenceDataSourceUpdate

Hashable ReferenceDataSourceUpdate

Methods

hashWithSalt :: Int -> ReferenceDataSourceUpdate -> Int

hash :: ReferenceDataSourceUpdate -> Int

ToJSON ReferenceDataSourceUpdate

Methods

toJSON :: ReferenceDataSourceUpdate -> Value

toEncoding :: ReferenceDataSourceUpdate -> Encoding

toJSONList :: [ReferenceDataSourceUpdate] -> Value

toEncodingList :: [ReferenceDataSourceUpdate] -> Encoding

NFData ReferenceDataSourceUpdate

Methods

rnf :: ReferenceDataSourceUpdate -> ()

type Rep ReferenceDataSourceUpdate

type Rep ReferenceDataSourceUpdate = D1 (MetaData "ReferenceDataSourceUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "ReferenceDataSourceUpdate'" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_rdsuTableNameUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_rdsuS3ReferenceDataSourceUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe S3ReferenceDataSourceUpdate)))) ((:*:) (S1 (MetaSel (Just Symbol "_rdsuReferenceSchemaUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SourceSchema))) (S1 (MetaSel (Just Symbol "_rdsuReferenceId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))))

referenceDataSourceUpdate

Arguments

:: Text

rdsuReferenceId

-> ReferenceDataSourceUpdate

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

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

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

rdsuTableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text)

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

rdsuS3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe S3ReferenceDataSourceUpdate)

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

rdsuReferenceSchemaUpdate :: Lens' ReferenceDataSourceUpdate (Maybe SourceSchema)

Undocumented member.

rdsuReferenceId :: Lens' ReferenceDataSourceUpdate Text

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

S3Configuration

data S3Configuration

See: s3Configuration smart constructor.

Instances

Eq S3Configuration

Methods

(==) :: S3Configuration -> S3Configuration -> Bool

(/=) :: S3Configuration -> S3Configuration -> Bool

Data S3Configuration

Methods

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

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

toConstr :: S3Configuration -> Constr

dataTypeOf :: S3Configuration -> DataType

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

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

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

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

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

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

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

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

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

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

Read S3Configuration

Methods

readsPrec :: Int -> ReadS S3Configuration

readList :: ReadS [S3Configuration]

readPrec :: ReadPrec S3Configuration

readListPrec :: ReadPrec [S3Configuration]

Show S3Configuration

Methods

showsPrec :: Int -> S3Configuration -> ShowS

show :: S3Configuration -> String

showList :: [S3Configuration] -> ShowS

Generic S3Configuration

Associated Types

type Rep S3Configuration :: * -> *

Methods

from :: S3Configuration -> Rep S3Configuration x

to :: Rep S3Configuration x -> S3Configuration

Hashable S3Configuration

Methods

hashWithSalt :: Int -> S3Configuration -> Int

hash :: S3Configuration -> Int

ToJSON S3Configuration

Methods

toJSON :: S3Configuration -> Value

toEncoding :: S3Configuration -> Encoding

toJSONList :: [S3Configuration] -> Value

toEncodingList :: [S3Configuration] -> Encoding

NFData S3Configuration

Methods

rnf :: S3Configuration -> ()

type Rep S3Configuration

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

s3Configuration

Arguments

:: Text

scRoleARN

-> Text

scBucketARN

-> Text

scFileKey

-> S3Configuration

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

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

• scRoleARN - Undocumented member.
• scBucketARN - Undocumented member.
• scFileKey - Undocumented member.

scRoleARN :: Lens' S3Configuration Text

Undocumented member.

scBucketARN :: Lens' S3Configuration Text

Undocumented member.

scFileKey :: Lens' S3Configuration Text

Undocumented member.

S3ReferenceDataSource

data S3ReferenceDataSource

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

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

See: s3ReferenceDataSource smart constructor.

Instances

Eq S3ReferenceDataSource

Methods

(==) :: S3ReferenceDataSource -> S3ReferenceDataSource -> Bool

(/=) :: S3ReferenceDataSource -> S3ReferenceDataSource -> Bool

Data S3ReferenceDataSource

Methods

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

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

toConstr :: S3ReferenceDataSource -> Constr

dataTypeOf :: S3ReferenceDataSource -> DataType

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

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

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

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

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

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

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

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

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

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

Read S3ReferenceDataSource

Methods

readsPrec :: Int -> ReadS S3ReferenceDataSource

readList :: ReadS [S3ReferenceDataSource]

readPrec :: ReadPrec S3ReferenceDataSource

readListPrec :: ReadPrec [S3ReferenceDataSource]

Show S3ReferenceDataSource

Methods

showsPrec :: Int -> S3ReferenceDataSource -> ShowS

show :: S3ReferenceDataSource -> String

showList :: [S3ReferenceDataSource] -> ShowS

Generic S3ReferenceDataSource

Associated Types

type Rep S3ReferenceDataSource :: * -> *

Methods

from :: S3ReferenceDataSource -> Rep S3ReferenceDataSource x

to :: Rep S3ReferenceDataSource x -> S3ReferenceDataSource

Hashable S3ReferenceDataSource

Methods

hashWithSalt :: Int -> S3ReferenceDataSource -> Int

hash :: S3ReferenceDataSource -> Int

ToJSON S3ReferenceDataSource

Methods

toJSON :: S3ReferenceDataSource -> Value

toEncoding :: S3ReferenceDataSource -> Encoding

toJSONList :: [S3ReferenceDataSource] -> Value

toEncodingList :: [S3ReferenceDataSource] -> Encoding

NFData S3ReferenceDataSource

Methods

rnf :: S3ReferenceDataSource -> ()

type Rep S3ReferenceDataSource

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

s3ReferenceDataSource

Arguments

:: Text

srdsBucketARN

-> Text

srdsFileKey

-> Text

srdsReferenceRoleARN

-> S3ReferenceDataSource

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

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

• srdsBucketARN - Amazon Resource Name (ARN) of the S3 bucket.
• srdsFileKey - Object key name containing reference data.
• srdsReferenceRoleARN - ARN of the IAM role that the service can assume to read data on your behalf. This role must have permission for the s3:GetObject action on the object and trust policy that allows Amazon Kinesis Analytics service principal to assume this role.

srdsBucketARN :: Lens' S3ReferenceDataSource Text

Amazon Resource Name (ARN) of the S3 bucket.

srdsFileKey :: Lens' S3ReferenceDataSource Text

Object key name containing reference data.

srdsReferenceRoleARN :: Lens' S3ReferenceDataSource Text

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

S3ReferenceDataSourceDescription

data S3ReferenceDataSourceDescription

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

See: s3ReferenceDataSourceDescription smart constructor.

Instances

Eq S3ReferenceDataSourceDescription

Methods

(==) :: S3ReferenceDataSourceDescription -> S3ReferenceDataSourceDescription -> Bool

(/=) :: S3ReferenceDataSourceDescription -> S3ReferenceDataSourceDescription -> Bool

Data S3ReferenceDataSourceDescription

Methods

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

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

toConstr :: S3ReferenceDataSourceDescription -> Constr

dataTypeOf :: S3ReferenceDataSourceDescription -> DataType

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

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

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

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

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

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

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

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

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

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

Read S3ReferenceDataSourceDescription

Methods

readsPrec :: Int -> ReadS S3ReferenceDataSourceDescription

readList :: ReadS [S3ReferenceDataSourceDescription]

readPrec :: ReadPrec S3ReferenceDataSourceDescription

readListPrec :: ReadPrec [S3ReferenceDataSourceDescription]

Show S3ReferenceDataSourceDescription

Methods

showsPrec :: Int -> S3ReferenceDataSourceDescription -> ShowS

show :: S3ReferenceDataSourceDescription -> String

showList :: [S3ReferenceDataSourceDescription] -> ShowS

Generic S3ReferenceDataSourceDescription

Associated Types

type Rep S3ReferenceDataSourceDescription :: * -> *

Methods

from :: S3ReferenceDataSourceDescription -> Rep S3ReferenceDataSourceDescription x

to :: Rep S3ReferenceDataSourceDescription x -> S3ReferenceDataSourceDescription

Hashable S3ReferenceDataSourceDescription

Methods

hashWithSalt :: Int -> S3ReferenceDataSourceDescription -> Int

hash :: S3ReferenceDataSourceDescription -> Int

FromJSON S3ReferenceDataSourceDescription

Methods

parseJSON :: Value -> Parser S3ReferenceDataSourceDescription

parseJSONList :: Value -> Parser [S3ReferenceDataSourceDescription]

NFData S3ReferenceDataSourceDescription

Methods

rnf :: S3ReferenceDataSourceDescription -> ()

type Rep S3ReferenceDataSourceDescription

type Rep S3ReferenceDataSourceDescription = D1 (MetaData "S3ReferenceDataSourceDescription" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "S3ReferenceDataSourceDescription'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_srdsdBucketARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) ((:*:) (S1 (MetaSel (Just Symbol "_srdsdFileKey") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_srdsdReferenceRoleARN") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))))

s3ReferenceDataSourceDescription

Arguments

:: Text

srdsdBucketARN

-> Text

srdsdFileKey

-> Text

srdsdReferenceRoleARN

-> S3ReferenceDataSourceDescription

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

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

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

srdsdBucketARN :: Lens' S3ReferenceDataSourceDescription Text

Amazon Resource Name (ARN) of the S3 bucket.

srdsdFileKey :: Lens' S3ReferenceDataSourceDescription Text

Amazon S3 object key name.

srdsdReferenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text

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

S3ReferenceDataSourceUpdate

data S3ReferenceDataSourceUpdate

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

See: s3ReferenceDataSourceUpdate smart constructor.

Instances

Eq S3ReferenceDataSourceUpdate

Methods

(==) :: S3ReferenceDataSourceUpdate -> S3ReferenceDataSourceUpdate -> Bool

(/=) :: S3ReferenceDataSourceUpdate -> S3ReferenceDataSourceUpdate -> Bool

Data S3ReferenceDataSourceUpdate

Methods

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

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

toConstr :: S3ReferenceDataSourceUpdate -> Constr

dataTypeOf :: S3ReferenceDataSourceUpdate -> DataType

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

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

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

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

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

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

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

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

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

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

Read S3ReferenceDataSourceUpdate

Methods

readsPrec :: Int -> ReadS S3ReferenceDataSourceUpdate

readList :: ReadS [S3ReferenceDataSourceUpdate]

readPrec :: ReadPrec S3ReferenceDataSourceUpdate

readListPrec :: ReadPrec [S3ReferenceDataSourceUpdate]

Show S3ReferenceDataSourceUpdate

Methods

showsPrec :: Int -> S3ReferenceDataSourceUpdate -> ShowS

show :: S3ReferenceDataSourceUpdate -> String

showList :: [S3ReferenceDataSourceUpdate] -> ShowS

Generic S3ReferenceDataSourceUpdate

Associated Types

type Rep S3ReferenceDataSourceUpdate :: * -> *

Methods

from :: S3ReferenceDataSourceUpdate -> Rep S3ReferenceDataSourceUpdate x

to :: Rep S3ReferenceDataSourceUpdate x -> S3ReferenceDataSourceUpdate

Hashable S3ReferenceDataSourceUpdate

Methods

hashWithSalt :: Int -> S3ReferenceDataSourceUpdate -> Int

hash :: S3ReferenceDataSourceUpdate -> Int

ToJSON S3ReferenceDataSourceUpdate

Methods

toJSON :: S3ReferenceDataSourceUpdate -> Value

toEncoding :: S3ReferenceDataSourceUpdate -> Encoding

toJSONList :: [S3ReferenceDataSourceUpdate] -> Value

toEncodingList :: [S3ReferenceDataSourceUpdate] -> Encoding

NFData S3ReferenceDataSourceUpdate

Methods

rnf :: S3ReferenceDataSourceUpdate -> ()

type Rep S3ReferenceDataSourceUpdate

type Rep S3ReferenceDataSourceUpdate = D1 (MetaData "S3ReferenceDataSourceUpdate" "Network.AWS.KinesisAnalytics.Types.Product" "amazonka-kinesis-analytics-1.5.0-Aag53z1k8npIGaZevnWzPh" False) (C1 (MetaCons "S3ReferenceDataSourceUpdate'" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_srdsuBucketARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) ((:*:) (S1 (MetaSel (Just Symbol "_srdsuFileKeyUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_srdsuReferenceRoleARNUpdate") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe Text))))))

s3ReferenceDataSourceUpdate :: S3ReferenceDataSourceUpdate

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

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

• srdsuBucketARNUpdate - Amazon Resource Name (ARN) of the S3 bucket.
• srdsuFileKeyUpdate - Object key name.
• srdsuReferenceRoleARNUpdate - ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application.

srdsuBucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)

Amazon Resource Name (ARN) of the S3 bucket.

srdsuFileKeyUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)

Object key name.

srdsuReferenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)

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

SourceSchema

data SourceSchema

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

See: sourceSchema smart constructor.

Instances

Eq SourceSchema

Methods

(==) :: SourceSchema -> SourceSchema -> Bool

(/=) :: SourceSchema -> SourceSchema -> Bool

Data SourceSchema

Methods

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

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

toConstr :: SourceSchema -> Constr

dataTypeOf :: SourceSchema -> DataType

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

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

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

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

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

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

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

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

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

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

Read SourceSchema

Methods

readsPrec :: Int -> ReadS SourceSchema

readList :: ReadS [SourceSchema]

readPrec :: ReadPrec SourceSchema

readListPrec :: ReadPrec [SourceSchema]

Show SourceSchema

Methods

showsPrec :: Int -> SourceSchema -> ShowS

show :: SourceSchema -> String

showList :: [SourceSchema] -> ShowS

Generic SourceSchema

Associated Types

type Rep SourceSchema :: * -> *

Methods

from :: SourceSchema -> Rep SourceSchema x

to :: Rep SourceSchema x -> SourceSchema

Hashable SourceSchema

Methods

hashWithSalt :: Int -> SourceSchema -> Int

hash :: SourceSchema -> Int

FromJSON SourceSchema

Methods

parseJSON :: Value -> Parser SourceSchema

parseJSONList :: Value -> Parser [SourceSchema]

ToJSON SourceSchema

Methods

toJSON :: SourceSchema -> Value

toEncoding :: SourceSchema -> Encoding

toJSONList :: [SourceSchema] -> Value

toEncodingList :: [SourceSchema] -> Encoding

NFData SourceSchema

Methods

rnf :: SourceSchema -> ()

type Rep SourceSchema

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

sourceSchema

Arguments

:: RecordFormat

ssRecordFormat

-> NonEmpty RecordColumn

ssRecordColumns

-> SourceSchema

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

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

• ssRecordEncoding - Specifies the encoding of the records in the streaming source. For example, UTF-8.
• ssRecordFormat - Specifies the format of the records on the streaming source.
• ssRecordColumns - A list of RecordColumn objects.

ssRecordEncoding :: Lens' SourceSchema (Maybe Text)

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

ssRecordFormat :: Lens' SourceSchema RecordFormat

Specifies the format of the records on the streaming source.

ssRecordColumns :: Lens' SourceSchema (NonEmpty RecordColumn)

A list of RecordColumn objects.