amazonka-kinesis-analytics 1.4.5 → 1.5.0

raw patch · 34 files changed

+4314/−2679 lines, 34 filesdep ~amazonka-coredep ~amazonka-kinesis-analyticsdep ~amazonka-testPVP ok

version bump matches the API change (PVP)

Dependency ranges changed: amazonka-core, amazonka-kinesis-analytics, amazonka-test

API changes (from Hackage documentation)

Files

• README.md +1/−1
• amazonka-kinesis-analytics.cabal +20/−11
• fixture/AddApplicationCloudWatchLoggingOption.yaml +10/−0
• fixture/AddApplicationCloudWatchLoggingOptionResponse.proto +0/−0
• fixture/AddApplicationInputProcessingConfiguration.yaml +10/−0
• fixture/AddApplicationInputProcessingConfigurationResponse.proto +0/−0
• fixture/DeleteApplicationCloudWatchLoggingOption.yaml +10/−0
• fixture/DeleteApplicationCloudWatchLoggingOptionResponse.proto +0/−0
• fixture/DeleteApplicationInputProcessingConfiguration.yaml +10/−0
• fixture/DeleteApplicationInputProcessingConfigurationResponse.proto +0/−0
• gen/Network/AWS/KinesisAnalytics.hs +101/−17
• gen/Network/AWS/KinesisAnalytics/AddApplicationCloudWatchLoggingOption.hs +168/−0
• gen/Network/AWS/KinesisAnalytics/AddApplicationInput.hs +29/−27
• gen/Network/AWS/KinesisAnalytics/AddApplicationInputProcessingConfiguration.hs +183/−0
• gen/Network/AWS/KinesisAnalytics/AddApplicationOutput.hs +27/−25
• gen/Network/AWS/KinesisAnalytics/AddApplicationReferenceDataSource.hs +29/−23
• gen/Network/AWS/KinesisAnalytics/CreateApplication.hs +49/−34
• gen/Network/AWS/KinesisAnalytics/DeleteApplication.hs +25/−23
• gen/Network/AWS/KinesisAnalytics/DeleteApplicationCloudWatchLoggingOption.hs +171/−0
• gen/Network/AWS/KinesisAnalytics/DeleteApplicationInputProcessingConfiguration.hs +171/−0
• gen/Network/AWS/KinesisAnalytics/DeleteApplicationOutput.hs +27/−25
• gen/Network/AWS/KinesisAnalytics/DeleteApplicationReferenceDataSource.hs +34/−26
• gen/Network/AWS/KinesisAnalytics/DescribeApplication.hs +25/−23
• gen/Network/AWS/KinesisAnalytics/DiscoverInputSchema.hs +82/−55
• gen/Network/AWS/KinesisAnalytics/ListApplications.hs +29/−27
• gen/Network/AWS/KinesisAnalytics/StartApplication.hs +23/−23
• gen/Network/AWS/KinesisAnalytics/StopApplication.hs +21/−21
• gen/Network/AWS/KinesisAnalytics/Types.hs +128/−36
• gen/Network/AWS/KinesisAnalytics/Types/Product.hs +2795/−2223
• gen/Network/AWS/KinesisAnalytics/Types/Sum.hs +20/−17
• gen/Network/AWS/KinesisAnalytics/UpdateApplication.hs +32/−30
• gen/Network/AWS/KinesisAnalytics/Waiters.hs +6/−6
• test/Main.hs +2/−2
• test/Test/AWS/Gen/KinesisAnalytics.hs +76/−4

@@ -8,7 +8,7 @@  ## Version -`1.4.5`+`1.5.0`   ## Description

@@ -1,13 +1,13 @@ name:                  amazonka-kinesis-analytics-version:               1.4.5+version:               1.5.0 synopsis:              Amazon Kinesis Analytics SDK. homepage:              https://github.com/brendanhay/amazonka bug-reports:           https://github.com/brendanhay/amazonka/issues-license:               OtherLicense+license:               MPL-2.0 license-file:          LICENSE author:                Brendan Hay-maintainer:            Brendan Hay <brendan.g.hay@gmail.com>-copyright:             Copyright (c) 2013-2016 Brendan Hay+maintainer:            Brendan Hay <brendan.g.hay+amazonka@gmail.com>+copyright:             Copyright (c) 2013-2017 Brendan Hay category:              Network, AWS, Cloud, Distributed Computing build-type:            Simple cabal-version:         >= 1.10@@ -29,22 +29,31 @@     to get started.  source-repository head-    type:     git-    location: git://github.com/brendanhay/amazonka.git+    type:              git+    location:          git://github.com/brendanhay/amazonka.git+    subdir:            amazonka-kinesis-analytics  library     default-language:  Haskell2010     hs-source-dirs:    src gen -    ghc-options:       -Wall+    ghc-options:+        -Wall+        -fwarn-incomplete-uni-patterns+        -fwarn-incomplete-record-updates+        -funbox-strict-fields      exposed-modules:           Network.AWS.KinesisAnalytics+        , Network.AWS.KinesisAnalytics.AddApplicationCloudWatchLoggingOption         , Network.AWS.KinesisAnalytics.AddApplicationInput+        , Network.AWS.KinesisAnalytics.AddApplicationInputProcessingConfiguration         , Network.AWS.KinesisAnalytics.AddApplicationOutput         , Network.AWS.KinesisAnalytics.AddApplicationReferenceDataSource         , Network.AWS.KinesisAnalytics.CreateApplication         , Network.AWS.KinesisAnalytics.DeleteApplication+        , Network.AWS.KinesisAnalytics.DeleteApplicationCloudWatchLoggingOption+        , Network.AWS.KinesisAnalytics.DeleteApplicationInputProcessingConfiguration         , Network.AWS.KinesisAnalytics.DeleteApplicationOutput         , Network.AWS.KinesisAnalytics.DeleteApplicationReferenceDataSource         , Network.AWS.KinesisAnalytics.DescribeApplication@@ -61,7 +70,7 @@         , Network.AWS.KinesisAnalytics.Types.Sum      build-depends:-          amazonka-core == 1.4.5.*+          amazonka-core == 1.5.0.*         , base          >= 4.7     && < 5  test-suite amazonka-kinesis-analytics-test@@ -81,9 +90,9 @@         , Test.AWS.KinesisAnalytics.Internal      build-depends:-          amazonka-core == 1.4.5.*-        , amazonka-test == 1.4.5.*-        , amazonka-kinesis-analytics == 1.4.5.*+          amazonka-core == 1.5.0.*+        , amazonka-test == 1.5.0.*+        , amazonka-kinesis-analytics         , base         , bytestring         , tasty

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesisanalytics/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesisanalytics.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesisanalytics/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesisanalytics.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesisanalytics/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesisanalytics.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesisanalytics/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesisanalytics.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -5,9 +5,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -38,6 +38,9 @@     -- ** ConcurrentModificationException     , _ConcurrentModificationException +    -- ** ServiceUnavailableException+    , _ServiceUnavailableException+     -- ** UnableToDetectSchemaException     , _UnableToDetectSchemaException @@ -77,6 +80,12 @@     -- ** UpdateApplication     , module Network.AWS.KinesisAnalytics.UpdateApplication +    -- ** DeleteApplicationCloudWatchLoggingOption+    , module Network.AWS.KinesisAnalytics.DeleteApplicationCloudWatchLoggingOption++    -- ** AddApplicationInputProcessingConfiguration+    , module Network.AWS.KinesisAnalytics.AddApplicationInputProcessingConfiguration+     -- ** CreateApplication     , module Network.AWS.KinesisAnalytics.CreateApplication @@ -92,9 +101,15 @@     -- ** 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@@ -111,6 +126,7 @@     , applicationDetail     , adApplicationDescription     , adOutputDescriptions+    , adCloudWatchLoggingOptionDescriptions     , adReferenceDataSourceDescriptions     , adInputDescriptions     , adApplicationCode@@ -133,6 +149,7 @@     , applicationUpdate     , auReferenceDataSourceUpdates     , auInputUpdates+    , auCloudWatchLoggingOptionUpdates     , auOutputUpdates     , auApplicationCodeUpdate @@ -142,6 +159,26 @@     , cmpRecordRowDelimiter     , cmpRecordColumnDelimiter +    -- ** CloudWatchLoggingOption+    , CloudWatchLoggingOption+    , cloudWatchLoggingOption+    , cwloLogStreamARN+    , cwloRoleARN++    -- ** CloudWatchLoggingOptionDescription+    , CloudWatchLoggingOptionDescription+    , cloudWatchLoggingOptionDescription+    , cwlodCloudWatchLoggingOptionId+    , cwlodLogStreamARN+    , cwlodRoleARN++    -- ** CloudWatchLoggingOptionUpdate+    , CloudWatchLoggingOptionUpdate+    , cloudWatchLoggingOptionUpdate+    , cwlouRoleARNUpdate+    , cwlouLogStreamARNUpdate+    , cwlouCloudWatchLoggingOptionId+     -- ** DestinationSchema     , DestinationSchema     , destinationSchema@@ -151,6 +188,7 @@     , Input     , input     , iInputParallelism+    , iInputProcessingConfiguration     , iKinesisStreamsInput     , iKinesisFirehoseInput     , iNamePrefix@@ -173,7 +211,26 @@     , idInputSchema     , idKinesisStreamsInputDescription     , idNamePrefix+    , idInputProcessingConfigurationDescription +    -- ** InputLambdaProcessor+    , InputLambdaProcessor+    , inputLambdaProcessor+    , ilpResourceARN+    , ilpRoleARN++    -- ** InputLambdaProcessorDescription+    , InputLambdaProcessorDescription+    , inputLambdaProcessorDescription+    , ilpdResourceARN+    , ilpdRoleARN++    -- ** InputLambdaProcessorUpdate+    , InputLambdaProcessorUpdate+    , inputLambdaProcessorUpdate+    , ilpuRoleARNUpdate+    , ilpuResourceARNUpdate+     -- ** InputParallelism     , InputParallelism     , inputParallelism@@ -184,6 +241,21 @@     , inputParallelismUpdate     , ipuCountUpdate +    -- ** InputProcessingConfiguration+    , InputProcessingConfiguration+    , inputProcessingConfiguration+    , ipcInputLambdaProcessor++    -- ** InputProcessingConfigurationDescription+    , InputProcessingConfigurationDescription+    , inputProcessingConfigurationDescription+    , ipcdInputLambdaProcessorDescription++    -- ** InputProcessingConfigurationUpdate+    , InputProcessingConfigurationUpdate+    , inputProcessingConfigurationUpdate+    , ipcuInputLambdaProcessorUpdate+     -- ** InputSchemaUpdate     , InputSchemaUpdate     , inputSchemaUpdate@@ -199,6 +271,7 @@     -- ** InputUpdate     , InputUpdate     , inputUpdate+    , iuInputProcessingConfigurationUpdate     , iuKinesisStreamsInputUpdate     , iuInputParallelismUpdate     , iuNamePrefixUpdate@@ -351,6 +424,13 @@     , rdsuReferenceSchemaUpdate     , rdsuReferenceId +    -- ** S3Configuration+    , S3Configuration+    , s3Configuration+    , scRoleARN+    , scBucketARN+    , scFileKey+     -- ** S3ReferenceDataSource     , S3ReferenceDataSource     , s3ReferenceDataSource@@ -380,21 +460,25 @@     , ssRecordColumns     ) where -import           Network.AWS.KinesisAnalytics.AddApplicationInput-import           Network.AWS.KinesisAnalytics.AddApplicationOutput-import           Network.AWS.KinesisAnalytics.AddApplicationReferenceDataSource-import           Network.AWS.KinesisAnalytics.CreateApplication-import           Network.AWS.KinesisAnalytics.DeleteApplication-import           Network.AWS.KinesisAnalytics.DeleteApplicationOutput-import           Network.AWS.KinesisAnalytics.DeleteApplicationReferenceDataSource-import           Network.AWS.KinesisAnalytics.DescribeApplication-import           Network.AWS.KinesisAnalytics.DiscoverInputSchema-import           Network.AWS.KinesisAnalytics.ListApplications-import           Network.AWS.KinesisAnalytics.StartApplication-import           Network.AWS.KinesisAnalytics.StopApplication-import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.UpdateApplication-import           Network.AWS.KinesisAnalytics.Waiters+import Network.AWS.KinesisAnalytics.AddApplicationCloudWatchLoggingOption+import Network.AWS.KinesisAnalytics.AddApplicationInput+import Network.AWS.KinesisAnalytics.AddApplicationInputProcessingConfiguration+import Network.AWS.KinesisAnalytics.AddApplicationOutput+import Network.AWS.KinesisAnalytics.AddApplicationReferenceDataSource+import Network.AWS.KinesisAnalytics.CreateApplication+import Network.AWS.KinesisAnalytics.DeleteApplication+import Network.AWS.KinesisAnalytics.DeleteApplicationCloudWatchLoggingOption+import Network.AWS.KinesisAnalytics.DeleteApplicationInputProcessingConfiguration+import Network.AWS.KinesisAnalytics.DeleteApplicationOutput+import Network.AWS.KinesisAnalytics.DeleteApplicationReferenceDataSource+import Network.AWS.KinesisAnalytics.DescribeApplication+import Network.AWS.KinesisAnalytics.DiscoverInputSchema+import Network.AWS.KinesisAnalytics.ListApplications+import Network.AWS.KinesisAnalytics.StartApplication+import Network.AWS.KinesisAnalytics.StopApplication+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.UpdateApplication+import Network.AWS.KinesisAnalytics.Waiters  {- $errors Error matchers are designed for use with the functions provided by

@@ -0,0 +1,168 @@+{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE DeriveGeneric      #-}+{-# LANGUAGE OverloadedStrings  #-}+{-# LANGUAGE RecordWildCards    #-}+{-# LANGUAGE TypeFamilies       #-}++{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-binds   #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Network.AWS.KinesisAnalytics.AddApplicationCloudWatchLoggingOption+-- Copyright   : (c) 2013-2017 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com>+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Adds a CloudWatch log stream to monitor application configuration errors. For more information about using CloudWatch log streams with Amazon Kinesis Analytics applications, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/cloudwatch-logs.html Working with Amazon CloudWatch Logs> .+--+--+module Network.AWS.KinesisAnalytics.AddApplicationCloudWatchLoggingOption+    (+    -- * Creating a Request+      addApplicationCloudWatchLoggingOption+    , AddApplicationCloudWatchLoggingOption+    -- * Request Lenses+    , aacwloApplicationName+    , aacwloCurrentApplicationVersionId+    , aacwloCloudWatchLoggingOption++    -- * Destructuring the Response+    , addApplicationCloudWatchLoggingOptionResponse+    , AddApplicationCloudWatchLoggingOptionResponse+    -- * Response Lenses+    , aacwlorsResponseStatus+    ) where++import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response++-- | /See:/ 'addApplicationCloudWatchLoggingOption' smart constructor.+data AddApplicationCloudWatchLoggingOption = AddApplicationCloudWatchLoggingOption'+  { _aacwloApplicationName             :: !Text+  , _aacwloCurrentApplicationVersionId :: !Nat+  , _aacwloCloudWatchLoggingOption     :: !CloudWatchLoggingOption+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'AddApplicationCloudWatchLoggingOption' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'aacwloApplicationName' - The Kinesis Analytics application name.+--+-- * 'aacwloCurrentApplicationVersionId' - The version ID of the Kinesis Analytics application.+--+-- * 'aacwloCloudWatchLoggingOption' - Provides the CloudWatch log stream Amazon Resource Name (ARN) and the IAM role ARN. Note: To write application messages to CloudWatch, the IAM role that is used must have the @PutLogEvents@ policy action enabled.+addApplicationCloudWatchLoggingOption+    :: Text -- ^ 'aacwloApplicationName'+    -> Natural -- ^ 'aacwloCurrentApplicationVersionId'+    -> CloudWatchLoggingOption -- ^ 'aacwloCloudWatchLoggingOption'+    -> AddApplicationCloudWatchLoggingOption+addApplicationCloudWatchLoggingOption pApplicationName_ pCurrentApplicationVersionId_ pCloudWatchLoggingOption_ =+  AddApplicationCloudWatchLoggingOption'+  { _aacwloApplicationName = pApplicationName_+  , _aacwloCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _aacwloCloudWatchLoggingOption = pCloudWatchLoggingOption_+  }+++-- | The Kinesis Analytics application name.+aacwloApplicationName :: Lens' AddApplicationCloudWatchLoggingOption Text+aacwloApplicationName = lens _aacwloApplicationName (\ s a -> s{_aacwloApplicationName = a});++-- | The version ID of the Kinesis Analytics application.+aacwloCurrentApplicationVersionId :: Lens' AddApplicationCloudWatchLoggingOption Natural+aacwloCurrentApplicationVersionId = lens _aacwloCurrentApplicationVersionId (\ s a -> s{_aacwloCurrentApplicationVersionId = a}) . _Nat;++-- | Provides the CloudWatch log stream Amazon Resource Name (ARN) and the IAM role ARN. Note: To write application messages to CloudWatch, the IAM role that is used must have the @PutLogEvents@ policy action enabled.+aacwloCloudWatchLoggingOption :: Lens' AddApplicationCloudWatchLoggingOption CloudWatchLoggingOption+aacwloCloudWatchLoggingOption = lens _aacwloCloudWatchLoggingOption (\ s a -> s{_aacwloCloudWatchLoggingOption = a});++instance AWSRequest+           AddApplicationCloudWatchLoggingOption+         where+        type Rs AddApplicationCloudWatchLoggingOption =+             AddApplicationCloudWatchLoggingOptionResponse+        request = postJSON kinesisAnalytics+        response+          = receiveEmpty+              (\ s h x ->+                 AddApplicationCloudWatchLoggingOptionResponse' <$>+                   (pure (fromEnum s)))++instance Hashable+           AddApplicationCloudWatchLoggingOption+         where++instance NFData AddApplicationCloudWatchLoggingOption+         where++instance ToHeaders+           AddApplicationCloudWatchLoggingOption+         where+        toHeaders+          = const+              (mconcat+                 ["X-Amz-Target" =#+                    ("KinesisAnalytics_20150814.AddApplicationCloudWatchLoggingOption"+                       :: ByteString),+                  "Content-Type" =#+                    ("application/x-amz-json-1.1" :: ByteString)])++instance ToJSON AddApplicationCloudWatchLoggingOption+         where+        toJSON AddApplicationCloudWatchLoggingOption'{..}+          = object+              (catMaybes+                 [Just ("ApplicationName" .= _aacwloApplicationName),+                  Just+                    ("CurrentApplicationVersionId" .=+                       _aacwloCurrentApplicationVersionId),+                  Just+                    ("CloudWatchLoggingOption" .=+                       _aacwloCloudWatchLoggingOption)])++instance ToPath AddApplicationCloudWatchLoggingOption+         where+        toPath = const "/"++instance ToQuery+           AddApplicationCloudWatchLoggingOption+         where+        toQuery = const mempty++-- | /See:/ 'addApplicationCloudWatchLoggingOptionResponse' smart constructor.+newtype AddApplicationCloudWatchLoggingOptionResponse = AddApplicationCloudWatchLoggingOptionResponse'+  { _aacwlorsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'AddApplicationCloudWatchLoggingOptionResponse' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'aacwlorsResponseStatus' - -- | The response status code.+addApplicationCloudWatchLoggingOptionResponse+    :: Int -- ^ 'aacwlorsResponseStatus'+    -> AddApplicationCloudWatchLoggingOptionResponse+addApplicationCloudWatchLoggingOptionResponse pResponseStatus_ =+  AddApplicationCloudWatchLoggingOptionResponse'+  {_aacwlorsResponseStatus = pResponseStatus_}+++-- | -- | The response status code.+aacwlorsResponseStatus :: Lens' AddApplicationCloudWatchLoggingOptionResponse Int+aacwlorsResponseStatus = lens _aacwlorsResponseStatus (\ s a -> s{_aacwlorsResponseStatus = a});++instance NFData+           AddApplicationCloudWatchLoggingOptionResponse+         where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.AddApplicationInput--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -44,12 +44,12 @@     , aairsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -57,11 +57,12 @@ -- -- /See:/ 'addApplicationInput' smart constructor. data AddApplicationInput = AddApplicationInput'-    { _aaiApplicationName             :: !Text-    , _aaiCurrentApplicationVersionId :: !Nat-    , _aaiInput                       :: !Input-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _aaiApplicationName             :: !Text+  , _aaiCurrentApplicationVersionId :: !Nat+  , _aaiInput                       :: !Input+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'AddApplicationInput' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -70,19 +71,20 @@ -- -- * 'aaiCurrentApplicationVersionId' - Current version of your Amazon Kinesis Analytics application. You can use the 'DescribeApplication' operation to find the current application version. ----- * 'aaiInput' - Undocumented member.+-- * 'aaiInput' - The 'Input' to add. addApplicationInput     :: Text -- ^ 'aaiApplicationName'     -> Natural -- ^ 'aaiCurrentApplicationVersionId'     -> Input -- ^ 'aaiInput'     -> AddApplicationInput addApplicationInput pApplicationName_ pCurrentApplicationVersionId_ pInput_ =-    AddApplicationInput'-    { _aaiApplicationName = pApplicationName_-    , _aaiCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_-    , _aaiInput = pInput_-    }+  AddApplicationInput'+  { _aaiApplicationName = pApplicationName_+  , _aaiCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _aaiInput = pInput_+  } + -- | Name of your existing Amazon Kinesis Analytics application to which you want to add the streaming source. aaiApplicationName :: Lens' AddApplicationInput Text aaiApplicationName = lens _aaiApplicationName (\ s a -> s{_aaiApplicationName = a});@@ -91,7 +93,7 @@ aaiCurrentApplicationVersionId :: Lens' AddApplicationInput Natural aaiCurrentApplicationVersionId = lens _aaiCurrentApplicationVersionId (\ s a -> s{_aaiCurrentApplicationVersionId = a}) . _Nat; --- | Undocumented member.+-- | The 'Input' to add. aaiInput :: Lens' AddApplicationInput Input aaiInput = lens _aaiInput (\ s a -> s{_aaiInput = a}); @@ -104,9 +106,9 @@               (\ s h x ->                  AddApplicationInputResponse' <$> (pure (fromEnum s))) -instance Hashable AddApplicationInput+instance Hashable AddApplicationInput where -instance NFData AddApplicationInput+instance NFData AddApplicationInput where  instance ToHeaders AddApplicationInput where         toHeaders@@ -140,9 +142,10 @@ -- -- /See:/ 'addApplicationInputResponse' smart constructor. newtype AddApplicationInputResponse = AddApplicationInputResponse'-    { _aairsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _aairsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'AddApplicationInputResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -152,12 +155,11 @@     :: Int -- ^ 'aairsResponseStatus'     -> AddApplicationInputResponse addApplicationInputResponse pResponseStatus_ =-    AddApplicationInputResponse'-    { _aairsResponseStatus = pResponseStatus_-    }+  AddApplicationInputResponse' {_aairsResponseStatus = pResponseStatus_} + -- | -- | The response status code. aairsResponseStatus :: Lens' AddApplicationInputResponse Int aairsResponseStatus = lens _aairsResponseStatus (\ s a -> s{_aairsResponseStatus = a}); -instance NFData AddApplicationInputResponse+instance NFData AddApplicationInputResponse where

@@ -0,0 +1,183 @@+{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE DeriveGeneric      #-}+{-# LANGUAGE OverloadedStrings  #-}+{-# LANGUAGE RecordWildCards    #-}+{-# LANGUAGE TypeFamilies       #-}++{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-binds   #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Network.AWS.KinesisAnalytics.AddApplicationInputProcessingConfiguration+-- Copyright   : (c) 2013-2017 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com>+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Adds an 'InputProcessingConfiguration' to an application. An input processor preprocesses records on the input stream before the application's SQL code executes. Currently, the only input processor available is <https://aws.amazon.com/documentation/lambda/ AWS Lambda> .+--+--+module Network.AWS.KinesisAnalytics.AddApplicationInputProcessingConfiguration+    (+    -- * Creating a Request+      addApplicationInputProcessingConfiguration+    , AddApplicationInputProcessingConfiguration+    -- * Request Lenses+    , aaipcApplicationName+    , aaipcCurrentApplicationVersionId+    , aaipcInputId+    , aaipcInputProcessingConfiguration++    -- * Destructuring the Response+    , addApplicationInputProcessingConfigurationResponse+    , AddApplicationInputProcessingConfigurationResponse+    -- * Response Lenses+    , aaipcrsResponseStatus+    ) where++import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response++-- | /See:/ 'addApplicationInputProcessingConfiguration' smart constructor.+data AddApplicationInputProcessingConfiguration = AddApplicationInputProcessingConfiguration'+  { _aaipcApplicationName              :: !Text+  , _aaipcCurrentApplicationVersionId  :: !Nat+  , _aaipcInputId                      :: !Text+  , _aaipcInputProcessingConfiguration :: !InputProcessingConfiguration+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'AddApplicationInputProcessingConfiguration' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'aaipcApplicationName' - Name of the application to which you want to add the input processing configuration.+--+-- * 'aaipcCurrentApplicationVersionId' - Version of the application to which you want to add the input processing configuration. You can use the 'DescribeApplication' operation to get the current application version. If the version specified is not the current version, the @ConcurrentModificationException@ is returned.+--+-- * 'aaipcInputId' - The ID of the input configuration to which to add the input configuration. You can get a list of the input IDs for an application using the 'DescribeApplication' operation.+--+-- * 'aaipcInputProcessingConfiguration' - The 'InputProcessingConfiguration' to add to the application.+addApplicationInputProcessingConfiguration+    :: Text -- ^ 'aaipcApplicationName'+    -> Natural -- ^ 'aaipcCurrentApplicationVersionId'+    -> Text -- ^ 'aaipcInputId'+    -> InputProcessingConfiguration -- ^ 'aaipcInputProcessingConfiguration'+    -> AddApplicationInputProcessingConfiguration+addApplicationInputProcessingConfiguration pApplicationName_ pCurrentApplicationVersionId_ pInputId_ pInputProcessingConfiguration_ =+  AddApplicationInputProcessingConfiguration'+  { _aaipcApplicationName = pApplicationName_+  , _aaipcCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _aaipcInputId = pInputId_+  , _aaipcInputProcessingConfiguration = pInputProcessingConfiguration_+  }+++-- | Name of the application to which you want to add the input processing configuration.+aaipcApplicationName :: Lens' AddApplicationInputProcessingConfiguration Text+aaipcApplicationName = lens _aaipcApplicationName (\ s a -> s{_aaipcApplicationName = a});++-- | Version of the application to which you want to add the input processing configuration. You can use the 'DescribeApplication' operation to get the current application version. If the version specified is not the current version, the @ConcurrentModificationException@ is returned.+aaipcCurrentApplicationVersionId :: Lens' AddApplicationInputProcessingConfiguration Natural+aaipcCurrentApplicationVersionId = lens _aaipcCurrentApplicationVersionId (\ s a -> s{_aaipcCurrentApplicationVersionId = a}) . _Nat;++-- | The ID of the input configuration to which to add the input configuration. You can get a list of the input IDs for an application using the 'DescribeApplication' operation.+aaipcInputId :: Lens' AddApplicationInputProcessingConfiguration Text+aaipcInputId = lens _aaipcInputId (\ s a -> s{_aaipcInputId = a});++-- | The 'InputProcessingConfiguration' to add to the application.+aaipcInputProcessingConfiguration :: Lens' AddApplicationInputProcessingConfiguration InputProcessingConfiguration+aaipcInputProcessingConfiguration = lens _aaipcInputProcessingConfiguration (\ s a -> s{_aaipcInputProcessingConfiguration = a});++instance AWSRequest+           AddApplicationInputProcessingConfiguration+         where+        type Rs AddApplicationInputProcessingConfiguration =+             AddApplicationInputProcessingConfigurationResponse+        request = postJSON kinesisAnalytics+        response+          = receiveEmpty+              (\ s h x ->+                 AddApplicationInputProcessingConfigurationResponse'+                   <$> (pure (fromEnum s)))++instance Hashable+           AddApplicationInputProcessingConfiguration+         where++instance NFData+           AddApplicationInputProcessingConfiguration+         where++instance ToHeaders+           AddApplicationInputProcessingConfiguration+         where+        toHeaders+          = const+              (mconcat+                 ["X-Amz-Target" =#+                    ("KinesisAnalytics_20150814.AddApplicationInputProcessingConfiguration"+                       :: ByteString),+                  "Content-Type" =#+                    ("application/x-amz-json-1.1" :: ByteString)])++instance ToJSON+           AddApplicationInputProcessingConfiguration+         where+        toJSON+          AddApplicationInputProcessingConfiguration'{..}+          = object+              (catMaybes+                 [Just ("ApplicationName" .= _aaipcApplicationName),+                  Just+                    ("CurrentApplicationVersionId" .=+                       _aaipcCurrentApplicationVersionId),+                  Just ("InputId" .= _aaipcInputId),+                  Just+                    ("InputProcessingConfiguration" .=+                       _aaipcInputProcessingConfiguration)])++instance ToPath+           AddApplicationInputProcessingConfiguration+         where+        toPath = const "/"++instance ToQuery+           AddApplicationInputProcessingConfiguration+         where+        toQuery = const mempty++-- | /See:/ 'addApplicationInputProcessingConfigurationResponse' smart constructor.+newtype AddApplicationInputProcessingConfigurationResponse = AddApplicationInputProcessingConfigurationResponse'+  { _aaipcrsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'AddApplicationInputProcessingConfigurationResponse' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'aaipcrsResponseStatus' - -- | The response status code.+addApplicationInputProcessingConfigurationResponse+    :: Int -- ^ 'aaipcrsResponseStatus'+    -> AddApplicationInputProcessingConfigurationResponse+addApplicationInputProcessingConfigurationResponse pResponseStatus_ =+  AddApplicationInputProcessingConfigurationResponse'+  {_aaipcrsResponseStatus = pResponseStatus_}+++-- | -- | The response status code.+aaipcrsResponseStatus :: Lens' AddApplicationInputProcessingConfigurationResponse Int+aaipcrsResponseStatus = lens _aaipcrsResponseStatus (\ s a -> s{_aaipcrsResponseStatus = a});++instance NFData+           AddApplicationInputProcessingConfigurationResponse+         where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.AddApplicationOutput--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -48,12 +48,12 @@     , aaorsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -61,11 +61,12 @@ -- -- /See:/ 'addApplicationOutput' smart constructor. data AddApplicationOutput = AddApplicationOutput'-    { _aaoApplicationName             :: !Text-    , _aaoCurrentApplicationVersionId :: !Nat-    , _aaoOutput                      :: !Output-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _aaoApplicationName             :: !Text+  , _aaoCurrentApplicationVersionId :: !Nat+  , _aaoOutput                      :: !Output+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'AddApplicationOutput' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -81,12 +82,13 @@     -> Output -- ^ 'aaoOutput'     -> AddApplicationOutput addApplicationOutput pApplicationName_ pCurrentApplicationVersionId_ pOutput_ =-    AddApplicationOutput'-    { _aaoApplicationName = pApplicationName_-    , _aaoCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_-    , _aaoOutput = pOutput_-    }+  AddApplicationOutput'+  { _aaoApplicationName = pApplicationName_+  , _aaoCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _aaoOutput = pOutput_+  } + -- | Name of the application to which you want to add the output configuration. aaoApplicationName :: Lens' AddApplicationOutput Text aaoApplicationName = lens _aaoApplicationName (\ s a -> s{_aaoApplicationName = a});@@ -109,9 +111,9 @@                  AddApplicationOutputResponse' <$>                    (pure (fromEnum s))) -instance Hashable AddApplicationOutput+instance Hashable AddApplicationOutput where -instance NFData AddApplicationOutput+instance NFData AddApplicationOutput where  instance ToHeaders AddApplicationOutput where         toHeaders@@ -145,9 +147,10 @@ -- -- /See:/ 'addApplicationOutputResponse' smart constructor. newtype AddApplicationOutputResponse = AddApplicationOutputResponse'-    { _aaorsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _aaorsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'AddApplicationOutputResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -157,12 +160,11 @@     :: Int -- ^ 'aaorsResponseStatus'     -> AddApplicationOutputResponse addApplicationOutputResponse pResponseStatus_ =-    AddApplicationOutputResponse'-    { _aaorsResponseStatus = pResponseStatus_-    }+  AddApplicationOutputResponse' {_aaorsResponseStatus = pResponseStatus_} + -- | -- | The response status code. aaorsResponseStatus :: Lens' AddApplicationOutputResponse Int aaorsResponseStatus = lens _aaorsResponseStatus (\ s a -> s{_aaorsResponseStatus = a}); -instance NFData AddApplicationOutputResponse+instance NFData AddApplicationOutputResponse where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.AddApplicationReferenceDataSource--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -44,12 +44,12 @@     , aardsrsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -57,11 +57,12 @@ -- -- /See:/ 'addApplicationReferenceDataSource' smart constructor. data AddApplicationReferenceDataSource = AddApplicationReferenceDataSource'-    { _aardsApplicationName             :: !Text-    , _aardsCurrentApplicationVersionId :: !Nat-    , _aardsReferenceDataSource         :: !ReferenceDataSource-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _aardsApplicationName             :: !Text+  , _aardsCurrentApplicationVersionId :: !Nat+  , _aardsReferenceDataSource         :: !ReferenceDataSource+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'AddApplicationReferenceDataSource' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -77,12 +78,13 @@     -> ReferenceDataSource -- ^ 'aardsReferenceDataSource'     -> AddApplicationReferenceDataSource addApplicationReferenceDataSource pApplicationName_ pCurrentApplicationVersionId_ pReferenceDataSource_ =-    AddApplicationReferenceDataSource'-    { _aardsApplicationName = pApplicationName_-    , _aardsCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_-    , _aardsReferenceDataSource = pReferenceDataSource_-    }+  AddApplicationReferenceDataSource'+  { _aardsApplicationName = pApplicationName_+  , _aardsCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _aardsReferenceDataSource = pReferenceDataSource_+  } + -- | Name of an existing application. aardsApplicationName :: Lens' AddApplicationReferenceDataSource Text aardsApplicationName = lens _aardsApplicationName (\ s a -> s{_aardsApplicationName = a});@@ -107,8 +109,10 @@                    (pure (fromEnum s)))  instance Hashable AddApplicationReferenceDataSource+         where  instance NFData AddApplicationReferenceDataSource+         where  instance ToHeaders AddApplicationReferenceDataSource          where@@ -148,9 +152,10 @@ -- -- /See:/ 'addApplicationReferenceDataSourceResponse' smart constructor. newtype AddApplicationReferenceDataSourceResponse = AddApplicationReferenceDataSourceResponse'-    { _aardsrsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _aardsrsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'AddApplicationReferenceDataSourceResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -160,13 +165,14 @@     :: Int -- ^ 'aardsrsResponseStatus'     -> AddApplicationReferenceDataSourceResponse addApplicationReferenceDataSourceResponse pResponseStatus_ =-    AddApplicationReferenceDataSourceResponse'-    { _aardsrsResponseStatus = pResponseStatus_-    }+  AddApplicationReferenceDataSourceResponse'+  {_aardsrsResponseStatus = pResponseStatus_} + -- | -- | The response status code. aardsrsResponseStatus :: Lens' AddApplicationReferenceDataSourceResponse Int aardsrsResponseStatus = lens _aardsrsResponseStatus (\ s a -> s{_aardsrsResponseStatus = a});  instance NFData-         AddApplicationReferenceDataSourceResponse+           AddApplicationReferenceDataSourceResponse+         where

@@ -12,16 +12,16 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.CreateApplication--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) -- -- Creates an Amazon Kinesis Analytics application. You can configure each application with one streaming source as input, application code to process the input, and up to five streaming destinations where you want Amazon Kinesis Analytics to write the output data from your application. For an overview, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works.html How it Works> . -- ----- In the input configuration, you map the streaming source to an in-application stream, which you can think of as a constantly updating table. In the mapping, you must provide a schema for the in-application stream and map each data column in the in-application stream to a data element in the streaming source, with the option of renaming, casting and dropping columns as desired.+-- In the input configuration, you map the streaming source to an in-application stream, which you can think of as a constantly updating table. In the mapping, you must provide a schema for the in-application stream and map each data column in the in-application stream to a data element in the streaming source. -- -- Your application code is one or more SQL statements that read input data, transform it, and generate output. Your application code can create one or more SQL artifacts like SQL streams or pumps. --@@ -39,6 +39,7 @@     -- * Request Lenses     , caApplicationDescription     , caInputs+    , caCloudWatchLoggingOptions     , caOutputs     , caApplicationCode     , caApplicationName@@ -51,12 +52,12 @@     , carsApplicationSummary     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | TBD --@@ -64,13 +65,15 @@ -- -- /See:/ 'createApplication' smart constructor. data CreateApplication = CreateApplication'-    { _caApplicationDescription :: !(Maybe Text)-    , _caInputs                 :: !(Maybe [Input])-    , _caOutputs                :: !(Maybe [Output])-    , _caApplicationCode        :: !(Maybe Text)-    , _caApplicationName        :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _caApplicationDescription   :: !(Maybe Text)+  , _caInputs                   :: !(Maybe [Input])+  , _caCloudWatchLoggingOptions :: !(Maybe [CloudWatchLoggingOption])+  , _caOutputs                  :: !(Maybe [Output])+  , _caApplicationCode          :: !(Maybe Text)+  , _caApplicationName          :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'CreateApplication' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -79,23 +82,27 @@ -- -- * 'caInputs' - Use this parameter to configure the application input. You can configure your application to receive input from a single streaming source. In this configuration, you map this streaming source to an in-application stream that is created. Your application code can then query the in-application stream like a table (you can think of it as a constantly updating table). For the streaming source, you provide its Amazon Resource Name (ARN) and format of data on the stream (for example, JSON, CSV, etc). You also must provide an IAM role that Amazon Kinesis Analytics can assume to read this stream on your behalf. To create the in-application stream, you need to specify a schema to transform your data into a schematized version used in SQL. In the schema, you provide the necessary mapping of the data elements in the streaming source to record columns in the in-app stream. --+-- * 'caCloudWatchLoggingOptions' - Use this parameter to configure a CloudWatch log stream to monitor application configuration errors. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/cloudwatch-logs.html Working with Amazon CloudWatch Logs> .+-- -- * 'caOutputs' - You can configure application output to write data from any of the in-application streams to up to five destinations. These destinations can be Amazon Kinesis streams, Amazon Kinesis Firehose delivery streams, or both. In the configuration, you specify the in-application stream name, the destination stream Amazon Resource Name (ARN), and the format to use when writing data. You must also provide an IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. In the output configuration, you also provide the output stream Amazon Resource Name (ARN) and the format of data in the stream (for example, JSON, CSV). You also must provide an IAM role that Amazon Kinesis Analytics can assume to write to this stream on your behalf. ----- * 'caApplicationCode' - One or more SQL statements that read input data, transform it, and generate output. For example, you can write a SQL statement that reads input data and generates a running average of the number of advertisement clicks by vendor. You can also provide a series of SQL statements, where output of one statement can be used as the input for the next statement. Note that the application code must create the streams with names specified in the @Outputs@ . For example, if your @Outputs@ defines output streams named @ExampleOutputStream1@ and @ExampleOutputStream2@ , then your application code must create these streams.+-- * 'caApplicationCode' - One or more SQL statements that read input data, transform it, and generate output. For example, you can write a SQL statement that reads data from one in-application stream, generates a running average of the number of advertisement clicks by vendor, and insert resulting rows in another in-application stream using pumps. For more inforamtion about the typical pattern, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-app-code.html Application Code> .  You can provide such series of SQL statements, where output of one statement can be used as the input for the next statement. You store intermediate results by creating in-application streams and pumps. Note that the application code must create the streams with names specified in the @Outputs@ . For example, if your @Outputs@ defines output streams named @ExampleOutputStream1@ and @ExampleOutputStream2@ , then your application code must create these streams. -- -- * 'caApplicationName' - Name of your Amazon Kinesis Analytics application (for example, @sample-app@ ). createApplication     :: Text -- ^ 'caApplicationName'     -> CreateApplication createApplication pApplicationName_ =-    CreateApplication'-    { _caApplicationDescription = Nothing-    , _caInputs = Nothing-    , _caOutputs = Nothing-    , _caApplicationCode = Nothing-    , _caApplicationName = pApplicationName_-    }+  CreateApplication'+  { _caApplicationDescription = Nothing+  , _caInputs = Nothing+  , _caCloudWatchLoggingOptions = Nothing+  , _caOutputs = Nothing+  , _caApplicationCode = Nothing+  , _caApplicationName = pApplicationName_+  } + -- | Summary description of the application. caApplicationDescription :: Lens' CreateApplication (Maybe Text) caApplicationDescription = lens _caApplicationDescription (\ s a -> s{_caApplicationDescription = a});@@ -104,11 +111,15 @@ caInputs :: Lens' CreateApplication [Input] caInputs = lens _caInputs (\ s a -> s{_caInputs = a}) . _Default . _Coerce; +-- | Use this parameter to configure a CloudWatch log stream to monitor application configuration errors. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/cloudwatch-logs.html Working with Amazon CloudWatch Logs> .+caCloudWatchLoggingOptions :: Lens' CreateApplication [CloudWatchLoggingOption]+caCloudWatchLoggingOptions = lens _caCloudWatchLoggingOptions (\ s a -> s{_caCloudWatchLoggingOptions = a}) . _Default . _Coerce;+ -- | You can configure application output to write data from any of the in-application streams to up to five destinations. These destinations can be Amazon Kinesis streams, Amazon Kinesis Firehose delivery streams, or both. In the configuration, you specify the in-application stream name, the destination stream Amazon Resource Name (ARN), and the format to use when writing data. You must also provide an IAM role that Amazon Kinesis Analytics can assume to write to the destination stream on your behalf. In the output configuration, you also provide the output stream Amazon Resource Name (ARN) and the format of data in the stream (for example, JSON, CSV). You also must provide an IAM role that Amazon Kinesis Analytics can assume to write to this stream on your behalf. caOutputs :: Lens' CreateApplication [Output] caOutputs = lens _caOutputs (\ s a -> s{_caOutputs = a}) . _Default . _Coerce; --- | One or more SQL statements that read input data, transform it, and generate output. For example, you can write a SQL statement that reads input data and generates a running average of the number of advertisement clicks by vendor. You can also provide a series of SQL statements, where output of one statement can be used as the input for the next statement. Note that the application code must create the streams with names specified in the @Outputs@ . For example, if your @Outputs@ defines output streams named @ExampleOutputStream1@ and @ExampleOutputStream2@ , then your application code must create these streams.+-- | One or more SQL statements that read input data, transform it, and generate output. For example, you can write a SQL statement that reads data from one in-application stream, generates a running average of the number of advertisement clicks by vendor, and insert resulting rows in another in-application stream using pumps. For more inforamtion about the typical pattern, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-app-code.html Application Code> .  You can provide such series of SQL statements, where output of one statement can be used as the input for the next statement. You store intermediate results by creating in-application streams and pumps. Note that the application code must create the streams with names specified in the @Outputs@ . For example, if your @Outputs@ defines output streams named @ExampleOutputStream1@ and @ExampleOutputStream2@ , then your application code must create these streams. caApplicationCode :: Lens' CreateApplication (Maybe Text) caApplicationCode = lens _caApplicationCode (\ s a -> s{_caApplicationCode = a}); @@ -125,9 +136,9 @@                  CreateApplicationResponse' <$>                    (pure (fromEnum s)) <*> (x .:> "ApplicationSummary")) -instance Hashable CreateApplication+instance Hashable CreateApplication where -instance NFData CreateApplication+instance NFData CreateApplication where  instance ToHeaders CreateApplication where         toHeaders@@ -146,6 +157,8 @@                  [("ApplicationDescription" .=) <$>                     _caApplicationDescription,                   ("Inputs" .=) <$> _caInputs,+                  ("CloudWatchLoggingOptions" .=) <$>+                    _caCloudWatchLoggingOptions,                   ("Outputs" .=) <$> _caOutputs,                   ("ApplicationCode" .=) <$> _caApplicationCode,                   Just ("ApplicationName" .= _caApplicationName)])@@ -162,10 +175,11 @@ -- -- /See:/ 'createApplicationResponse' smart constructor. data CreateApplicationResponse = CreateApplicationResponse'-    { _carsResponseStatus     :: !Int-    , _carsApplicationSummary :: !ApplicationSummary-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _carsResponseStatus     :: !Int+  , _carsApplicationSummary :: !ApplicationSummary+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'CreateApplicationResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -178,11 +192,12 @@     -> ApplicationSummary -- ^ 'carsApplicationSummary'     -> CreateApplicationResponse createApplicationResponse pResponseStatus_ pApplicationSummary_ =-    CreateApplicationResponse'-    { _carsResponseStatus = pResponseStatus_-    , _carsApplicationSummary = pApplicationSummary_-    }+  CreateApplicationResponse'+  { _carsResponseStatus = pResponseStatus_+  , _carsApplicationSummary = pApplicationSummary_+  } + -- | -- | The response status code. carsResponseStatus :: Lens' CreateApplicationResponse Int carsResponseStatus = lens _carsResponseStatus (\ s a -> s{_carsResponseStatus = a});@@ -191,4 +206,4 @@ carsApplicationSummary :: Lens' CreateApplicationResponse ApplicationSummary carsApplicationSummary = lens _carsApplicationSummary (\ s a -> s{_carsApplicationSummary = a}); -instance NFData CreateApplicationResponse+instance NFData CreateApplicationResponse where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.DeleteApplication--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -39,12 +39,12 @@     , drsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -52,10 +52,11 @@ -- -- /See:/ 'deleteApplication' smart constructor. data DeleteApplication = DeleteApplication'-    { _dApplicationName :: !Text-    , _dCreateTimestamp :: !POSIX-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _dApplicationName :: !Text+  , _dCreateTimestamp :: !POSIX+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DeleteApplication' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -68,11 +69,12 @@     -> UTCTime -- ^ 'dCreateTimestamp'     -> DeleteApplication deleteApplication pApplicationName_ pCreateTimestamp_ =-    DeleteApplication'-    { _dApplicationName = pApplicationName_-    , _dCreateTimestamp = _Time # pCreateTimestamp_-    }+  DeleteApplication'+  { _dApplicationName = pApplicationName_+  , _dCreateTimestamp = _Time # pCreateTimestamp_+  } + -- | Name of the Amazon Kinesis Analytics application to delete. dApplicationName :: Lens' DeleteApplication Text dApplicationName = lens _dApplicationName (\ s a -> s{_dApplicationName = a});@@ -89,9 +91,9 @@               (\ s h x ->                  DeleteApplicationResponse' <$> (pure (fromEnum s))) -instance Hashable DeleteApplication+instance Hashable DeleteApplication where -instance NFData DeleteApplication+instance NFData DeleteApplication where  instance ToHeaders DeleteApplication where         toHeaders@@ -122,9 +124,10 @@ -- -- /See:/ 'deleteApplicationResponse' smart constructor. newtype DeleteApplicationResponse = DeleteApplicationResponse'-    { _drsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _drsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DeleteApplicationResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -134,12 +137,11 @@     :: Int -- ^ 'drsResponseStatus'     -> DeleteApplicationResponse deleteApplicationResponse pResponseStatus_ =-    DeleteApplicationResponse'-    { _drsResponseStatus = pResponseStatus_-    }+  DeleteApplicationResponse' {_drsResponseStatus = pResponseStatus_} + -- | -- | The response status code. drsResponseStatus :: Lens' DeleteApplicationResponse Int drsResponseStatus = lens _drsResponseStatus (\ s a -> s{_drsResponseStatus = a}); -instance NFData DeleteApplicationResponse+instance NFData DeleteApplicationResponse where

@@ -0,0 +1,171 @@+{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE DeriveGeneric      #-}+{-# LANGUAGE OverloadedStrings  #-}+{-# LANGUAGE RecordWildCards    #-}+{-# LANGUAGE TypeFamilies       #-}++{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-binds   #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Network.AWS.KinesisAnalytics.DeleteApplicationCloudWatchLoggingOption+-- Copyright   : (c) 2013-2017 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com>+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Deletes a CloudWatch log stream from an application. For more information about using CloudWatch log streams with Amazon Kinesis Analytics applications, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/cloudwatch-logs.html Working with Amazon CloudWatch Logs> .+--+--+module Network.AWS.KinesisAnalytics.DeleteApplicationCloudWatchLoggingOption+    (+    -- * Creating a Request+      deleteApplicationCloudWatchLoggingOption+    , DeleteApplicationCloudWatchLoggingOption+    -- * Request Lenses+    , dacwloApplicationName+    , dacwloCurrentApplicationVersionId+    , dacwloCloudWatchLoggingOptionId++    -- * Destructuring the Response+    , deleteApplicationCloudWatchLoggingOptionResponse+    , DeleteApplicationCloudWatchLoggingOptionResponse+    -- * Response Lenses+    , dacwlorsResponseStatus+    ) where++import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response++-- | /See:/ 'deleteApplicationCloudWatchLoggingOption' smart constructor.+data DeleteApplicationCloudWatchLoggingOption = DeleteApplicationCloudWatchLoggingOption'+  { _dacwloApplicationName             :: !Text+  , _dacwloCurrentApplicationVersionId :: !Nat+  , _dacwloCloudWatchLoggingOptionId   :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'DeleteApplicationCloudWatchLoggingOption' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'dacwloApplicationName' - The Kinesis Analytics application name.+--+-- * 'dacwloCurrentApplicationVersionId' - The version ID of the Kinesis Analytics application.+--+-- * 'dacwloCloudWatchLoggingOptionId' - The @CloudWatchLoggingOptionId@ of the CloudWatch logging option to delete. You can use the 'DescribeApplication' operation to get the @CloudWatchLoggingOptionId@ .+deleteApplicationCloudWatchLoggingOption+    :: Text -- ^ 'dacwloApplicationName'+    -> Natural -- ^ 'dacwloCurrentApplicationVersionId'+    -> Text -- ^ 'dacwloCloudWatchLoggingOptionId'+    -> DeleteApplicationCloudWatchLoggingOption+deleteApplicationCloudWatchLoggingOption pApplicationName_ pCurrentApplicationVersionId_ pCloudWatchLoggingOptionId_ =+  DeleteApplicationCloudWatchLoggingOption'+  { _dacwloApplicationName = pApplicationName_+  , _dacwloCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _dacwloCloudWatchLoggingOptionId = pCloudWatchLoggingOptionId_+  }+++-- | The Kinesis Analytics application name.+dacwloApplicationName :: Lens' DeleteApplicationCloudWatchLoggingOption Text+dacwloApplicationName = lens _dacwloApplicationName (\ s a -> s{_dacwloApplicationName = a});++-- | The version ID of the Kinesis Analytics application.+dacwloCurrentApplicationVersionId :: Lens' DeleteApplicationCloudWatchLoggingOption Natural+dacwloCurrentApplicationVersionId = lens _dacwloCurrentApplicationVersionId (\ s a -> s{_dacwloCurrentApplicationVersionId = a}) . _Nat;++-- | The @CloudWatchLoggingOptionId@ of the CloudWatch logging option to delete. You can use the 'DescribeApplication' operation to get the @CloudWatchLoggingOptionId@ .+dacwloCloudWatchLoggingOptionId :: Lens' DeleteApplicationCloudWatchLoggingOption Text+dacwloCloudWatchLoggingOptionId = lens _dacwloCloudWatchLoggingOptionId (\ s a -> s{_dacwloCloudWatchLoggingOptionId = a});++instance AWSRequest+           DeleteApplicationCloudWatchLoggingOption+         where+        type Rs DeleteApplicationCloudWatchLoggingOption =+             DeleteApplicationCloudWatchLoggingOptionResponse+        request = postJSON kinesisAnalytics+        response+          = receiveEmpty+              (\ s h x ->+                 DeleteApplicationCloudWatchLoggingOptionResponse' <$>+                   (pure (fromEnum s)))++instance Hashable+           DeleteApplicationCloudWatchLoggingOption+         where++instance NFData+           DeleteApplicationCloudWatchLoggingOption+         where++instance ToHeaders+           DeleteApplicationCloudWatchLoggingOption+         where+        toHeaders+          = const+              (mconcat+                 ["X-Amz-Target" =#+                    ("KinesisAnalytics_20150814.DeleteApplicationCloudWatchLoggingOption"+                       :: ByteString),+                  "Content-Type" =#+                    ("application/x-amz-json-1.1" :: ByteString)])++instance ToJSON+           DeleteApplicationCloudWatchLoggingOption+         where+        toJSON DeleteApplicationCloudWatchLoggingOption'{..}+          = object+              (catMaybes+                 [Just ("ApplicationName" .= _dacwloApplicationName),+                  Just+                    ("CurrentApplicationVersionId" .=+                       _dacwloCurrentApplicationVersionId),+                  Just+                    ("CloudWatchLoggingOptionId" .=+                       _dacwloCloudWatchLoggingOptionId)])++instance ToPath+           DeleteApplicationCloudWatchLoggingOption+         where+        toPath = const "/"++instance ToQuery+           DeleteApplicationCloudWatchLoggingOption+         where+        toQuery = const mempty++-- | /See:/ 'deleteApplicationCloudWatchLoggingOptionResponse' smart constructor.+newtype DeleteApplicationCloudWatchLoggingOptionResponse = DeleteApplicationCloudWatchLoggingOptionResponse'+  { _dacwlorsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'DeleteApplicationCloudWatchLoggingOptionResponse' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'dacwlorsResponseStatus' - -- | The response status code.+deleteApplicationCloudWatchLoggingOptionResponse+    :: Int -- ^ 'dacwlorsResponseStatus'+    -> DeleteApplicationCloudWatchLoggingOptionResponse+deleteApplicationCloudWatchLoggingOptionResponse pResponseStatus_ =+  DeleteApplicationCloudWatchLoggingOptionResponse'+  {_dacwlorsResponseStatus = pResponseStatus_}+++-- | -- | The response status code.+dacwlorsResponseStatus :: Lens' DeleteApplicationCloudWatchLoggingOptionResponse Int+dacwlorsResponseStatus = lens _dacwlorsResponseStatus (\ s a -> s{_dacwlorsResponseStatus = a});++instance NFData+           DeleteApplicationCloudWatchLoggingOptionResponse+         where

@@ -0,0 +1,171 @@+{-# LANGUAGE DeriveDataTypeable #-}+{-# LANGUAGE DeriveGeneric      #-}+{-# LANGUAGE OverloadedStrings  #-}+{-# LANGUAGE RecordWildCards    #-}+{-# LANGUAGE TypeFamilies       #-}++{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-binds   #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Network.AWS.KinesisAnalytics.DeleteApplicationInputProcessingConfiguration+-- Copyright   : (c) 2013-2017 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com>+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Deletes an 'InputProcessingConfiguration' from an input.+--+--+module Network.AWS.KinesisAnalytics.DeleteApplicationInputProcessingConfiguration+    (+    -- * Creating a Request+      deleteApplicationInputProcessingConfiguration+    , DeleteApplicationInputProcessingConfiguration+    -- * Request Lenses+    , daipcApplicationName+    , daipcCurrentApplicationVersionId+    , daipcInputId++    -- * Destructuring the Response+    , deleteApplicationInputProcessingConfigurationResponse+    , DeleteApplicationInputProcessingConfigurationResponse+    -- * Response Lenses+    , daipcrsResponseStatus+    ) where++import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response++-- | /See:/ 'deleteApplicationInputProcessingConfiguration' smart constructor.+data DeleteApplicationInputProcessingConfiguration = DeleteApplicationInputProcessingConfiguration'+  { _daipcApplicationName             :: !Text+  , _daipcCurrentApplicationVersionId :: !Nat+  , _daipcInputId                     :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'DeleteApplicationInputProcessingConfiguration' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'daipcApplicationName' - The Kinesis Analytics application name.+--+-- * 'daipcCurrentApplicationVersionId' - The version ID of the Kinesis Analytics application.+--+-- * 'daipcInputId' - The ID of the input configuration from which to delete the input configuration. You can get a list of the input IDs for an application using the 'DescribeApplication' operation.+deleteApplicationInputProcessingConfiguration+    :: Text -- ^ 'daipcApplicationName'+    -> Natural -- ^ 'daipcCurrentApplicationVersionId'+    -> Text -- ^ 'daipcInputId'+    -> DeleteApplicationInputProcessingConfiguration+deleteApplicationInputProcessingConfiguration pApplicationName_ pCurrentApplicationVersionId_ pInputId_ =+  DeleteApplicationInputProcessingConfiguration'+  { _daipcApplicationName = pApplicationName_+  , _daipcCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _daipcInputId = pInputId_+  }+++-- | The Kinesis Analytics application name.+daipcApplicationName :: Lens' DeleteApplicationInputProcessingConfiguration Text+daipcApplicationName = lens _daipcApplicationName (\ s a -> s{_daipcApplicationName = a});++-- | The version ID of the Kinesis Analytics application.+daipcCurrentApplicationVersionId :: Lens' DeleteApplicationInputProcessingConfiguration Natural+daipcCurrentApplicationVersionId = lens _daipcCurrentApplicationVersionId (\ s a -> s{_daipcCurrentApplicationVersionId = a}) . _Nat;++-- | The ID of the input configuration from which to delete the input configuration. You can get a list of the input IDs for an application using the 'DescribeApplication' operation.+daipcInputId :: Lens' DeleteApplicationInputProcessingConfiguration Text+daipcInputId = lens _daipcInputId (\ s a -> s{_daipcInputId = a});++instance AWSRequest+           DeleteApplicationInputProcessingConfiguration+         where+        type Rs DeleteApplicationInputProcessingConfiguration+             =+             DeleteApplicationInputProcessingConfigurationResponse+        request = postJSON kinesisAnalytics+        response+          = receiveEmpty+              (\ s h x ->+                 DeleteApplicationInputProcessingConfigurationResponse'+                   <$> (pure (fromEnum s)))++instance Hashable+           DeleteApplicationInputProcessingConfiguration+         where++instance NFData+           DeleteApplicationInputProcessingConfiguration+         where++instance ToHeaders+           DeleteApplicationInputProcessingConfiguration+         where+        toHeaders+          = const+              (mconcat+                 ["X-Amz-Target" =#+                    ("KinesisAnalytics_20150814.DeleteApplicationInputProcessingConfiguration"+                       :: ByteString),+                  "Content-Type" =#+                    ("application/x-amz-json-1.1" :: ByteString)])++instance ToJSON+           DeleteApplicationInputProcessingConfiguration+         where+        toJSON+          DeleteApplicationInputProcessingConfiguration'{..}+          = object+              (catMaybes+                 [Just ("ApplicationName" .= _daipcApplicationName),+                  Just+                    ("CurrentApplicationVersionId" .=+                       _daipcCurrentApplicationVersionId),+                  Just ("InputId" .= _daipcInputId)])++instance ToPath+           DeleteApplicationInputProcessingConfiguration+         where+        toPath = const "/"++instance ToQuery+           DeleteApplicationInputProcessingConfiguration+         where+        toQuery = const mempty++-- | /See:/ 'deleteApplicationInputProcessingConfigurationResponse' smart constructor.+newtype DeleteApplicationInputProcessingConfigurationResponse = DeleteApplicationInputProcessingConfigurationResponse'+  { _daipcrsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | Creates a value of 'DeleteApplicationInputProcessingConfigurationResponse' with the minimum fields required to make a request.+--+-- Use one of the following lenses to modify other fields as desired:+--+-- * 'daipcrsResponseStatus' - -- | The response status code.+deleteApplicationInputProcessingConfigurationResponse+    :: Int -- ^ 'daipcrsResponseStatus'+    -> DeleteApplicationInputProcessingConfigurationResponse+deleteApplicationInputProcessingConfigurationResponse pResponseStatus_ =+  DeleteApplicationInputProcessingConfigurationResponse'+  {_daipcrsResponseStatus = pResponseStatus_}+++-- | -- | The response status code.+daipcrsResponseStatus :: Lens' DeleteApplicationInputProcessingConfigurationResponse Int+daipcrsResponseStatus = lens _daipcrsResponseStatus (\ s a -> s{_daipcrsResponseStatus = a});++instance NFData+           DeleteApplicationInputProcessingConfigurationResponse+         where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.DeleteApplicationOutput--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -40,12 +40,12 @@     , daorsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -53,11 +53,12 @@ -- -- /See:/ 'deleteApplicationOutput' smart constructor. data DeleteApplicationOutput = DeleteApplicationOutput'-    { _daoApplicationName             :: !Text-    , _daoCurrentApplicationVersionId :: !Nat-    , _daoOutputId                    :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _daoApplicationName             :: !Text+  , _daoCurrentApplicationVersionId :: !Nat+  , _daoOutputId                    :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DeleteApplicationOutput' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -73,12 +74,13 @@     -> Text -- ^ 'daoOutputId'     -> DeleteApplicationOutput deleteApplicationOutput pApplicationName_ pCurrentApplicationVersionId_ pOutputId_ =-    DeleteApplicationOutput'-    { _daoApplicationName = pApplicationName_-    , _daoCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_-    , _daoOutputId = pOutputId_-    }+  DeleteApplicationOutput'+  { _daoApplicationName = pApplicationName_+  , _daoCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _daoOutputId = pOutputId_+  } + -- | Amazon Kinesis Analytics application name. daoApplicationName :: Lens' DeleteApplicationOutput Text daoApplicationName = lens _daoApplicationName (\ s a -> s{_daoApplicationName = a});@@ -101,9 +103,9 @@                  DeleteApplicationOutputResponse' <$>                    (pure (fromEnum s))) -instance Hashable DeleteApplicationOutput+instance Hashable DeleteApplicationOutput where -instance NFData DeleteApplicationOutput+instance NFData DeleteApplicationOutput where  instance ToHeaders DeleteApplicationOutput where         toHeaders@@ -137,9 +139,10 @@ -- -- /See:/ 'deleteApplicationOutputResponse' smart constructor. newtype DeleteApplicationOutputResponse = DeleteApplicationOutputResponse'-    { _daorsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _daorsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DeleteApplicationOutputResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -149,12 +152,11 @@     :: Int -- ^ 'daorsResponseStatus'     -> DeleteApplicationOutputResponse deleteApplicationOutputResponse pResponseStatus_ =-    DeleteApplicationOutputResponse'-    { _daorsResponseStatus = pResponseStatus_-    }+  DeleteApplicationOutputResponse' {_daorsResponseStatus = pResponseStatus_} + -- | -- | The response status code. daorsResponseStatus :: Lens' DeleteApplicationOutputResponse Int daorsResponseStatus = lens _daorsResponseStatus (\ s a -> s{_daorsResponseStatus = a}); -instance NFData DeleteApplicationOutputResponse+instance NFData DeleteApplicationOutputResponse where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.DeleteApplicationReferenceDataSource--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -42,20 +42,21 @@     , dardsrsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | /See:/ 'deleteApplicationReferenceDataSource' smart constructor. data DeleteApplicationReferenceDataSource = DeleteApplicationReferenceDataSource'-    { _dardsApplicationName             :: !Text-    , _dardsCurrentApplicationVersionId :: !Nat-    , _dardsReferenceId                 :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _dardsApplicationName             :: !Text+  , _dardsCurrentApplicationVersionId :: !Nat+  , _dardsReferenceId                 :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DeleteApplicationReferenceDataSource' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -71,12 +72,13 @@     -> Text -- ^ 'dardsReferenceId'     -> DeleteApplicationReferenceDataSource deleteApplicationReferenceDataSource pApplicationName_ pCurrentApplicationVersionId_ pReferenceId_ =-    DeleteApplicationReferenceDataSource'-    { _dardsApplicationName = pApplicationName_-    , _dardsCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_-    , _dardsReferenceId = pReferenceId_-    }+  DeleteApplicationReferenceDataSource'+  { _dardsApplicationName = pApplicationName_+  , _dardsCurrentApplicationVersionId = _Nat # pCurrentApplicationVersionId_+  , _dardsReferenceId = pReferenceId_+  } + -- | Name of an existing application. dardsApplicationName :: Lens' DeleteApplicationReferenceDataSource Text dardsApplicationName = lens _dardsApplicationName (\ s a -> s{_dardsApplicationName = a});@@ -90,7 +92,8 @@ dardsReferenceId = lens _dardsReferenceId (\ s a -> s{_dardsReferenceId = a});  instance AWSRequest-         DeleteApplicationReferenceDataSource where+           DeleteApplicationReferenceDataSource+         where         type Rs DeleteApplicationReferenceDataSource =              DeleteApplicationReferenceDataSourceResponse         request = postJSON kinesisAnalytics@@ -101,12 +104,15 @@                    (pure (fromEnum s)))  instance Hashable-         DeleteApplicationReferenceDataSource+           DeleteApplicationReferenceDataSource+         where  instance NFData DeleteApplicationReferenceDataSource+         where  instance ToHeaders-         DeleteApplicationReferenceDataSource where+           DeleteApplicationReferenceDataSource+         where         toHeaders           = const               (mconcat@@ -137,9 +143,10 @@  -- | /See:/ 'deleteApplicationReferenceDataSourceResponse' smart constructor. newtype DeleteApplicationReferenceDataSourceResponse = DeleteApplicationReferenceDataSourceResponse'-    { _dardsrsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _dardsrsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DeleteApplicationReferenceDataSourceResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -149,13 +156,14 @@     :: Int -- ^ 'dardsrsResponseStatus'     -> DeleteApplicationReferenceDataSourceResponse deleteApplicationReferenceDataSourceResponse pResponseStatus_ =-    DeleteApplicationReferenceDataSourceResponse'-    { _dardsrsResponseStatus = pResponseStatus_-    }+  DeleteApplicationReferenceDataSourceResponse'+  {_dardsrsResponseStatus = pResponseStatus_} + -- | -- | The response status code. dardsrsResponseStatus :: Lens' DeleteApplicationReferenceDataSourceResponse Int dardsrsResponseStatus = lens _dardsrsResponseStatus (\ s a -> s{_dardsrsResponseStatus = a});  instance NFData-         DeleteApplicationReferenceDataSourceResponse+           DeleteApplicationReferenceDataSourceResponse+         where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.DescribeApplication--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -41,12 +41,12 @@     , darsApplicationDetail     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -54,9 +54,10 @@ -- -- /See:/ 'describeApplication' smart constructor. newtype DescribeApplication = DescribeApplication'-    { _daApplicationName :: Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _daApplicationName :: Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DescribeApplication' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -66,10 +67,9 @@     :: Text -- ^ 'daApplicationName'     -> DescribeApplication describeApplication pApplicationName_ =-    DescribeApplication'-    { _daApplicationName = pApplicationName_-    }+  DescribeApplication' {_daApplicationName = pApplicationName_} + -- | Name of the application. daApplicationName :: Lens' DescribeApplication Text daApplicationName = lens _daApplicationName (\ s a -> s{_daApplicationName = a});@@ -84,9 +84,9 @@                  DescribeApplicationResponse' <$>                    (pure (fromEnum s)) <*> (x .:> "ApplicationDetail")) -instance Hashable DescribeApplication+instance Hashable DescribeApplication where -instance NFData DescribeApplication+instance NFData DescribeApplication where  instance ToHeaders DescribeApplication where         toHeaders@@ -116,10 +116,11 @@ -- -- /See:/ 'describeApplicationResponse' smart constructor. data DescribeApplicationResponse = DescribeApplicationResponse'-    { _darsResponseStatus    :: !Int-    , _darsApplicationDetail :: !ApplicationDetail-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _darsResponseStatus    :: !Int+  , _darsApplicationDetail :: !ApplicationDetail+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DescribeApplicationResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -132,11 +133,12 @@     -> ApplicationDetail -- ^ 'darsApplicationDetail'     -> DescribeApplicationResponse describeApplicationResponse pResponseStatus_ pApplicationDetail_ =-    DescribeApplicationResponse'-    { _darsResponseStatus = pResponseStatus_-    , _darsApplicationDetail = pApplicationDetail_-    }+  DescribeApplicationResponse'+  { _darsResponseStatus = pResponseStatus_+  , _darsApplicationDetail = pApplicationDetail_+  } + -- | -- | The response status code. darsResponseStatus :: Lens' DescribeApplicationResponse Int darsResponseStatus = lens _darsResponseStatus (\ s a -> s{_darsResponseStatus = a});@@ -145,4 +147,4 @@ darsApplicationDetail :: Lens' DescribeApplicationResponse ApplicationDetail darsApplicationDetail = lens _darsApplicationDetail (\ s a -> s{_darsApplicationDetail = a}); -instance NFData DescribeApplicationResponse+instance NFData DescribeApplicationResponse where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.DiscoverInputSchema--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -31,9 +31,11 @@       discoverInputSchema     , DiscoverInputSchema     -- * Request Lenses+    , disInputStartingPositionConfiguration+    , disInputProcessingConfiguration+    , disS3Configuration     , disResourceARN     , disRoleARN-    , disInputStartingPositionConfiguration      -- * Destructuring the Response     , discoverInputSchemaResponse@@ -41,61 +43,73 @@     -- * Response Lenses     , disrsRawInputRecords     , disrsInputSchema+    , disrsProcessedInputRecords     , disrsParsedInputRecords     , disrsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response --- |------------ /See:/ 'discoverInputSchema' smart constructor.+-- | /See:/ 'discoverInputSchema' smart constructor. data DiscoverInputSchema = DiscoverInputSchema'-    { _disResourceARN                        :: !Text-    , _disRoleARN                            :: !Text-    , _disInputStartingPositionConfiguration :: !InputStartingPositionConfiguration-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _disInputStartingPositionConfiguration :: !(Maybe InputStartingPositionConfiguration)+  , _disInputProcessingConfiguration :: !(Maybe InputProcessingConfiguration)+  , _disS3Configuration :: !(Maybe S3Configuration)+  , _disResourceARN :: !(Maybe Text)+  , _disRoleARN :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DiscoverInputSchema' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired: --+-- * 'disInputStartingPositionConfiguration' - Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes.+--+-- * 'disInputProcessingConfiguration' - The 'InputProcessingConfiguration' to use to preprocess the records before discovering the schema of the records.+--+-- * 'disS3Configuration' - Undocumented member.+-- -- * 'disResourceARN' - Amazon Resource Name (ARN) of the streaming source. -- -- * 'disRoleARN' - ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.------ * 'disInputStartingPositionConfiguration' - Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes. discoverInputSchema-    :: Text -- ^ 'disResourceARN'-    -> Text -- ^ 'disRoleARN'-    -> InputStartingPositionConfiguration -- ^ 'disInputStartingPositionConfiguration'-    -> DiscoverInputSchema-discoverInputSchema pResourceARN_ pRoleARN_ pInputStartingPositionConfiguration_ =-    DiscoverInputSchema'-    { _disResourceARN = pResourceARN_-    , _disRoleARN = pRoleARN_-    , _disInputStartingPositionConfiguration = pInputStartingPositionConfiguration_-    }+    :: DiscoverInputSchema+discoverInputSchema =+  DiscoverInputSchema'+  { _disInputStartingPositionConfiguration = Nothing+  , _disInputProcessingConfiguration = Nothing+  , _disS3Configuration = Nothing+  , _disResourceARN = Nothing+  , _disRoleARN = Nothing+  } ++-- | Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes.+disInputStartingPositionConfiguration :: Lens' DiscoverInputSchema (Maybe InputStartingPositionConfiguration)+disInputStartingPositionConfiguration = lens _disInputStartingPositionConfiguration (\ s a -> s{_disInputStartingPositionConfiguration = a});++-- | The 'InputProcessingConfiguration' to use to preprocess the records before discovering the schema of the records.+disInputProcessingConfiguration :: Lens' DiscoverInputSchema (Maybe InputProcessingConfiguration)+disInputProcessingConfiguration = lens _disInputProcessingConfiguration (\ s a -> s{_disInputProcessingConfiguration = a});++-- | Undocumented member.+disS3Configuration :: Lens' DiscoverInputSchema (Maybe S3Configuration)+disS3Configuration = lens _disS3Configuration (\ s a -> s{_disS3Configuration = a});+ -- | Amazon Resource Name (ARN) of the streaming source.-disResourceARN :: Lens' DiscoverInputSchema Text+disResourceARN :: Lens' DiscoverInputSchema (Maybe Text) disResourceARN = lens _disResourceARN (\ s a -> s{_disResourceARN = a});  -- | ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.-disRoleARN :: Lens' DiscoverInputSchema Text+disRoleARN :: Lens' DiscoverInputSchema (Maybe Text) disRoleARN = lens _disRoleARN (\ s a -> s{_disRoleARN = a}); --- | Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes.-disInputStartingPositionConfiguration :: Lens' DiscoverInputSchema InputStartingPositionConfiguration-disInputStartingPositionConfiguration = lens _disInputStartingPositionConfiguration (\ s a -> s{_disInputStartingPositionConfiguration = a});- instance AWSRequest DiscoverInputSchema where         type Rs DiscoverInputSchema =              DiscoverInputSchemaResponse@@ -106,12 +120,13 @@                  DiscoverInputSchemaResponse' <$>                    (x .?> "RawInputRecords" .!@ mempty) <*>                      (x .?> "InputSchema")+                     <*> (x .?> "ProcessedInputRecords" .!@ mempty)                      <*> (x .?> "ParsedInputRecords" .!@ mempty)                      <*> (pure (fromEnum s))) -instance Hashable DiscoverInputSchema+instance Hashable DiscoverInputSchema where -instance NFData DiscoverInputSchema+instance NFData DiscoverInputSchema where  instance ToHeaders DiscoverInputSchema where         toHeaders@@ -127,11 +142,13 @@         toJSON DiscoverInputSchema'{..}           = object               (catMaybes-                 [Just ("ResourceARN" .= _disResourceARN),-                  Just ("RoleARN" .= _disRoleARN),-                  Just-                    ("InputStartingPositionConfiguration" .=-                       _disInputStartingPositionConfiguration)])+                 [("InputStartingPositionConfiguration" .=) <$>+                    _disInputStartingPositionConfiguration,+                  ("InputProcessingConfiguration" .=) <$>+                    _disInputProcessingConfiguration,+                  ("S3Configuration" .=) <$> _disS3Configuration,+                  ("ResourceARN" .=) <$> _disResourceARN,+                  ("RoleARN" .=) <$> _disRoleARN])  instance ToPath DiscoverInputSchema where         toPath = const "/"@@ -145,12 +162,14 @@ -- -- /See:/ 'discoverInputSchemaResponse' smart constructor. data DiscoverInputSchemaResponse = DiscoverInputSchemaResponse'-    { _disrsRawInputRecords    :: !(Maybe [Text])-    , _disrsInputSchema        :: !(Maybe SourceSchema)-    , _disrsParsedInputRecords :: !(Maybe [[Text]])-    , _disrsResponseStatus     :: !Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _disrsRawInputRecords       :: !(Maybe [Text])+  , _disrsInputSchema           :: !(Maybe SourceSchema)+  , _disrsProcessedInputRecords :: !(Maybe [Text])+  , _disrsParsedInputRecords    :: !(Maybe [[Text]])+  , _disrsResponseStatus        :: !Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'DiscoverInputSchemaResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -159,6 +178,8 @@ -- -- * 'disrsInputSchema' - Schema inferred from the streaming source. It identifies the format of the data in the streaming source and how each data element maps to corresponding columns in the in-application stream that you can create. --+-- * 'disrsProcessedInputRecords' - Stream data that was modified by the processor specified in the @InputProcessingConfiguration@ parameter.+-- -- * 'disrsParsedInputRecords' - An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row). -- -- * 'disrsResponseStatus' - -- | The response status code.@@ -166,13 +187,15 @@     :: Int -- ^ 'disrsResponseStatus'     -> DiscoverInputSchemaResponse discoverInputSchemaResponse pResponseStatus_ =-    DiscoverInputSchemaResponse'-    { _disrsRawInputRecords = Nothing-    , _disrsInputSchema = Nothing-    , _disrsParsedInputRecords = Nothing-    , _disrsResponseStatus = pResponseStatus_-    }+  DiscoverInputSchemaResponse'+  { _disrsRawInputRecords = Nothing+  , _disrsInputSchema = Nothing+  , _disrsProcessedInputRecords = Nothing+  , _disrsParsedInputRecords = Nothing+  , _disrsResponseStatus = pResponseStatus_+  } + -- | Raw stream data that was sampled to infer the schema. disrsRawInputRecords :: Lens' DiscoverInputSchemaResponse [Text] disrsRawInputRecords = lens _disrsRawInputRecords (\ s a -> s{_disrsRawInputRecords = a}) . _Default . _Coerce;@@ -181,6 +204,10 @@ disrsInputSchema :: Lens' DiscoverInputSchemaResponse (Maybe SourceSchema) disrsInputSchema = lens _disrsInputSchema (\ s a -> s{_disrsInputSchema = a}); +-- | Stream data that was modified by the processor specified in the @InputProcessingConfiguration@ parameter.+disrsProcessedInputRecords :: Lens' DiscoverInputSchemaResponse [Text]+disrsProcessedInputRecords = lens _disrsProcessedInputRecords (\ s a -> s{_disrsProcessedInputRecords = a}) . _Default . _Coerce;+ -- | An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row). disrsParsedInputRecords :: Lens' DiscoverInputSchemaResponse [[Text]] disrsParsedInputRecords = lens _disrsParsedInputRecords (\ s a -> s{_disrsParsedInputRecords = a}) . _Default . _Coerce;@@ -189,4 +216,4 @@ disrsResponseStatus :: Lens' DiscoverInputSchemaResponse Int disrsResponseStatus = lens _disrsResponseStatus (\ s a -> s{_disrsResponseStatus = a}); -instance NFData DiscoverInputSchemaResponse+instance NFData DiscoverInputSchemaResponse where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.ListApplications--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -43,12 +43,12 @@     , larsHasMoreApplications     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -56,10 +56,11 @@ -- -- /See:/ 'listApplications' smart constructor. data ListApplications = ListApplications'-    { _laLimit                         :: !(Maybe Nat)-    , _laExclusiveStartApplicationName :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _laLimit                         :: !(Maybe Nat)+  , _laExclusiveStartApplicationName :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'ListApplications' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -70,11 +71,10 @@ listApplications     :: ListApplications listApplications =-    ListApplications'-    { _laLimit = Nothing-    , _laExclusiveStartApplicationName = Nothing-    }+  ListApplications'+  {_laLimit = Nothing, _laExclusiveStartApplicationName = Nothing} + -- | Maximum number of applications to list. laLimit :: Lens' ListApplications (Maybe Natural) laLimit = lens _laLimit (\ s a -> s{_laLimit = a}) . mapping _Nat;@@ -94,9 +94,9 @@                      (x .?> "ApplicationSummaries" .!@ mempty)                      <*> (x .:> "HasMoreApplications")) -instance Hashable ListApplications+instance Hashable ListApplications where -instance NFData ListApplications+instance NFData ListApplications where  instance ToHeaders ListApplications where         toHeaders@@ -128,11 +128,12 @@ -- -- /See:/ 'listApplicationsResponse' smart constructor. data ListApplicationsResponse = ListApplicationsResponse'-    { _larsResponseStatus       :: !Int-    , _larsApplicationSummaries :: ![ApplicationSummary]-    , _larsHasMoreApplications  :: !Bool-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _larsResponseStatus       :: !Int+  , _larsApplicationSummaries :: ![ApplicationSummary]+  , _larsHasMoreApplications  :: !Bool+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'ListApplicationsResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -147,12 +148,13 @@     -> Bool -- ^ 'larsHasMoreApplications'     -> ListApplicationsResponse listApplicationsResponse pResponseStatus_ pHasMoreApplications_ =-    ListApplicationsResponse'-    { _larsResponseStatus = pResponseStatus_-    , _larsApplicationSummaries = mempty-    , _larsHasMoreApplications = pHasMoreApplications_-    }+  ListApplicationsResponse'+  { _larsResponseStatus = pResponseStatus_+  , _larsApplicationSummaries = mempty+  , _larsHasMoreApplications = pHasMoreApplications_+  } + -- | -- | The response status code. larsResponseStatus :: Lens' ListApplicationsResponse Int larsResponseStatus = lens _larsResponseStatus (\ s a -> s{_larsResponseStatus = a});@@ -165,4 +167,4 @@ larsHasMoreApplications :: Lens' ListApplicationsResponse Bool larsHasMoreApplications = lens _larsHasMoreApplications (\ s a -> s{_larsHasMoreApplications = a}); -instance NFData ListApplicationsResponse+instance NFData ListApplicationsResponse where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.StartApplication--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -45,12 +45,12 @@     , sarsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -58,10 +58,11 @@ -- -- /See:/ 'startApplication' smart constructor. data StartApplication = StartApplication'-    { _saApplicationName     :: !Text-    , _saInputConfigurations :: ![InputConfiguration]-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _saApplicationName     :: !Text+  , _saInputConfigurations :: ![InputConfiguration]+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'StartApplication' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -73,11 +74,10 @@     :: Text -- ^ 'saApplicationName'     -> StartApplication startApplication pApplicationName_ =-    StartApplication'-    { _saApplicationName = pApplicationName_-    , _saInputConfigurations = mempty-    }+  StartApplication'+  {_saApplicationName = pApplicationName_, _saInputConfigurations = mempty} + -- | Name of the application. saApplicationName :: Lens' StartApplication Text saApplicationName = lens _saApplicationName (\ s a -> s{_saApplicationName = a});@@ -94,9 +94,9 @@               (\ s h x ->                  StartApplicationResponse' <$> (pure (fromEnum s))) -instance Hashable StartApplication+instance Hashable StartApplication where -instance NFData StartApplication+instance NFData StartApplication where  instance ToHeaders StartApplication where         toHeaders@@ -128,9 +128,10 @@ -- -- /See:/ 'startApplicationResponse' smart constructor. newtype StartApplicationResponse = StartApplicationResponse'-    { _sarsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _sarsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'StartApplicationResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -140,12 +141,11 @@     :: Int -- ^ 'sarsResponseStatus'     -> StartApplicationResponse startApplicationResponse pResponseStatus_ =-    StartApplicationResponse'-    { _sarsResponseStatus = pResponseStatus_-    }+  StartApplicationResponse' {_sarsResponseStatus = pResponseStatus_} + -- | -- | The response status code. sarsResponseStatus :: Lens' StartApplicationResponse Int sarsResponseStatus = lens _sarsResponseStatus (\ s a -> s{_sarsResponseStatus = a}); -instance NFData StartApplicationResponse+instance NFData StartApplicationResponse where

@@ -12,9 +12,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.StopApplication--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -38,12 +38,12 @@     , srsResponseStatus     ) where -import           Network.AWS.KinesisAnalytics.Types-import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Request-import           Network.AWS.Response+import Network.AWS.KinesisAnalytics.Types+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Request+import Network.AWS.Response  -- | --@@ -51,9 +51,10 @@ -- -- /See:/ 'stopApplication' smart constructor. newtype StopApplication = StopApplication'-    { _sApplicationName :: Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _sApplicationName :: Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'StopApplication' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -63,10 +64,9 @@     :: Text -- ^ 'sApplicationName'     -> StopApplication stopApplication pApplicationName_ =-    StopApplication'-    { _sApplicationName = pApplicationName_-    }+  StopApplication' {_sApplicationName = pApplicationName_} + -- | Name of the running application to stop. sApplicationName :: Lens' StopApplication Text sApplicationName = lens _sApplicationName (\ s a -> s{_sApplicationName = a});@@ -79,9 +79,9 @@               (\ s h x ->                  StopApplicationResponse' <$> (pure (fromEnum s))) -instance Hashable StopApplication+instance Hashable StopApplication where -instance NFData StopApplication+instance NFData StopApplication where  instance ToHeaders StopApplication where         toHeaders@@ -111,9 +111,10 @@ -- -- /See:/ 'stopApplicationResponse' smart constructor. newtype StopApplicationResponse = StopApplicationResponse'-    { _srsResponseStatus :: Int-    } deriving (Eq,Read,Show,Data,Typeable,Generic)+  { _srsResponseStatus :: Int+  } deriving (Eq, Read, Show, Data, Typeable, Generic) + -- | Creates a value of 'StopApplicationResponse' with the minimum fields required to make a request. -- -- Use one of the following lenses to modify other fields as desired:@@ -123,12 +124,11 @@     :: Int -- ^ 'srsResponseStatus'     -> StopApplicationResponse stopApplicationResponse pResponseStatus_ =-    StopApplicationResponse'-    { _srsResponseStatus = pResponseStatus_-    }+  StopApplicationResponse' {_srsResponseStatus = pResponseStatus_} + -- | -- | The response status code. srsResponseStatus :: Lens' StopApplicationResponse Int srsResponseStatus = lens _srsResponseStatus (\ s a -> s{_srsResponseStatus = a}); -instance NFData StopApplicationResponse+instance NFData StopApplicationResponse where

@@ -4,9 +4,9 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.Types--- Copyright   : (c) 2013-2016 Brendan Hay+-- Copyright   : (c) 2013-2017 Brendan Hay -- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com> -- Stability   : auto-generated -- Portability : non-portable (GHC extensions) --@@ -21,6 +21,7 @@     , _InvalidArgumentException     , _CodeValidationException     , _ConcurrentModificationException+    , _ServiceUnavailableException     , _UnableToDetectSchemaException     , _ResourceNotFoundException     , _LimitExceededException@@ -40,6 +41,7 @@     , applicationDetail     , adApplicationDescription     , adOutputDescriptions+    , adCloudWatchLoggingOptionDescriptions     , adReferenceDataSourceDescriptions     , adInputDescriptions     , adApplicationCode@@ -62,6 +64,7 @@     , applicationUpdate     , auReferenceDataSourceUpdates     , auInputUpdates+    , auCloudWatchLoggingOptionUpdates     , auOutputUpdates     , auApplicationCodeUpdate @@ -71,6 +74,26 @@     , cmpRecordRowDelimiter     , cmpRecordColumnDelimiter +    -- * CloudWatchLoggingOption+    , CloudWatchLoggingOption+    , cloudWatchLoggingOption+    , cwloLogStreamARN+    , cwloRoleARN++    -- * CloudWatchLoggingOptionDescription+    , CloudWatchLoggingOptionDescription+    , cloudWatchLoggingOptionDescription+    , cwlodCloudWatchLoggingOptionId+    , cwlodLogStreamARN+    , cwlodRoleARN++    -- * CloudWatchLoggingOptionUpdate+    , CloudWatchLoggingOptionUpdate+    , cloudWatchLoggingOptionUpdate+    , cwlouRoleARNUpdate+    , cwlouLogStreamARNUpdate+    , cwlouCloudWatchLoggingOptionId+     -- * DestinationSchema     , DestinationSchema     , destinationSchema@@ -80,6 +103,7 @@     , Input     , input     , iInputParallelism+    , iInputProcessingConfiguration     , iKinesisStreamsInput     , iKinesisFirehoseInput     , iNamePrefix@@ -102,7 +126,26 @@     , idInputSchema     , idKinesisStreamsInputDescription     , idNamePrefix+    , idInputProcessingConfigurationDescription +    -- * InputLambdaProcessor+    , InputLambdaProcessor+    , inputLambdaProcessor+    , ilpResourceARN+    , ilpRoleARN++    -- * InputLambdaProcessorDescription+    , InputLambdaProcessorDescription+    , inputLambdaProcessorDescription+    , ilpdResourceARN+    , ilpdRoleARN++    -- * InputLambdaProcessorUpdate+    , InputLambdaProcessorUpdate+    , inputLambdaProcessorUpdate+    , ilpuRoleARNUpdate+    , ilpuResourceARNUpdate+     -- * InputParallelism     , InputParallelism     , inputParallelism@@ -113,6 +156,21 @@     , inputParallelismUpdate     , ipuCountUpdate +    -- * InputProcessingConfiguration+    , InputProcessingConfiguration+    , inputProcessingConfiguration+    , ipcInputLambdaProcessor++    -- * InputProcessingConfigurationDescription+    , InputProcessingConfigurationDescription+    , inputProcessingConfigurationDescription+    , ipcdInputLambdaProcessorDescription++    -- * InputProcessingConfigurationUpdate+    , InputProcessingConfigurationUpdate+    , inputProcessingConfigurationUpdate+    , ipcuInputLambdaProcessorUpdate+     -- * InputSchemaUpdate     , InputSchemaUpdate     , inputSchemaUpdate@@ -128,6 +186,7 @@     -- * InputUpdate     , InputUpdate     , inputUpdate+    , iuInputProcessingConfigurationUpdate     , iuKinesisStreamsInputUpdate     , iuInputParallelismUpdate     , iuNamePrefixUpdate@@ -280,6 +339,13 @@     , rdsuReferenceSchemaUpdate     , rdsuReferenceId +    -- * S3Configuration+    , S3Configuration+    , s3Configuration+    , scRoleARN+    , scBucketARN+    , scFileKey+     -- * S3ReferenceDataSource     , S3ReferenceDataSource     , s3ReferenceDataSource@@ -309,38 +375,40 @@     , ssRecordColumns     ) where -import           Network.AWS.KinesisAnalytics.Types.Product-import           Network.AWS.KinesisAnalytics.Types.Sum-import           Network.AWS.Lens-import           Network.AWS.Prelude-import           Network.AWS.Sign.V4+import Network.AWS.KinesisAnalytics.Types.Product+import Network.AWS.KinesisAnalytics.Types.Sum+import Network.AWS.Lens+import Network.AWS.Prelude+import Network.AWS.Sign.V4  -- | API version @2015-08-14@ of the Amazon Kinesis Analytics SDK configuration. kinesisAnalytics :: Service kinesisAnalytics =-    Service-    { _svcAbbrev = "KinesisAnalytics"-    , _svcSigner = v4-    , _svcPrefix = "kinesisanalytics"-    , _svcVersion = "2015-08-14"-    , _svcEndpoint = defaultEndpoint kinesisAnalytics-    , _svcTimeout = Just 70-    , _svcCheck = statusSuccess-    , _svcError = parseJSONError "KinesisAnalytics"-    , _svcRetry = retry-    }+  Service+  { _svcAbbrev = "KinesisAnalytics"+  , _svcSigner = v4+  , _svcPrefix = "kinesisanalytics"+  , _svcVersion = "2015-08-14"+  , _svcEndpoint = defaultEndpoint kinesisAnalytics+  , _svcTimeout = Just 70+  , _svcCheck = statusSuccess+  , _svcError = parseJSONError "KinesisAnalytics"+  , _svcRetry = retry+  }   where     retry =-        Exponential-        { _retryBase = 5.0e-2-        , _retryGrowth = 2-        , _retryAttempts = 5-        , _retryCheck = check-        }+      Exponential+      { _retryBase = 5.0e-2+      , _retryGrowth = 2+      , _retryAttempts = 5+      , _retryCheck = check+      }     check e+      | has (hasCode "ThrottledException" . hasStatus 400) e =+        Just "throttled_exception"       | has (hasStatus 429) e = Just "too_many_requests"       | has (hasCode "ThrottlingException" . hasStatus 400) e =-          Just "throttling_exception"+        Just "throttling_exception"       | has (hasCode "Throttling" . hasStatus 400) e = Just "throttling"       | has (hasStatus 504) e = Just "gateway_timeout"       | has (hasStatus 502) e = Just "bad_gateway"@@ -349,61 +417,85 @@       | has (hasStatus 509) e = Just "limit_exceeded"       | otherwise = Nothing + -- | User-provided application configuration is not valid. -- -- _InvalidApplicationConfigurationException :: AsError a => Getting (First ServiceError) a ServiceError _InvalidApplicationConfigurationException =-    _ServiceError . hasCode "InvalidApplicationConfigurationException"+  _MatchServiceError kinesisAnalytics "InvalidApplicationConfigurationException" --- | Discovery failed to get a record from the streaming source because of the Kinesis Streams ProvisionedThroughputExceededException.++-- | Discovery failed to get a record from the streaming source because of the Amazon Kinesis Streams ProvisionedThroughputExceededException. For more information, see <http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html GetRecords> in the Amazon Kinesis Streams API Reference. -- -- _ResourceProvisionedThroughputExceededException :: AsError a => Getting (First ServiceError) a ServiceError _ResourceProvisionedThroughputExceededException =-    _ServiceError . hasCode "ResourceProvisionedThroughputExceededException"+  _MatchServiceError+    kinesisAnalytics+    "ResourceProvisionedThroughputExceededException" + -- | Specified input parameter value is invalid. -- -- _InvalidArgumentException :: AsError a => Getting (First ServiceError) a ServiceError-_InvalidArgumentException = _ServiceError . hasCode "InvalidArgumentException"+_InvalidArgumentException =+  _MatchServiceError kinesisAnalytics "InvalidArgumentException" + -- | User-provided application code (query) is invalid. This can be a simple syntax error. -- -- _CodeValidationException :: AsError a => Getting (First ServiceError) a ServiceError-_CodeValidationException = _ServiceError . hasCode "CodeValidationException"+_CodeValidationException =+  _MatchServiceError kinesisAnalytics "CodeValidationException" + -- | 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. -- -- _ConcurrentModificationException :: AsError a => Getting (First ServiceError) a ServiceError _ConcurrentModificationException =-    _ServiceError . hasCode "ConcurrentModificationException"+  _MatchServiceError kinesisAnalytics "ConcurrentModificationException" --- | Data format is not valid, Kinesis Analytics is not able to detect schema for the given streaming source.++-- | The service is unavailable, back off and retry the operation. -- --+_ServiceUnavailableException :: AsError a => Getting (First ServiceError) a ServiceError+_ServiceUnavailableException =+  _MatchServiceError kinesisAnalytics "ServiceUnavailableException"+++-- | Data format is not valid, Amazon Kinesis Analytics is not able to detect schema for the given streaming source.+--+-- _UnableToDetectSchemaException :: AsError a => Getting (First ServiceError) a ServiceError _UnableToDetectSchemaException =-    _ServiceError . hasCode "UnableToDetectSchemaException"+  _MatchServiceError kinesisAnalytics "UnableToDetectSchemaException" + -- | Specified application can't be found. -- -- _ResourceNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError _ResourceNotFoundException =-    _ServiceError . hasCode "ResourceNotFoundException"+  _MatchServiceError kinesisAnalytics "ResourceNotFoundException" + -- | Exceeded the number of applications allowed. -- -- _LimitExceededException :: AsError a => Getting (First ServiceError) a ServiceError-_LimitExceededException = _ServiceError . hasCode "LimitExceededException"+_LimitExceededException =+  _MatchServiceError kinesisAnalytics "LimitExceededException" + -- | Application is not available for this operation. -- -- _ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError-_ResourceInUseException = _ServiceError . hasCode "ResourceInUseException"+_ResourceInUseException =+  _MatchServiceError kinesisAnalytics "ResourceInUseException"+

@@ -9,2229 +9,2801 @@  -- | -- Module      : Network.AWS.KinesisAnalytics.Types.Product--- Copyright   : (c) 2013-2016 Brendan Hay--- License     : Mozilla Public License, v. 2.0.--- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>--- Stability   : auto-generated--- Portability : non-portable (GHC extensions)----module Network.AWS.KinesisAnalytics.Types.Product where--import           Network.AWS.KinesisAnalytics.Types.Sum-import           Network.AWS.Lens-import           Network.AWS.Prelude---- | 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.-data ApplicationDetail = ApplicationDetail'-    { _adApplicationDescription          :: !(Maybe Text)-    , _adOutputDescriptions              :: !(Maybe [OutputDescription])-    , _adReferenceDataSourceDescriptions :: !(Maybe [ReferenceDataSourceDescription])-    , _adInputDescriptions               :: !(Maybe [InputDescription])-    , _adApplicationCode                 :: !(Maybe Text)-    , _adCreateTimestamp                 :: !(Maybe POSIX)-    , _adLastUpdateTimestamp             :: !(Maybe POSIX)-    , _adApplicationName                 :: !Text-    , _adApplicationARN                  :: !Text-    , _adApplicationStatus               :: !ApplicationStatus-    , _adApplicationVersionId            :: !Nat-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html Configuring Application Output> .------ * 'adReferenceDataSourceDescriptions' - Describes reference data sources configured for the application. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .------ * 'adInputDescriptions' - Describes the application input configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html 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.-applicationDetail-    :: Text -- ^ 'adApplicationName'-    -> Text -- ^ 'adApplicationARN'-    -> ApplicationStatus -- ^ 'adApplicationStatus'-    -> Natural -- ^ 'adApplicationVersionId'-    -> ApplicationDetail-applicationDetail pApplicationName_ pApplicationARN_ pApplicationStatus_ pApplicationVersionId_ =-    ApplicationDetail'-    { _adApplicationDescription = Nothing-    , _adOutputDescriptions = Nothing-    , _adReferenceDataSourceDescriptions = Nothing-    , _adInputDescriptions = Nothing-    , _adApplicationCode = Nothing-    , _adCreateTimestamp = Nothing-    , _adLastUpdateTimestamp = Nothing-    , _adApplicationName = pApplicationName_-    , _adApplicationARN = pApplicationARN_-    , _adApplicationStatus = pApplicationStatus_-    , _adApplicationVersionId = _Nat # pApplicationVersionId_-    }---- | Description of the application.-adApplicationDescription :: Lens' ApplicationDetail (Maybe Text)-adApplicationDescription = lens _adApplicationDescription (\ s a -> s{_adApplicationDescription = a});---- | Describes the application output configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html Configuring Application Output> .-adOutputDescriptions :: Lens' ApplicationDetail [OutputDescription]-adOutputDescriptions = lens _adOutputDescriptions (\ s a -> s{_adOutputDescriptions = a}) . _Default . _Coerce;---- | Describes reference data sources configured for the application. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .-adReferenceDataSourceDescriptions :: Lens' ApplicationDetail [ReferenceDataSourceDescription]-adReferenceDataSourceDescriptions = lens _adReferenceDataSourceDescriptions (\ s a -> s{_adReferenceDataSourceDescriptions = a}) . _Default . _Coerce;---- | Describes the application input configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .-adInputDescriptions :: Lens' ApplicationDetail [InputDescription]-adInputDescriptions = lens _adInputDescriptions (\ s a -> s{_adInputDescriptions = a}) . _Default . _Coerce;---- | Returns the application code that you provided to perform data analysis on any of the in-application streams in your application.-adApplicationCode :: Lens' ApplicationDetail (Maybe Text)-adApplicationCode = lens _adApplicationCode (\ s a -> s{_adApplicationCode = a});---- | Timestamp when the application version was created.-adCreateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)-adCreateTimestamp = lens _adCreateTimestamp (\ s a -> s{_adCreateTimestamp = a}) . mapping _Time;---- | Timestamp when the application was last updated.-adLastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)-adLastUpdateTimestamp = lens _adLastUpdateTimestamp (\ s a -> s{_adLastUpdateTimestamp = a}) . mapping _Time;---- | Name of the application.-adApplicationName :: Lens' ApplicationDetail Text-adApplicationName = lens _adApplicationName (\ s a -> s{_adApplicationName = a});---- | ARN of the application.-adApplicationARN :: Lens' ApplicationDetail Text-adApplicationARN = lens _adApplicationARN (\ s a -> s{_adApplicationARN = a});---- | Status of the application.-adApplicationStatus :: Lens' ApplicationDetail ApplicationStatus-adApplicationStatus = lens _adApplicationStatus (\ s a -> s{_adApplicationStatus = a});---- | Provides the current application version.-adApplicationVersionId :: Lens' ApplicationDetail Natural-adApplicationVersionId = lens _adApplicationVersionId (\ s a -> s{_adApplicationVersionId = a}) . _Nat;--instance FromJSON ApplicationDetail where-        parseJSON-          = withObject "ApplicationDetail"-              (\ x ->-                 ApplicationDetail' <$>-                   (x .:? "ApplicationDescription") <*>-                     (x .:? "OutputDescriptions" .!= mempty)-                     <*>-                     (x .:? "ReferenceDataSourceDescriptions" .!= mempty)-                     <*> (x .:? "InputDescriptions" .!= mempty)-                     <*> (x .:? "ApplicationCode")-                     <*> (x .:? "CreateTimestamp")-                     <*> (x .:? "LastUpdateTimestamp")-                     <*> (x .: "ApplicationName")-                     <*> (x .: "ApplicationARN")-                     <*> (x .: "ApplicationStatus")-                     <*> (x .: "ApplicationVersionId"))--instance Hashable ApplicationDetail--instance NFData ApplicationDetail---- | Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.------------ /See:/ 'applicationSummary' smart constructor.-data ApplicationSummary = ApplicationSummary'-    { _asApplicationName   :: !Text-    , _asApplicationARN    :: !Text-    , _asApplicationStatus :: !ApplicationStatus-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-applicationSummary-    :: Text -- ^ 'asApplicationName'-    -> Text -- ^ 'asApplicationARN'-    -> ApplicationStatus -- ^ 'asApplicationStatus'-    -> ApplicationSummary-applicationSummary pApplicationName_ pApplicationARN_ pApplicationStatus_ =-    ApplicationSummary'-    { _asApplicationName = pApplicationName_-    , _asApplicationARN = pApplicationARN_-    , _asApplicationStatus = pApplicationStatus_-    }---- | Name of the application.-asApplicationName :: Lens' ApplicationSummary Text-asApplicationName = lens _asApplicationName (\ s a -> s{_asApplicationName = a});---- | ARN of the application.-asApplicationARN :: Lens' ApplicationSummary Text-asApplicationARN = lens _asApplicationARN (\ s a -> s{_asApplicationARN = a});---- | Status of the application.-asApplicationStatus :: Lens' ApplicationSummary ApplicationStatus-asApplicationStatus = lens _asApplicationStatus (\ s a -> s{_asApplicationStatus = a});--instance FromJSON ApplicationSummary where-        parseJSON-          = withObject "ApplicationSummary"-              (\ x ->-                 ApplicationSummary' <$>-                   (x .: "ApplicationName") <*> (x .: "ApplicationARN")-                     <*> (x .: "ApplicationStatus"))--instance Hashable ApplicationSummary--instance NFData ApplicationSummary---- | Describes updates to apply to an existing Kinesis Analytics application.------------ /See:/ 'applicationUpdate' smart constructor.-data ApplicationUpdate = ApplicationUpdate'-    { _auReferenceDataSourceUpdates :: !(Maybe [ReferenceDataSourceUpdate])-    , _auInputUpdates               :: !(Maybe [InputUpdate])-    , _auOutputUpdates              :: !(Maybe [OutputUpdate])-    , _auApplicationCodeUpdate      :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.------ * 'auOutputUpdates' - Describes application output configuration updates.------ * 'auApplicationCodeUpdate' - Describes application code updates.-applicationUpdate-    :: ApplicationUpdate-applicationUpdate =-    ApplicationUpdate'-    { _auReferenceDataSourceUpdates = Nothing-    , _auInputUpdates = Nothing-    , _auOutputUpdates = Nothing-    , _auApplicationCodeUpdate = Nothing-    }---- | Describes application reference data source updates.-auReferenceDataSourceUpdates :: Lens' ApplicationUpdate [ReferenceDataSourceUpdate]-auReferenceDataSourceUpdates = lens _auReferenceDataSourceUpdates (\ s a -> s{_auReferenceDataSourceUpdates = a}) . _Default . _Coerce;---- | Describes application input configuration updates.-auInputUpdates :: Lens' ApplicationUpdate [InputUpdate]-auInputUpdates = lens _auInputUpdates (\ s a -> s{_auInputUpdates = a}) . _Default . _Coerce;---- | Describes application output configuration updates.-auOutputUpdates :: Lens' ApplicationUpdate [OutputUpdate]-auOutputUpdates = lens _auOutputUpdates (\ s a -> s{_auOutputUpdates = a}) . _Default . _Coerce;---- | Describes application code updates.-auApplicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text)-auApplicationCodeUpdate = lens _auApplicationCodeUpdate (\ s a -> s{_auApplicationCodeUpdate = a});--instance Hashable ApplicationUpdate--instance NFData ApplicationUpdate--instance ToJSON ApplicationUpdate where-        toJSON ApplicationUpdate'{..}-          = object-              (catMaybes-                 [("ReferenceDataSourceUpdates" .=) <$>-                    _auReferenceDataSourceUpdates,-                  ("InputUpdates" .=) <$> _auInputUpdates,-                  ("OutputUpdates" .=) <$> _auOutputUpdates,-                  ("ApplicationCodeUpdate" .=) <$>-                    _auApplicationCodeUpdate])---- | 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.-data CSVMappingParameters = CSVMappingParameters'-    { _cmpRecordRowDelimiter    :: !Text-    , _cmpRecordColumnDelimiter :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-csvMappingParameters-    :: Text -- ^ 'cmpRecordRowDelimiter'-    -> Text -- ^ 'cmpRecordColumnDelimiter'-    -> CSVMappingParameters-csvMappingParameters pRecordRowDelimiter_ pRecordColumnDelimiter_ =-    CSVMappingParameters'-    { _cmpRecordRowDelimiter = pRecordRowDelimiter_-    , _cmpRecordColumnDelimiter = pRecordColumnDelimiter_-    }---- | Row delimiter. For example, in a CSV format, /'\n'/ is the typical row delimiter.-cmpRecordRowDelimiter :: Lens' CSVMappingParameters Text-cmpRecordRowDelimiter = lens _cmpRecordRowDelimiter (\ s a -> s{_cmpRecordRowDelimiter = a});---- | Column delimiter. For example, in a CSV format, a comma (",") is the typical column delimiter.-cmpRecordColumnDelimiter :: Lens' CSVMappingParameters Text-cmpRecordColumnDelimiter = lens _cmpRecordColumnDelimiter (\ s a -> s{_cmpRecordColumnDelimiter = a});--instance FromJSON CSVMappingParameters where-        parseJSON-          = withObject "CSVMappingParameters"-              (\ x ->-                 CSVMappingParameters' <$>-                   (x .: "RecordRowDelimiter") <*>-                     (x .: "RecordColumnDelimiter"))--instance Hashable CSVMappingParameters--instance NFData CSVMappingParameters--instance ToJSON CSVMappingParameters where-        toJSON CSVMappingParameters'{..}-          = object-              (catMaybes-                 [Just-                    ("RecordRowDelimiter" .= _cmpRecordRowDelimiter),-                  Just-                    ("RecordColumnDelimiter" .=-                       _cmpRecordColumnDelimiter)])---- | Describes the data format when records are written to the destination. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html Configuring Application Output> .------------ /See:/ 'destinationSchema' smart constructor.-newtype DestinationSchema = DestinationSchema'-    { _dsRecordFormatType :: Maybe RecordFormatType-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-destinationSchema-    :: DestinationSchema-destinationSchema =-    DestinationSchema'-    { _dsRecordFormatType = Nothing-    }---- | Specifies the format of the records on the output stream.-dsRecordFormatType :: Lens' DestinationSchema (Maybe RecordFormatType)-dsRecordFormatType = lens _dsRecordFormatType (\ s a -> s{_dsRecordFormatType = a});--instance FromJSON DestinationSchema where-        parseJSON-          = withObject "DestinationSchema"-              (\ x ->-                 DestinationSchema' <$> (x .:? "RecordFormatType"))--instance Hashable DestinationSchema--instance NFData DestinationSchema--instance ToJSON DestinationSchema where-        toJSON DestinationSchema'{..}-          = object-              (catMaybes-                 [("RecordFormatType" .=) <$> _dsRecordFormatType])---- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .------------ /See:/ 'input' smart constructor.-data Input = Input'-    { _iInputParallelism     :: !(Maybe InputParallelism)-    , _iKinesisStreamsInput  :: !(Maybe KinesisStreamsInput)-    , _iKinesisFirehoseInput :: !(Maybe KinesisFirehoseInput)-    , _iNamePrefix           :: !Text-    , _iInputSchema          :: !SourceSchema-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .------ * 'iKinesisStreamsInput' - If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.------ * 'iKinesisFirehoseInput' - If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the Firehose delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.------ * 'iNamePrefix' - Name prefix to use when creating in-application stream. Suppose you specify a prefix "MyInApplicationStream". Kinesis Analytics will then create one or more (as per the @InputParallelism@ count you specified) in-application streams with names "MyInApplicationStream_001", "MyInApplicationStream_002" and so on.------ * 'iInputSchema' - Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created. Also used to describe the format of the reference data source.-input-    :: Text -- ^ 'iNamePrefix'-    -> SourceSchema -- ^ 'iInputSchema'-    -> Input-input pNamePrefix_ pInputSchema_ =-    Input'-    { _iInputParallelism = Nothing-    , _iKinesisStreamsInput = Nothing-    , _iKinesisFirehoseInput = Nothing-    , _iNamePrefix = pNamePrefix_-    , _iInputSchema = pInputSchema_-    }---- | Describes the number of in-application streams to create.  Data from your source will be routed to these in-application input streams. (see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .-iInputParallelism :: Lens' Input (Maybe InputParallelism)-iInputParallelism = lens _iInputParallelism (\ s a -> s{_iInputParallelism = a});---- | 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.-iKinesisStreamsInput :: Lens' Input (Maybe KinesisStreamsInput)-iKinesisStreamsInput = lens _iKinesisStreamsInput (\ s a -> s{_iKinesisStreamsInput = a});---- | 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.-iKinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput)-iKinesisFirehoseInput = lens _iKinesisFirehoseInput (\ s a -> s{_iKinesisFirehoseInput = a});---- | Name prefix to use when creating in-application stream. Suppose you specify a prefix "MyInApplicationStream". Kinesis Analytics will then create one or more (as per the @InputParallelism@ count you specified) in-application streams with names "MyInApplicationStream_001", "MyInApplicationStream_002" and so on.-iNamePrefix :: Lens' Input Text-iNamePrefix = lens _iNamePrefix (\ s a -> s{_iNamePrefix = a});---- | 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.-iInputSchema :: Lens' Input SourceSchema-iInputSchema = lens _iInputSchema (\ s a -> s{_iInputSchema = a});--instance Hashable Input--instance NFData Input--instance ToJSON Input where-        toJSON Input'{..}-          = object-              (catMaybes-                 [("InputParallelism" .=) <$> _iInputParallelism,-                  ("KinesisStreamsInput" .=) <$> _iKinesisStreamsInput,-                  ("KinesisFirehoseInput" .=) <$>-                    _iKinesisFirehoseInput,-                  Just ("NamePrefix" .= _iNamePrefix),-                  Just ("InputSchema" .= _iInputSchema)])---- | 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.-data InputConfiguration = InputConfiguration'-    { _icId                                 :: !Text-    , _icInputStartingPositionConfiguration :: !InputStartingPositionConfiguration-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-inputConfiguration-    :: Text -- ^ 'icId'-    -> InputStartingPositionConfiguration -- ^ 'icInputStartingPositionConfiguration'-    -> InputConfiguration-inputConfiguration pId_ pInputStartingPositionConfiguration_ =-    InputConfiguration'-    { _icId = pId_-    , _icInputStartingPositionConfiguration = pInputStartingPositionConfiguration_-    }---- | Input source ID. You can get this ID by calling the 'DescribeApplication' operation.-icId :: Lens' InputConfiguration Text-icId = lens _icId (\ s a -> s{_icId = a});---- | Point at which you want the application to start processing records from the streaming source.-icInputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration-icInputStartingPositionConfiguration = lens _icInputStartingPositionConfiguration (\ s a -> s{_icInputStartingPositionConfiguration = a});--instance Hashable InputConfiguration--instance NFData InputConfiguration--instance ToJSON InputConfiguration where-        toJSON InputConfiguration'{..}-          = object-              (catMaybes-                 [Just ("Id" .= _icId),-                  Just-                    ("InputStartingPositionConfiguration" .=-                       _icInputStartingPositionConfiguration)])---- | Describes the application input configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .------------ /See:/ 'inputDescription' smart constructor.-data InputDescription = InputDescription'-    { _idInputStartingPositionConfiguration :: !(Maybe InputStartingPositionConfiguration)-    , _idInputParallelism                   :: !(Maybe InputParallelism)-    , _idInputId                            :: !(Maybe Text)-    , _idInAppStreamNames                   :: !(Maybe [Text])-    , _idKinesisFirehoseInputDescription    :: !(Maybe KinesisFirehoseInputDescription)-    , _idInputSchema                        :: !(Maybe SourceSchema)-    , _idKinesisStreamsInputDescription     :: !(Maybe KinesisStreamsInputDescription)-    , _idNamePrefix                         :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | Creates a value of 'InputDescription' with the minimum fields required to make a request.------ Use one of the following lenses to modify other fields as desired:------ * 'idInputStartingPositionConfiguration' - Point at which the application is configured to read from the input stream.------ * 'idInputParallelism' - Describes the configured parallelism (number of in-application streams mapped to the streaming source).------ * 'idInputId' - Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.------ * 'idInAppStreamNames' - Returns the in-application stream names that are mapped to the stream source.------ * 'idKinesisFirehoseInputDescription' - If an Amazon Kinesis Firehose delivery stream is configured as a streaming source, provides the Firehose delivery stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.------ * 'idInputSchema' - Undocumented member.------ * 'idKinesisStreamsInputDescription' - If an Amazon Kinesis stream is configured as streaming source, provides Amazon Kinesis stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.------ * 'idNamePrefix' - In-application name prefix.-inputDescription-    :: InputDescription-inputDescription =-    InputDescription'-    { _idInputStartingPositionConfiguration = Nothing-    , _idInputParallelism = Nothing-    , _idInputId = Nothing-    , _idInAppStreamNames = Nothing-    , _idKinesisFirehoseInputDescription = Nothing-    , _idInputSchema = Nothing-    , _idKinesisStreamsInputDescription = Nothing-    , _idNamePrefix = Nothing-    }---- | Point at which the application is configured to read from the input stream.-idInputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration)-idInputStartingPositionConfiguration = lens _idInputStartingPositionConfiguration (\ s a -> s{_idInputStartingPositionConfiguration = a});---- | Describes the configured parallelism (number of in-application streams mapped to the streaming source).-idInputParallelism :: Lens' InputDescription (Maybe InputParallelism)-idInputParallelism = lens _idInputParallelism (\ s a -> s{_idInputParallelism = a});---- | 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.-idInputId :: Lens' InputDescription (Maybe Text)-idInputId = lens _idInputId (\ s a -> s{_idInputId = a});---- | Returns the in-application stream names that are mapped to the stream source.-idInAppStreamNames :: Lens' InputDescription [Text]-idInAppStreamNames = lens _idInAppStreamNames (\ s a -> s{_idInAppStreamNames = a}) . _Default . _Coerce;---- | 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.-idKinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription)-idKinesisFirehoseInputDescription = lens _idKinesisFirehoseInputDescription (\ s a -> s{_idKinesisFirehoseInputDescription = a});---- | Undocumented member.-idInputSchema :: Lens' InputDescription (Maybe SourceSchema)-idInputSchema = lens _idInputSchema (\ s a -> s{_idInputSchema = a});---- | 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.-idKinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription)-idKinesisStreamsInputDescription = lens _idKinesisStreamsInputDescription (\ s a -> s{_idKinesisStreamsInputDescription = a});---- | In-application name prefix.-idNamePrefix :: Lens' InputDescription (Maybe Text)-idNamePrefix = lens _idNamePrefix (\ s a -> s{_idNamePrefix = a});--instance FromJSON InputDescription where-        parseJSON-          = withObject "InputDescription"-              (\ x ->-                 InputDescription' <$>-                   (x .:? "InputStartingPositionConfiguration") <*>-                     (x .:? "InputParallelism")-                     <*> (x .:? "InputId")-                     <*> (x .:? "InAppStreamNames" .!= mempty)-                     <*> (x .:? "KinesisFirehoseInputDescription")-                     <*> (x .:? "InputSchema")-                     <*> (x .:? "KinesisStreamsInputDescription")-                     <*> (x .:? "NamePrefix"))--instance Hashable InputDescription--instance NFData InputDescription---- | Describes the number of in-application streams to create for a given streaming source. For information about parallellism, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .------------ /See:/ 'inputParallelism' smart constructor.-newtype InputParallelism = InputParallelism'-    { _ipCount :: Maybe Nat-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html Limits> .-inputParallelism-    :: InputParallelism-inputParallelism =-    InputParallelism'-    { _ipCount = Nothing-    }---- | Number of in-application streams to create. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html Limits> .-ipCount :: Lens' InputParallelism (Maybe Natural)-ipCount = lens _ipCount (\ s a -> s{_ipCount = a}) . mapping _Nat;--instance FromJSON InputParallelism where-        parseJSON-          = withObject "InputParallelism"-              (\ x -> InputParallelism' <$> (x .:? "Count"))--instance Hashable InputParallelism--instance NFData InputParallelism--instance ToJSON InputParallelism where-        toJSON InputParallelism'{..}-          = object (catMaybes [("Count" .=) <$> _ipCount])---- | Provides updates to the parallelism count.------------ /See:/ 'inputParallelismUpdate' smart constructor.-newtype InputParallelismUpdate = InputParallelismUpdate'-    { _ipuCountUpdate :: Maybe Nat-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-inputParallelismUpdate-    :: InputParallelismUpdate-inputParallelismUpdate =-    InputParallelismUpdate'-    { _ipuCountUpdate = Nothing-    }---- | Number of in-application streams to create for the specified streaming source.-ipuCountUpdate :: Lens' InputParallelismUpdate (Maybe Natural)-ipuCountUpdate = lens _ipuCountUpdate (\ s a -> s{_ipuCountUpdate = a}) . mapping _Nat;--instance Hashable InputParallelismUpdate--instance NFData InputParallelismUpdate--instance ToJSON InputParallelismUpdate where-        toJSON InputParallelismUpdate'{..}-          = object-              (catMaybes [("CountUpdate" .=) <$> _ipuCountUpdate])---- | Describes updates for the application's input schema.------------ /See:/ 'inputSchemaUpdate' smart constructor.-data InputSchemaUpdate = InputSchemaUpdate'-    { _isuRecordFormatUpdate   :: !(Maybe RecordFormat)-    , _isuRecordEncodingUpdate :: !(Maybe Text)-    , _isuRecordColumnUpdates  :: !(Maybe (List1 RecordColumn))-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-inputSchemaUpdate-    :: InputSchemaUpdate-inputSchemaUpdate =-    InputSchemaUpdate'-    { _isuRecordFormatUpdate = Nothing-    , _isuRecordEncodingUpdate = Nothing-    , _isuRecordColumnUpdates = Nothing-    }---- | Specifies the format of the records on the streaming source.-isuRecordFormatUpdate :: Lens' InputSchemaUpdate (Maybe RecordFormat)-isuRecordFormatUpdate = lens _isuRecordFormatUpdate (\ s a -> s{_isuRecordFormatUpdate = a});---- | Specifies the encoding of the records in the streaming source. For example, UTF-8.-isuRecordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text)-isuRecordEncodingUpdate = lens _isuRecordEncodingUpdate (\ s a -> s{_isuRecordEncodingUpdate = a});---- | A list of @RecordColumn@ objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.-isuRecordColumnUpdates :: Lens' InputSchemaUpdate (Maybe (NonEmpty RecordColumn))-isuRecordColumnUpdates = lens _isuRecordColumnUpdates (\ s a -> s{_isuRecordColumnUpdates = a}) . mapping _List1;--instance Hashable InputSchemaUpdate--instance NFData InputSchemaUpdate--instance ToJSON InputSchemaUpdate where-        toJSON InputSchemaUpdate'{..}-          = object-              (catMaybes-                 [("RecordFormatUpdate" .=) <$>-                    _isuRecordFormatUpdate,-                  ("RecordEncodingUpdate" .=) <$>-                    _isuRecordEncodingUpdate,-                  ("RecordColumnUpdates" .=) <$>-                    _isuRecordColumnUpdates])---- | Describes the point at which the application reads from the streaming source.------------ /See:/ 'inputStartingPositionConfiguration' smart constructor.-newtype InputStartingPositionConfiguration = InputStartingPositionConfiguration'-    { _ispcInputStartingPosition :: Maybe InputStartingPosition-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | Creates a value of 'InputStartingPositionConfiguration' with the minimum fields required to make a request.------ Use one of the following lenses to modify other fields as desired:------ * 'ispcInputStartingPosition' - The starting position on the stream.     * @LATEST@ - Start reading just after the most recent record in the stream.     * @TRIM_HORIZON@ - Start reading at the last untrimmed record in the stream, which is the oldest record available in the stream. This option is not available for an Amazon Kinesis Firehose delivery stream.     * @LAST_STOPPED_POINT@ - Resume reading from where the application last stopped reading.-inputStartingPositionConfiguration-    :: InputStartingPositionConfiguration-inputStartingPositionConfiguration =-    InputStartingPositionConfiguration'-    { _ispcInputStartingPosition = Nothing-    }---- | The starting position on the stream.     * @LATEST@ - Start reading just after the most recent record in the stream.     * @TRIM_HORIZON@ - Start reading at the last untrimmed record in the stream, which is the oldest record available in the stream. This option is not available for an Amazon Kinesis Firehose delivery stream.     * @LAST_STOPPED_POINT@ - Resume reading from where the application last stopped reading.-ispcInputStartingPosition :: Lens' InputStartingPositionConfiguration (Maybe InputStartingPosition)-ispcInputStartingPosition = lens _ispcInputStartingPosition (\ s a -> s{_ispcInputStartingPosition = a});--instance FromJSON InputStartingPositionConfiguration-         where-        parseJSON-          = withObject "InputStartingPositionConfiguration"-              (\ x ->-                 InputStartingPositionConfiguration' <$>-                   (x .:? "InputStartingPosition"))--instance Hashable InputStartingPositionConfiguration--instance NFData InputStartingPositionConfiguration--instance ToJSON InputStartingPositionConfiguration-         where-        toJSON InputStartingPositionConfiguration'{..}-          = object-              (catMaybes-                 [("InputStartingPosition" .=) <$>-                    _ispcInputStartingPosition])---- | Describes updates to a specific input configuration (identified by the @InputId@ of an application).------------ /See:/ 'inputUpdate' smart constructor.-data InputUpdate = InputUpdate'-    { _iuKinesisStreamsInputUpdate  :: !(Maybe KinesisStreamsInputUpdate)-    , _iuInputParallelismUpdate     :: !(Maybe InputParallelismUpdate)-    , _iuNamePrefixUpdate           :: !(Maybe Text)-    , _iuInputSchemaUpdate          :: !(Maybe InputSchemaUpdate)-    , _iuKinesisFirehoseInputUpdate :: !(Maybe KinesisFirehoseInputUpdate)-    , _iuInputId                    :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | Creates a value of 'InputUpdate' with the minimum fields required to make a request.------ Use one of the following lenses to modify other fields as desired:------ * 'iuKinesisStreamsInputUpdate' - If a Amazon Kinesis stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.------ * 'iuInputParallelismUpdate' - Describes the parallelism updates (the number in-application streams Kinesis Analytics creates for the specific streaming source).------ * 'iuNamePrefixUpdate' - Name prefix for in-application stream(s) that Kinesis Analytics creates for the specific streaming source.------ * 'iuInputSchemaUpdate' - Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.------ * 'iuKinesisFirehoseInputUpdate' - If an Amazon Kinesis Firehose delivery stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN) and IAM role ARN.------ * 'iuInputId' - Input ID of the application input to be updated.-inputUpdate-    :: Text -- ^ 'iuInputId'-    -> InputUpdate-inputUpdate pInputId_ =-    InputUpdate'-    { _iuKinesisStreamsInputUpdate = Nothing-    , _iuInputParallelismUpdate = Nothing-    , _iuNamePrefixUpdate = Nothing-    , _iuInputSchemaUpdate = Nothing-    , _iuKinesisFirehoseInputUpdate = Nothing-    , _iuInputId = pInputId_-    }---- | If a Amazon Kinesis stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.-iuKinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate)-iuKinesisStreamsInputUpdate = lens _iuKinesisStreamsInputUpdate (\ s a -> s{_iuKinesisStreamsInputUpdate = a});---- | Describes the parallelism updates (the number in-application streams Kinesis Analytics creates for the specific streaming source).-iuInputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate)-iuInputParallelismUpdate = lens _iuInputParallelismUpdate (\ s a -> s{_iuInputParallelismUpdate = a});---- | Name prefix for in-application stream(s) that Kinesis Analytics creates for the specific streaming source.-iuNamePrefixUpdate :: Lens' InputUpdate (Maybe Text)-iuNamePrefixUpdate = lens _iuNamePrefixUpdate (\ s a -> s{_iuNamePrefixUpdate = a});---- | 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.-iuInputSchemaUpdate :: Lens' InputUpdate (Maybe InputSchemaUpdate)-iuInputSchemaUpdate = lens _iuInputSchemaUpdate (\ s a -> s{_iuInputSchemaUpdate = a});---- | 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.-iuKinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate)-iuKinesisFirehoseInputUpdate = lens _iuKinesisFirehoseInputUpdate (\ s a -> s{_iuKinesisFirehoseInputUpdate = a});---- | Input ID of the application input to be updated.-iuInputId :: Lens' InputUpdate Text-iuInputId = lens _iuInputId (\ s a -> s{_iuInputId = a});--instance Hashable InputUpdate--instance NFData InputUpdate--instance ToJSON InputUpdate where-        toJSON InputUpdate'{..}-          = object-              (catMaybes-                 [("KinesisStreamsInputUpdate" .=) <$>-                    _iuKinesisStreamsInputUpdate,-                  ("InputParallelismUpdate" .=) <$>-                    _iuInputParallelismUpdate,-                  ("NamePrefixUpdate" .=) <$> _iuNamePrefixUpdate,-                  ("InputSchemaUpdate" .=) <$> _iuInputSchemaUpdate,-                  ("KinesisFirehoseInputUpdate" .=) <$>-                    _iuKinesisFirehoseInputUpdate,-                  Just ("InputId" .= _iuInputId)])---- | Provides additional mapping information when JSON is the record format on the streaming source.------------ /See:/ 'jsonMappingParameters' smart constructor.-newtype JSONMappingParameters = JSONMappingParameters'-    { _jmpRecordRowPath :: Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | Creates a value of 'JSONMappingParameters' with the minimum fields required to make a request.------ Use one of the following lenses to modify other fields as desired:------ * 'jmpRecordRowPath' - Path to the top-level parent that contains the records. For example, consider the following JSON record: In the @RecordRowPath@ , @"$"@ refers to the root and path @"$.vehicle.Model"@ refers to the specific @"Model"@ key in the JSON.-jsonMappingParameters-    :: Text -- ^ 'jmpRecordRowPath'-    -> JSONMappingParameters-jsonMappingParameters pRecordRowPath_ =-    JSONMappingParameters'-    { _jmpRecordRowPath = pRecordRowPath_-    }---- | Path to the top-level parent that contains the records. For example, consider the following JSON record: In the @RecordRowPath@ , @"$"@ refers to the root and path @"$.vehicle.Model"@ refers to the specific @"Model"@ key in the JSON.-jmpRecordRowPath :: Lens' JSONMappingParameters Text-jmpRecordRowPath = lens _jmpRecordRowPath (\ s a -> s{_jmpRecordRowPath = a});--instance FromJSON JSONMappingParameters where-        parseJSON-          = withObject "JSONMappingParameters"-              (\ x ->-                 JSONMappingParameters' <$> (x .: "RecordRowPath"))--instance Hashable JSONMappingParameters--instance NFData JSONMappingParameters--instance ToJSON JSONMappingParameters where-        toJSON JSONMappingParameters'{..}-          = object-              (catMaybes-                 [Just ("RecordRowPath" .= _jmpRecordRowPath)])---- | 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.-data KinesisFirehoseInput = KinesisFirehoseInput'-    { _kfiResourceARN :: !Text-    , _kfiRoleARN     :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisFirehoseInput-    :: Text -- ^ 'kfiResourceARN'-    -> Text -- ^ 'kfiRoleARN'-    -> KinesisFirehoseInput-kinesisFirehoseInput pResourceARN_ pRoleARN_ =-    KinesisFirehoseInput'-    { _kfiResourceARN = pResourceARN_-    , _kfiRoleARN = pRoleARN_-    }---- | ARN of the input Firehose delivery stream.-kfiResourceARN :: Lens' KinesisFirehoseInput Text-kfiResourceARN = lens _kfiResourceARN (\ s a -> s{_kfiResourceARN = a});---- | 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.-kfiRoleARN :: Lens' KinesisFirehoseInput Text-kfiRoleARN = lens _kfiRoleARN (\ s a -> s{_kfiRoleARN = a});--instance Hashable KinesisFirehoseInput--instance NFData KinesisFirehoseInput--instance ToJSON KinesisFirehoseInput where-        toJSON KinesisFirehoseInput'{..}-          = object-              (catMaybes-                 [Just ("ResourceARN" .= _kfiResourceARN),-                  Just ("RoleARN" .= _kfiRoleARN)])---- | Describes the Amazon Kinesis Firehose delivery stream that is configured as the streaming source in the application input configuration.------------ /See:/ 'kinesisFirehoseInputDescription' smart constructor.-data KinesisFirehoseInputDescription = KinesisFirehoseInputDescription'-    { _kfidResourceARN :: !(Maybe Text)-    , _kfidRoleARN     :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisFirehoseInputDescription-    :: KinesisFirehoseInputDescription-kinesisFirehoseInputDescription =-    KinesisFirehoseInputDescription'-    { _kfidResourceARN = Nothing-    , _kfidRoleARN = Nothing-    }---- | Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.-kfidResourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)-kfidResourceARN = lens _kfidResourceARN (\ s a -> s{_kfidResourceARN = a});---- | ARN of the IAM role that Amazon Kinesis Analytics assumes to access the stream.-kfidRoleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)-kfidRoleARN = lens _kfidRoleARN (\ s a -> s{_kfidRoleARN = a});--instance FromJSON KinesisFirehoseInputDescription-         where-        parseJSON-          = withObject "KinesisFirehoseInputDescription"-              (\ x ->-                 KinesisFirehoseInputDescription' <$>-                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))--instance Hashable KinesisFirehoseInputDescription--instance NFData KinesisFirehoseInputDescription---- | When updating application input configuration, provides information about an Amazon Kinesis Firehose delivery stream as the streaming source.------------ /See:/ 'kinesisFirehoseInputUpdate' smart constructor.-data KinesisFirehoseInputUpdate = KinesisFirehoseInputUpdate'-    { _kfiuRoleARNUpdate     :: !(Maybe Text)-    , _kfiuResourceARNUpdate :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisFirehoseInputUpdate-    :: KinesisFirehoseInputUpdate-kinesisFirehoseInputUpdate =-    KinesisFirehoseInputUpdate'-    { _kfiuRoleARNUpdate = Nothing-    , _kfiuResourceARNUpdate = Nothing-    }---- | 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.-kfiuRoleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)-kfiuRoleARNUpdate = lens _kfiuRoleARNUpdate (\ s a -> s{_kfiuRoleARNUpdate = a});---- | ARN of the input Amazon Kinesis Firehose delivery stream to read.-kfiuResourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)-kfiuResourceARNUpdate = lens _kfiuResourceARNUpdate (\ s a -> s{_kfiuResourceARNUpdate = a});--instance Hashable KinesisFirehoseInputUpdate--instance NFData KinesisFirehoseInputUpdate--instance ToJSON KinesisFirehoseInputUpdate where-        toJSON KinesisFirehoseInputUpdate'{..}-          = object-              (catMaybes-                 [("RoleARNUpdate" .=) <$> _kfiuRoleARNUpdate,-                  ("ResourceARNUpdate" .=) <$> _kfiuResourceARNUpdate])---- | 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.-data KinesisFirehoseOutput = KinesisFirehoseOutput'-    { _kfoResourceARN :: !Text-    , _kfoRoleARN     :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisFirehoseOutput-    :: Text -- ^ 'kfoResourceARN'-    -> Text -- ^ 'kfoRoleARN'-    -> KinesisFirehoseOutput-kinesisFirehoseOutput pResourceARN_ pRoleARN_ =-    KinesisFirehoseOutput'-    { _kfoResourceARN = pResourceARN_-    , _kfoRoleARN = pRoleARN_-    }---- | ARN of the destination Amazon Kinesis Firehose delivery stream to write to.-kfoResourceARN :: Lens' KinesisFirehoseOutput Text-kfoResourceARN = lens _kfoResourceARN (\ s a -> s{_kfoResourceARN = a});---- | 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.-kfoRoleARN :: Lens' KinesisFirehoseOutput Text-kfoRoleARN = lens _kfoRoleARN (\ s a -> s{_kfoRoleARN = a});--instance Hashable KinesisFirehoseOutput--instance NFData KinesisFirehoseOutput--instance ToJSON KinesisFirehoseOutput where-        toJSON KinesisFirehoseOutput'{..}-          = object-              (catMaybes-                 [Just ("ResourceARN" .= _kfoResourceARN),-                  Just ("RoleARN" .= _kfoRoleARN)])---- | For an application output, describes the Amazon Kinesis Firehose delivery stream configured as its destination.------------ /See:/ 'kinesisFirehoseOutputDescription' smart constructor.-data KinesisFirehoseOutputDescription = KinesisFirehoseOutputDescription'-    { _kfodResourceARN :: !(Maybe Text)-    , _kfodRoleARN     :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisFirehoseOutputDescription-    :: KinesisFirehoseOutputDescription-kinesisFirehoseOutputDescription =-    KinesisFirehoseOutputDescription'-    { _kfodResourceARN = Nothing-    , _kfodRoleARN = Nothing-    }---- | Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.-kfodResourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)-kfodResourceARN = lens _kfodResourceARN (\ s a -> s{_kfodResourceARN = a});---- | ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.-kfodRoleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)-kfodRoleARN = lens _kfodRoleARN (\ s a -> s{_kfodRoleARN = a});--instance FromJSON KinesisFirehoseOutputDescription-         where-        parseJSON-          = withObject "KinesisFirehoseOutputDescription"-              (\ x ->-                 KinesisFirehoseOutputDescription' <$>-                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))--instance Hashable KinesisFirehoseOutputDescription--instance NFData KinesisFirehoseOutputDescription---- | 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.-data KinesisFirehoseOutputUpdate = KinesisFirehoseOutputUpdate'-    { _kfouRoleARNUpdate     :: !(Maybe Text)-    , _kfouResourceARNUpdate :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisFirehoseOutputUpdate-    :: KinesisFirehoseOutputUpdate-kinesisFirehoseOutputUpdate =-    KinesisFirehoseOutputUpdate'-    { _kfouRoleARNUpdate = Nothing-    , _kfouResourceARNUpdate = Nothing-    }---- | 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.-kfouRoleARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)-kfouRoleARNUpdate = lens _kfouRoleARNUpdate (\ s a -> s{_kfouRoleARNUpdate = a});---- | Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream to write to.-kfouResourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)-kfouResourceARNUpdate = lens _kfouResourceARNUpdate (\ s a -> s{_kfouResourceARNUpdate = a});--instance Hashable KinesisFirehoseOutputUpdate--instance NFData KinesisFirehoseOutputUpdate--instance ToJSON KinesisFirehoseOutputUpdate where-        toJSON KinesisFirehoseOutputUpdate'{..}-          = object-              (catMaybes-                 [("RoleARNUpdate" .=) <$> _kfouRoleARNUpdate,-                  ("ResourceARNUpdate" .=) <$> _kfouResourceARNUpdate])---- | 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.-data KinesisStreamsInput = KinesisStreamsInput'-    { _ksiResourceARN :: !Text-    , _ksiRoleARN     :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisStreamsInput-    :: Text -- ^ 'ksiResourceARN'-    -> Text -- ^ 'ksiRoleARN'-    -> KinesisStreamsInput-kinesisStreamsInput pResourceARN_ pRoleARN_ =-    KinesisStreamsInput'-    { _ksiResourceARN = pResourceARN_-    , _ksiRoleARN = pRoleARN_-    }---- | ARN of the input Amazon Kinesis stream to read.-ksiResourceARN :: Lens' KinesisStreamsInput Text-ksiResourceARN = lens _ksiResourceARN (\ s a -> s{_ksiResourceARN = a});---- | 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.-ksiRoleARN :: Lens' KinesisStreamsInput Text-ksiRoleARN = lens _ksiRoleARN (\ s a -> s{_ksiRoleARN = a});--instance Hashable KinesisStreamsInput--instance NFData KinesisStreamsInput--instance ToJSON KinesisStreamsInput where-        toJSON KinesisStreamsInput'{..}-          = object-              (catMaybes-                 [Just ("ResourceARN" .= _ksiResourceARN),-                  Just ("RoleARN" .= _ksiRoleARN)])---- | Describes the Amazon Kinesis stream that is configured as the streaming source in the application input configuration.------------ /See:/ 'kinesisStreamsInputDescription' smart constructor.-data KinesisStreamsInputDescription = KinesisStreamsInputDescription'-    { _ksidResourceARN :: !(Maybe Text)-    , _ksidRoleARN     :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisStreamsInputDescription-    :: KinesisStreamsInputDescription-kinesisStreamsInputDescription =-    KinesisStreamsInputDescription'-    { _ksidResourceARN = Nothing-    , _ksidRoleARN = Nothing-    }---- | Amazon Resource Name (ARN) of the Amazon Kinesis stream.-ksidResourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text)-ksidResourceARN = lens _ksidResourceARN (\ s a -> s{_ksidResourceARN = a});---- | ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.-ksidRoleARN :: Lens' KinesisStreamsInputDescription (Maybe Text)-ksidRoleARN = lens _ksidRoleARN (\ s a -> s{_ksidRoleARN = a});--instance FromJSON KinesisStreamsInputDescription-         where-        parseJSON-          = withObject "KinesisStreamsInputDescription"-              (\ x ->-                 KinesisStreamsInputDescription' <$>-                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))--instance Hashable KinesisStreamsInputDescription--instance NFData KinesisStreamsInputDescription---- | When updating application input configuration, provides information about an Amazon Kinesis stream as the streaming source.------------ /See:/ 'kinesisStreamsInputUpdate' smart constructor.-data KinesisStreamsInputUpdate = KinesisStreamsInputUpdate'-    { _ksiuRoleARNUpdate     :: !(Maybe Text)-    , _ksiuResourceARNUpdate :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisStreamsInputUpdate-    :: KinesisStreamsInputUpdate-kinesisStreamsInputUpdate =-    KinesisStreamsInputUpdate'-    { _ksiuRoleARNUpdate = Nothing-    , _ksiuResourceARNUpdate = Nothing-    }---- | 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.-ksiuRoleARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)-ksiuRoleARNUpdate = lens _ksiuRoleARNUpdate (\ s a -> s{_ksiuRoleARNUpdate = a});---- | Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.-ksiuResourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)-ksiuResourceARNUpdate = lens _ksiuResourceARNUpdate (\ s a -> s{_ksiuResourceARNUpdate = a});--instance Hashable KinesisStreamsInputUpdate--instance NFData KinesisStreamsInputUpdate--instance ToJSON KinesisStreamsInputUpdate where-        toJSON KinesisStreamsInputUpdate'{..}-          = object-              (catMaybes-                 [("RoleARNUpdate" .=) <$> _ksiuRoleARNUpdate,-                  ("ResourceARNUpdate" .=) <$> _ksiuResourceARNUpdate])---- | 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.-data KinesisStreamsOutput = KinesisStreamsOutput'-    { _ksoResourceARN :: !Text-    , _ksoRoleARN     :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisStreamsOutput-    :: Text -- ^ 'ksoResourceARN'-    -> Text -- ^ 'ksoRoleARN'-    -> KinesisStreamsOutput-kinesisStreamsOutput pResourceARN_ pRoleARN_ =-    KinesisStreamsOutput'-    { _ksoResourceARN = pResourceARN_-    , _ksoRoleARN = pRoleARN_-    }---- | ARN of the destination Amazon Kinesis stream to write to.-ksoResourceARN :: Lens' KinesisStreamsOutput Text-ksoResourceARN = lens _ksoResourceARN (\ s a -> s{_ksoResourceARN = a});---- | 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.-ksoRoleARN :: Lens' KinesisStreamsOutput Text-ksoRoleARN = lens _ksoRoleARN (\ s a -> s{_ksoRoleARN = a});--instance Hashable KinesisStreamsOutput--instance NFData KinesisStreamsOutput--instance ToJSON KinesisStreamsOutput where-        toJSON KinesisStreamsOutput'{..}-          = object-              (catMaybes-                 [Just ("ResourceARN" .= _ksoResourceARN),-                  Just ("RoleARN" .= _ksoRoleARN)])---- | For an application output, describes the Amazon Kinesis stream configured as its destination.------------ /See:/ 'kinesisStreamsOutputDescription' smart constructor.-data KinesisStreamsOutputDescription = KinesisStreamsOutputDescription'-    { _ksodResourceARN :: !(Maybe Text)-    , _ksodRoleARN     :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisStreamsOutputDescription-    :: KinesisStreamsOutputDescription-kinesisStreamsOutputDescription =-    KinesisStreamsOutputDescription'-    { _ksodResourceARN = Nothing-    , _ksodRoleARN = Nothing-    }---- | Amazon Resource Name (ARN) of the Amazon Kinesis stream.-ksodResourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)-ksodResourceARN = lens _ksodResourceARN (\ s a -> s{_ksodResourceARN = a});---- | ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.-ksodRoleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)-ksodRoleARN = lens _ksodRoleARN (\ s a -> s{_ksodRoleARN = a});--instance FromJSON KinesisStreamsOutputDescription-         where-        parseJSON-          = withObject "KinesisStreamsOutputDescription"-              (\ x ->-                 KinesisStreamsOutputDescription' <$>-                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))--instance Hashable KinesisStreamsOutputDescription--instance NFData KinesisStreamsOutputDescription---- | When updating an output configuration using the 'UpdateApplication' operation, provides information about an Amazon Kinesis stream configured as the destination.------------ /See:/ 'kinesisStreamsOutputUpdate' smart constructor.-data KinesisStreamsOutputUpdate = KinesisStreamsOutputUpdate'-    { _ksouRoleARNUpdate     :: !(Maybe Text)-    , _ksouResourceARNUpdate :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-kinesisStreamsOutputUpdate-    :: KinesisStreamsOutputUpdate-kinesisStreamsOutputUpdate =-    KinesisStreamsOutputUpdate'-    { _ksouRoleARNUpdate = Nothing-    , _ksouResourceARNUpdate = Nothing-    }---- | 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.-ksouRoleARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)-ksouRoleARNUpdate = lens _ksouRoleARNUpdate (\ s a -> s{_ksouRoleARNUpdate = a});---- | Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want to write the output.-ksouResourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)-ksouResourceARNUpdate = lens _ksouResourceARNUpdate (\ s a -> s{_ksouResourceARNUpdate = a});--instance Hashable KinesisStreamsOutputUpdate--instance NFData KinesisStreamsOutputUpdate--instance ToJSON KinesisStreamsOutputUpdate where-        toJSON KinesisStreamsOutputUpdate'{..}-          = object-              (catMaybes-                 [("RoleARNUpdate" .=) <$> _ksouRoleARNUpdate,-                  ("ResourceARNUpdate" .=) <$> _ksouResourceARNUpdate])---- | 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.-data MappingParameters = MappingParameters'-    { _mpCSVMappingParameters  :: !(Maybe CSVMappingParameters)-    , _mpJSONMappingParameters :: !(Maybe JSONMappingParameters)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-mappingParameters-    :: MappingParameters-mappingParameters =-    MappingParameters'-    { _mpCSVMappingParameters = Nothing-    , _mpJSONMappingParameters = Nothing-    }---- | Provides additional mapping information when the record format uses delimiters (for example, CSV).-mpCSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters)-mpCSVMappingParameters = lens _mpCSVMappingParameters (\ s a -> s{_mpCSVMappingParameters = a});---- | Provides additional mapping information when JSON is the record format on the streaming source.-mpJSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters)-mpJSONMappingParameters = lens _mpJSONMappingParameters (\ s a -> s{_mpJSONMappingParameters = a});--instance FromJSON MappingParameters where-        parseJSON-          = withObject "MappingParameters"-              (\ x ->-                 MappingParameters' <$>-                   (x .:? "CSVMappingParameters") <*>-                     (x .:? "JSONMappingParameters"))--instance Hashable MappingParameters--instance NFData MappingParameters--instance ToJSON MappingParameters where-        toJSON MappingParameters'{..}-          = object-              (catMaybes-                 [("CSVMappingParameters" .=) <$>-                    _mpCSVMappingParameters,-                  ("JSONMappingParameters" .=) <$>-                    _mpJSONMappingParameters])---- | Describes application output configuration in which you identify an in-application stream and a destination where you want the in-application stream data to be written. The destination can be an Amazon Kinesis stream or an Amazon Kinesis Firehose delivery stream.--------------- You can configure your application to write output to up to five destinations.--------- /See:/ 'output' smart constructor.-data Output = Output'-    { _oKinesisStreamsOutput  :: !(Maybe KinesisStreamsOutput)-    , _oKinesisFirehoseOutput :: !(Maybe KinesisFirehoseOutput)-    , _oName                  :: !Text-    , _oDestinationSchema     :: !DestinationSchema-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-output-    :: Text -- ^ 'oName'-    -> DestinationSchema -- ^ 'oDestinationSchema'-    -> Output-output pName_ pDestinationSchema_ =-    Output'-    { _oKinesisStreamsOutput = Nothing-    , _oKinesisFirehoseOutput = Nothing-    , _oName = pName_-    , _oDestinationSchema = pDestinationSchema_-    }---- | Identifies an Amazon Kinesis stream as the destination.-oKinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput)-oKinesisStreamsOutput = lens _oKinesisStreamsOutput (\ s a -> s{_oKinesisStreamsOutput = a});---- | Identifies an Amazon Kinesis Firehose delivery stream as the destination.-oKinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput)-oKinesisFirehoseOutput = lens _oKinesisFirehoseOutput (\ s a -> s{_oKinesisFirehoseOutput = a});---- | Name of the in-application stream.-oName :: Lens' Output Text-oName = lens _oName (\ s a -> s{_oName = a});---- | Undocumented member.-oDestinationSchema :: Lens' Output DestinationSchema-oDestinationSchema = lens _oDestinationSchema (\ s a -> s{_oDestinationSchema = a});--instance Hashable Output--instance NFData Output--instance ToJSON Output where-        toJSON Output'{..}-          = object-              (catMaybes-                 [("KinesisStreamsOutput" .=) <$>-                    _oKinesisStreamsOutput,-                  ("KinesisFirehoseOutput" .=) <$>-                    _oKinesisFirehoseOutput,-                  Just ("Name" .= _oName),-                  Just ("DestinationSchema" .= _oDestinationSchema)])---- | 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.-data OutputDescription = OutputDescription'-    { _odOutputId                         :: !(Maybe Text)-    , _odDestinationSchema                :: !(Maybe DestinationSchema)-    , _odKinesisFirehoseOutputDescription :: !(Maybe KinesisFirehoseOutputDescription)-    , _odKinesisStreamsOutputDescription  :: !(Maybe KinesisStreamsOutputDescription)-    , _odName                             :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-outputDescription-    :: OutputDescription-outputDescription =-    OutputDescription'-    { _odOutputId = Nothing-    , _odDestinationSchema = Nothing-    , _odKinesisFirehoseOutputDescription = Nothing-    , _odKinesisStreamsOutputDescription = Nothing-    , _odName = Nothing-    }---- | A unique identifier for the output configuration.-odOutputId :: Lens' OutputDescription (Maybe Text)-odOutputId = lens _odOutputId (\ s a -> s{_odOutputId = a});---- | Data format used for writing data to the destination.-odDestinationSchema :: Lens' OutputDescription (Maybe DestinationSchema)-odDestinationSchema = lens _odDestinationSchema (\ s a -> s{_odDestinationSchema = a});---- | Describes the Amazon Kinesis Firehose delivery stream configured as the destination where output is written.-odKinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription)-odKinesisFirehoseOutputDescription = lens _odKinesisFirehoseOutputDescription (\ s a -> s{_odKinesisFirehoseOutputDescription = a});---- | Describes Amazon Kinesis stream configured as the destination where output is written.-odKinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription)-odKinesisStreamsOutputDescription = lens _odKinesisStreamsOutputDescription (\ s a -> s{_odKinesisStreamsOutputDescription = a});---- | Name of the in-application stream configured as output.-odName :: Lens' OutputDescription (Maybe Text)-odName = lens _odName (\ s a -> s{_odName = a});--instance FromJSON OutputDescription where-        parseJSON-          = withObject "OutputDescription"-              (\ x ->-                 OutputDescription' <$>-                   (x .:? "OutputId") <*> (x .:? "DestinationSchema")-                     <*> (x .:? "KinesisFirehoseOutputDescription")-                     <*> (x .:? "KinesisStreamsOutputDescription")-                     <*> (x .:? "Name"))--instance Hashable OutputDescription--instance NFData OutputDescription---- | Describes updates to the output configuration identified by the @OutputId@ .------------ /See:/ 'outputUpdate' smart constructor.-data OutputUpdate = OutputUpdate'-    { _ouKinesisStreamsOutputUpdate  :: !(Maybe KinesisStreamsOutputUpdate)-    , _ouDestinationSchemaUpdate     :: !(Maybe DestinationSchema)-    , _ouKinesisFirehoseOutputUpdate :: !(Maybe KinesisFirehoseOutputUpdate)-    , _ouNameUpdate                  :: !(Maybe Text)-    , _ouOutputId                    :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-outputUpdate-    :: Text -- ^ 'ouOutputId'-    -> OutputUpdate-outputUpdate pOutputId_ =-    OutputUpdate'-    { _ouKinesisStreamsOutputUpdate = Nothing-    , _ouDestinationSchemaUpdate = Nothing-    , _ouKinesisFirehoseOutputUpdate = Nothing-    , _ouNameUpdate = Nothing-    , _ouOutputId = pOutputId_-    }---- | Describes an Amazon Kinesis stream as the destination for the output.-ouKinesisStreamsOutputUpdate :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate)-ouKinesisStreamsOutputUpdate = lens _ouKinesisStreamsOutputUpdate (\ s a -> s{_ouKinesisStreamsOutputUpdate = a});---- | Undocumented member.-ouDestinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema)-ouDestinationSchemaUpdate = lens _ouDestinationSchemaUpdate (\ s a -> s{_ouDestinationSchemaUpdate = a});---- | Describes a Amazon Kinesis Firehose delivery stream as the destination for the output.-ouKinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate)-ouKinesisFirehoseOutputUpdate = lens _ouKinesisFirehoseOutputUpdate (\ s a -> s{_ouKinesisFirehoseOutputUpdate = a});---- | 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.-ouNameUpdate :: Lens' OutputUpdate (Maybe Text)-ouNameUpdate = lens _ouNameUpdate (\ s a -> s{_ouNameUpdate = a});---- | Identifies the specific output configuration that you want to update.-ouOutputId :: Lens' OutputUpdate Text-ouOutputId = lens _ouOutputId (\ s a -> s{_ouOutputId = a});--instance Hashable OutputUpdate--instance NFData OutputUpdate--instance ToJSON OutputUpdate where-        toJSON OutputUpdate'{..}-          = object-              (catMaybes-                 [("KinesisStreamsOutputUpdate" .=) <$>-                    _ouKinesisStreamsOutputUpdate,-                  ("DestinationSchemaUpdate" .=) <$>-                    _ouDestinationSchemaUpdate,-                  ("KinesisFirehoseOutputUpdate" .=) <$>-                    _ouKinesisFirehoseOutputUpdate,-                  ("NameUpdate" .=) <$> _ouNameUpdate,-                  Just ("OutputId" .= _ouOutputId)])---- | 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.-data RecordColumn = RecordColumn'-    { _rcMapping :: !(Maybe Text)-    , _rcName    :: !Text-    , _rcSqlType :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-recordColumn-    :: Text -- ^ 'rcName'-    -> Text -- ^ 'rcSqlType'-    -> RecordColumn-recordColumn pName_ pSqlType_ =-    RecordColumn'-    { _rcMapping = Nothing-    , _rcName = pName_-    , _rcSqlType = pSqlType_-    }---- | Reference to the data element in the streaming input of the reference data source.-rcMapping :: Lens' RecordColumn (Maybe Text)-rcMapping = lens _rcMapping (\ s a -> s{_rcMapping = a});---- | Name of the column created in the in-application input stream or reference table.-rcName :: Lens' RecordColumn Text-rcName = lens _rcName (\ s a -> s{_rcName = a});---- | Type of column created in the in-application input stream or reference table.-rcSqlType :: Lens' RecordColumn Text-rcSqlType = lens _rcSqlType (\ s a -> s{_rcSqlType = a});--instance FromJSON RecordColumn where-        parseJSON-          = withObject "RecordColumn"-              (\ x ->-                 RecordColumn' <$>-                   (x .:? "Mapping") <*> (x .: "Name") <*>-                     (x .: "SqlType"))--instance Hashable RecordColumn--instance NFData RecordColumn--instance ToJSON RecordColumn where-        toJSON RecordColumn'{..}-          = object-              (catMaybes-                 [("Mapping" .=) <$> _rcMapping,-                  Just ("Name" .= _rcName),-                  Just ("SqlType" .= _rcSqlType)])---- | Describes the record format and relevant mapping information that should be applied to schematize the records on the stream.------------ /See:/ 'recordFormat' smart constructor.-data RecordFormat = RecordFormat'-    { _rfMappingParameters :: !(Maybe MappingParameters)-    , _rfRecordFormatType  :: !RecordFormatType-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-recordFormat-    :: RecordFormatType -- ^ 'rfRecordFormatType'-    -> RecordFormat-recordFormat pRecordFormatType_ =-    RecordFormat'-    { _rfMappingParameters = Nothing-    , _rfRecordFormatType = pRecordFormatType_-    }---- | Undocumented member.-rfMappingParameters :: Lens' RecordFormat (Maybe MappingParameters)-rfMappingParameters = lens _rfMappingParameters (\ s a -> s{_rfMappingParameters = a});---- | The type of record format.-rfRecordFormatType :: Lens' RecordFormat RecordFormatType-rfRecordFormatType = lens _rfRecordFormatType (\ s a -> s{_rfRecordFormatType = a});--instance FromJSON RecordFormat where-        parseJSON-          = withObject "RecordFormat"-              (\ x ->-                 RecordFormat' <$>-                   (x .:? "MappingParameters") <*>-                     (x .: "RecordFormatType"))--instance Hashable RecordFormat--instance NFData RecordFormat--instance ToJSON RecordFormat where-        toJSON RecordFormat'{..}-          = object-              (catMaybes-                 [("MappingParameters" .=) <$> _rfMappingParameters,-                  Just ("RecordFormatType" .= _rfRecordFormatType)])---- | 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.-data ReferenceDataSource = ReferenceDataSource'-    { _rdsS3ReferenceDataSource :: !(Maybe S3ReferenceDataSource)-    , _rdsTableName             :: !Text-    , _rdsReferenceSchema       :: !SourceSchema-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-referenceDataSource-    :: Text -- ^ 'rdsTableName'-    -> SourceSchema -- ^ 'rdsReferenceSchema'-    -> ReferenceDataSource-referenceDataSource pTableName_ pReferenceSchema_ =-    ReferenceDataSource'-    { _rdsS3ReferenceDataSource = Nothing-    , _rdsTableName = pTableName_-    , _rdsReferenceSchema = pReferenceSchema_-    }---- | Undocumented member.-rdsS3ReferenceDataSource :: Lens' ReferenceDataSource (Maybe S3ReferenceDataSource)-rdsS3ReferenceDataSource = lens _rdsS3ReferenceDataSource (\ s a -> s{_rdsS3ReferenceDataSource = a});---- | Name of the in-application table to create.-rdsTableName :: Lens' ReferenceDataSource Text-rdsTableName = lens _rdsTableName (\ s a -> s{_rdsTableName = a});---- | Undocumented member.-rdsReferenceSchema :: Lens' ReferenceDataSource SourceSchema-rdsReferenceSchema = lens _rdsReferenceSchema (\ s a -> s{_rdsReferenceSchema = a});--instance Hashable ReferenceDataSource--instance NFData ReferenceDataSource--instance ToJSON ReferenceDataSource where-        toJSON ReferenceDataSource'{..}-          = object-              (catMaybes-                 [("S3ReferenceDataSource" .=) <$>-                    _rdsS3ReferenceDataSource,-                  Just ("TableName" .= _rdsTableName),-                  Just ("ReferenceSchema" .= _rdsReferenceSchema)])---- | Describes the reference data source configured for an application.------------ /See:/ 'referenceDataSourceDescription' smart constructor.-data ReferenceDataSourceDescription = ReferenceDataSourceDescription'-    { _rdsdReferenceSchema                  :: !(Maybe SourceSchema)-    , _rdsdReferenceId                      :: !Text-    , _rdsdTableName                        :: !Text-    , _rdsdS3ReferenceDataSourceDescription :: !S3ReferenceDataSourceDescription-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-referenceDataSourceDescription-    :: Text -- ^ 'rdsdReferenceId'-    -> Text -- ^ 'rdsdTableName'-    -> S3ReferenceDataSourceDescription -- ^ 'rdsdS3ReferenceDataSourceDescription'-    -> ReferenceDataSourceDescription-referenceDataSourceDescription pReferenceId_ pTableName_ pS3ReferenceDataSourceDescription_ =-    ReferenceDataSourceDescription'-    { _rdsdReferenceSchema = Nothing-    , _rdsdReferenceId = pReferenceId_-    , _rdsdTableName = pTableName_-    , _rdsdS3ReferenceDataSourceDescription = pS3ReferenceDataSourceDescription_-    }---- | Undocumented member.-rdsdReferenceSchema :: Lens' ReferenceDataSourceDescription (Maybe SourceSchema)-rdsdReferenceSchema = lens _rdsdReferenceSchema (\ s a -> s{_rdsdReferenceSchema = a});---- | 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.-rdsdReferenceId :: Lens' ReferenceDataSourceDescription Text-rdsdReferenceId = lens _rdsdReferenceId (\ s a -> s{_rdsdReferenceId = a});---- | The in-application table name created by the specific reference data source configuration.-rdsdTableName :: Lens' ReferenceDataSourceDescription Text-rdsdTableName = lens _rdsdTableName (\ s a -> s{_rdsdTableName = a});---- | 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.-rdsdS3ReferenceDataSourceDescription :: Lens' ReferenceDataSourceDescription S3ReferenceDataSourceDescription-rdsdS3ReferenceDataSourceDescription = lens _rdsdS3ReferenceDataSourceDescription (\ s a -> s{_rdsdS3ReferenceDataSourceDescription = a});--instance FromJSON ReferenceDataSourceDescription-         where-        parseJSON-          = withObject "ReferenceDataSourceDescription"-              (\ x ->-                 ReferenceDataSourceDescription' <$>-                   (x .:? "ReferenceSchema") <*> (x .: "ReferenceId")-                     <*> (x .: "TableName")-                     <*> (x .: "S3ReferenceDataSourceDescription"))--instance Hashable ReferenceDataSourceDescription--instance NFData ReferenceDataSourceDescription---- | 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.-data ReferenceDataSourceUpdate = ReferenceDataSourceUpdate'-    { _rdsuTableNameUpdate             :: !(Maybe Text)-    , _rdsuS3ReferenceDataSourceUpdate :: !(Maybe S3ReferenceDataSourceUpdate)-    , _rdsuReferenceSchemaUpdate       :: !(Maybe SourceSchema)-    , _rdsuReferenceId                 :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-referenceDataSourceUpdate-    :: Text -- ^ 'rdsuReferenceId'-    -> ReferenceDataSourceUpdate-referenceDataSourceUpdate pReferenceId_ =-    ReferenceDataSourceUpdate'-    { _rdsuTableNameUpdate = Nothing-    , _rdsuS3ReferenceDataSourceUpdate = Nothing-    , _rdsuReferenceSchemaUpdate = Nothing-    , _rdsuReferenceId = pReferenceId_-    }---- | In-application table name that is created by this update.-rdsuTableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text)-rdsuTableNameUpdate = lens _rdsuTableNameUpdate (\ s a -> s{_rdsuTableNameUpdate = a});---- | 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.-rdsuS3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe S3ReferenceDataSourceUpdate)-rdsuS3ReferenceDataSourceUpdate = lens _rdsuS3ReferenceDataSourceUpdate (\ s a -> s{_rdsuS3ReferenceDataSourceUpdate = a});---- | Undocumented member.-rdsuReferenceSchemaUpdate :: Lens' ReferenceDataSourceUpdate (Maybe SourceSchema)-rdsuReferenceSchemaUpdate = lens _rdsuReferenceSchemaUpdate (\ s a -> s{_rdsuReferenceSchemaUpdate = a});---- | ID of the reference data source being updated. You can use the 'DescribeApplication' operation to get this value.-rdsuReferenceId :: Lens' ReferenceDataSourceUpdate Text-rdsuReferenceId = lens _rdsuReferenceId (\ s a -> s{_rdsuReferenceId = a});--instance Hashable ReferenceDataSourceUpdate--instance NFData ReferenceDataSourceUpdate--instance ToJSON ReferenceDataSourceUpdate where-        toJSON ReferenceDataSourceUpdate'{..}-          = object-              (catMaybes-                 [("TableNameUpdate" .=) <$> _rdsuTableNameUpdate,-                  ("S3ReferenceDataSourceUpdate" .=) <$>-                    _rdsuS3ReferenceDataSourceUpdate,-                  ("ReferenceSchemaUpdate" .=) <$>-                    _rdsuReferenceSchemaUpdate,-                  Just ("ReferenceId" .= _rdsuReferenceId)])---- | 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.-data S3ReferenceDataSource = S3ReferenceDataSource'-    { _srdsBucketARN        :: !Text-    , _srdsFileKey          :: !Text-    , _srdsReferenceRoleARN :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-s3ReferenceDataSource-    :: Text -- ^ 'srdsBucketARN'-    -> Text -- ^ 'srdsFileKey'-    -> Text -- ^ 'srdsReferenceRoleARN'-    -> S3ReferenceDataSource-s3ReferenceDataSource pBucketARN_ pFileKey_ pReferenceRoleARN_ =-    S3ReferenceDataSource'-    { _srdsBucketARN = pBucketARN_-    , _srdsFileKey = pFileKey_-    , _srdsReferenceRoleARN = pReferenceRoleARN_-    }---- | Amazon Resource Name (ARN) of the S3 bucket.-srdsBucketARN :: Lens' S3ReferenceDataSource Text-srdsBucketARN = lens _srdsBucketARN (\ s a -> s{_srdsBucketARN = a});---- | Object key name containing reference data.-srdsFileKey :: Lens' S3ReferenceDataSource Text-srdsFileKey = lens _srdsFileKey (\ s a -> s{_srdsFileKey = a});---- | 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.-srdsReferenceRoleARN :: Lens' S3ReferenceDataSource Text-srdsReferenceRoleARN = lens _srdsReferenceRoleARN (\ s a -> s{_srdsReferenceRoleARN = a});--instance Hashable S3ReferenceDataSource--instance NFData S3ReferenceDataSource--instance ToJSON S3ReferenceDataSource where-        toJSON S3ReferenceDataSource'{..}-          = object-              (catMaybes-                 [Just ("BucketARN" .= _srdsBucketARN),-                  Just ("FileKey" .= _srdsFileKey),-                  Just ("ReferenceRoleARN" .= _srdsReferenceRoleARN)])---- | Provides the bucket name and object key name that stores the reference data.------------ /See:/ 's3ReferenceDataSourceDescription' smart constructor.-data S3ReferenceDataSourceDescription = S3ReferenceDataSourceDescription'-    { _srdsdBucketARN        :: !Text-    , _srdsdFileKey          :: !Text-    , _srdsdReferenceRoleARN :: !Text-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-s3ReferenceDataSourceDescription-    :: Text -- ^ 'srdsdBucketARN'-    -> Text -- ^ 'srdsdFileKey'-    -> Text -- ^ 'srdsdReferenceRoleARN'-    -> S3ReferenceDataSourceDescription-s3ReferenceDataSourceDescription pBucketARN_ pFileKey_ pReferenceRoleARN_ =-    S3ReferenceDataSourceDescription'-    { _srdsdBucketARN = pBucketARN_-    , _srdsdFileKey = pFileKey_-    , _srdsdReferenceRoleARN = pReferenceRoleARN_-    }---- | Amazon Resource Name (ARN) of the S3 bucket.-srdsdBucketARN :: Lens' S3ReferenceDataSourceDescription Text-srdsdBucketARN = lens _srdsdBucketARN (\ s a -> s{_srdsdBucketARN = a});---- | Amazon S3 object key name.-srdsdFileKey :: Lens' S3ReferenceDataSourceDescription Text-srdsdFileKey = lens _srdsdFileKey (\ s a -> s{_srdsdFileKey = a});---- | 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.-srdsdReferenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text-srdsdReferenceRoleARN = lens _srdsdReferenceRoleARN (\ s a -> s{_srdsdReferenceRoleARN = a});--instance FromJSON S3ReferenceDataSourceDescription-         where-        parseJSON-          = withObject "S3ReferenceDataSourceDescription"-              (\ x ->-                 S3ReferenceDataSourceDescription' <$>-                   (x .: "BucketARN") <*> (x .: "FileKey") <*>-                     (x .: "ReferenceRoleARN"))--instance Hashable S3ReferenceDataSourceDescription--instance NFData S3ReferenceDataSourceDescription---- | 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.-data S3ReferenceDataSourceUpdate = S3ReferenceDataSourceUpdate'-    { _srdsuBucketARNUpdate        :: !(Maybe Text)-    , _srdsuFileKeyUpdate          :: !(Maybe Text)-    , _srdsuReferenceRoleARNUpdate :: !(Maybe Text)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-s3ReferenceDataSourceUpdate-    :: S3ReferenceDataSourceUpdate-s3ReferenceDataSourceUpdate =-    S3ReferenceDataSourceUpdate'-    { _srdsuBucketARNUpdate = Nothing-    , _srdsuFileKeyUpdate = Nothing-    , _srdsuReferenceRoleARNUpdate = Nothing-    }---- | Amazon Resource Name (ARN) of the S3 bucket.-srdsuBucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)-srdsuBucketARNUpdate = lens _srdsuBucketARNUpdate (\ s a -> s{_srdsuBucketARNUpdate = a});---- | Object key name.-srdsuFileKeyUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)-srdsuFileKeyUpdate = lens _srdsuFileKeyUpdate (\ s a -> s{_srdsuFileKeyUpdate = a});---- | ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application.-srdsuReferenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)-srdsuReferenceRoleARNUpdate = lens _srdsuReferenceRoleARNUpdate (\ s a -> s{_srdsuReferenceRoleARNUpdate = a});--instance Hashable S3ReferenceDataSourceUpdate--instance NFData S3ReferenceDataSourceUpdate--instance ToJSON S3ReferenceDataSourceUpdate where-        toJSON S3ReferenceDataSourceUpdate'{..}-          = object-              (catMaybes-                 [("BucketARNUpdate" .=) <$> _srdsuBucketARNUpdate,-                  ("FileKeyUpdate" .=) <$> _srdsuFileKeyUpdate,-                  ("ReferenceRoleARNUpdate" .=) <$>-                    _srdsuReferenceRoleARNUpdate])---- | 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.-data SourceSchema = SourceSchema'-    { _ssRecordEncoding :: !(Maybe Text)-    , _ssRecordFormat   :: !RecordFormat-    , _ssRecordColumns  :: !(List1 RecordColumn)-    } deriving (Eq,Read,Show,Data,Typeable,Generic)---- | 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.-sourceSchema-    :: RecordFormat -- ^ 'ssRecordFormat'-    -> NonEmpty RecordColumn -- ^ 'ssRecordColumns'-    -> SourceSchema-sourceSchema pRecordFormat_ pRecordColumns_ =-    SourceSchema'-    { _ssRecordEncoding = Nothing-    , _ssRecordFormat = pRecordFormat_-    , _ssRecordColumns = _List1 # pRecordColumns_-    }---- | Specifies the encoding of the records in the streaming source. For example, UTF-8.-ssRecordEncoding :: Lens' SourceSchema (Maybe Text)-ssRecordEncoding = lens _ssRecordEncoding (\ s a -> s{_ssRecordEncoding = a});---- | Specifies the format of the records on the streaming source.-ssRecordFormat :: Lens' SourceSchema RecordFormat-ssRecordFormat = lens _ssRecordFormat (\ s a -> s{_ssRecordFormat = a});---- | A list of @RecordColumn@ objects.-ssRecordColumns :: Lens' SourceSchema (NonEmpty RecordColumn)-ssRecordColumns = lens _ssRecordColumns (\ s a -> s{_ssRecordColumns = a}) . _List1;--instance FromJSON SourceSchema where-        parseJSON-          = withObject "SourceSchema"-              (\ x ->-                 SourceSchema' <$>-                   (x .:? "RecordEncoding") <*> (x .: "RecordFormat")-                     <*> (x .: "RecordColumns"))--instance Hashable SourceSchema--instance NFData SourceSchema+-- Copyright   : (c) 2013-2017 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay <brendan.g.hay+amazonka@gmail.com>+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+module Network.AWS.KinesisAnalytics.Types.Product where++import Network.AWS.KinesisAnalytics.Types.Sum+import Network.AWS.Lens+import Network.AWS.Prelude++-- | 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.+data ApplicationDetail = ApplicationDetail'+  { _adApplicationDescription :: !(Maybe Text)+  , _adOutputDescriptions :: !(Maybe [OutputDescription])+  , _adCloudWatchLoggingOptionDescriptions :: !(Maybe [CloudWatchLoggingOptionDescription])+  , _adReferenceDataSourceDescriptions :: !(Maybe [ReferenceDataSourceDescription])+  , _adInputDescriptions :: !(Maybe [InputDescription])+  , _adApplicationCode :: !(Maybe Text)+  , _adCreateTimestamp :: !(Maybe POSIX)+  , _adLastUpdateTimestamp :: !(Maybe POSIX)+  , _adApplicationName :: !Text+  , _adApplicationARN :: !Text+  , _adApplicationStatus :: !ApplicationStatus+  , _adApplicationVersionId :: !Nat+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/cloudwatch-logs.html Working with Amazon CloudWatch Logs> .+--+-- * 'adReferenceDataSourceDescriptions' - Describes reference data sources configured for the application. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .+--+-- * 'adInputDescriptions' - Describes the application input configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html 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.+applicationDetail+    :: Text -- ^ 'adApplicationName'+    -> Text -- ^ 'adApplicationARN'+    -> ApplicationStatus -- ^ 'adApplicationStatus'+    -> Natural -- ^ 'adApplicationVersionId'+    -> ApplicationDetail+applicationDetail pApplicationName_ pApplicationARN_ pApplicationStatus_ pApplicationVersionId_ =+  ApplicationDetail'+  { _adApplicationDescription = Nothing+  , _adOutputDescriptions = Nothing+  , _adCloudWatchLoggingOptionDescriptions = Nothing+  , _adReferenceDataSourceDescriptions = Nothing+  , _adInputDescriptions = Nothing+  , _adApplicationCode = Nothing+  , _adCreateTimestamp = Nothing+  , _adLastUpdateTimestamp = Nothing+  , _adApplicationName = pApplicationName_+  , _adApplicationARN = pApplicationARN_+  , _adApplicationStatus = pApplicationStatus_+  , _adApplicationVersionId = _Nat # pApplicationVersionId_+  }+++-- | Description of the application.+adApplicationDescription :: Lens' ApplicationDetail (Maybe Text)+adApplicationDescription = lens _adApplicationDescription (\ s a -> s{_adApplicationDescription = a});++-- | Describes the application output configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html Configuring Application Output> .+adOutputDescriptions :: Lens' ApplicationDetail [OutputDescription]+adOutputDescriptions = lens _adOutputDescriptions (\ s a -> s{_adOutputDescriptions = a}) . _Default . _Coerce;++-- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/cloudwatch-logs.html Working with Amazon CloudWatch Logs> .+adCloudWatchLoggingOptionDescriptions :: Lens' ApplicationDetail [CloudWatchLoggingOptionDescription]+adCloudWatchLoggingOptionDescriptions = lens _adCloudWatchLoggingOptionDescriptions (\ s a -> s{_adCloudWatchLoggingOptionDescriptions = a}) . _Default . _Coerce;++-- | Describes reference data sources configured for the application. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .+adReferenceDataSourceDescriptions :: Lens' ApplicationDetail [ReferenceDataSourceDescription]+adReferenceDataSourceDescriptions = lens _adReferenceDataSourceDescriptions (\ s a -> s{_adReferenceDataSourceDescriptions = a}) . _Default . _Coerce;++-- | Describes the application input configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .+adInputDescriptions :: Lens' ApplicationDetail [InputDescription]+adInputDescriptions = lens _adInputDescriptions (\ s a -> s{_adInputDescriptions = a}) . _Default . _Coerce;++-- | Returns the application code that you provided to perform data analysis on any of the in-application streams in your application.+adApplicationCode :: Lens' ApplicationDetail (Maybe Text)+adApplicationCode = lens _adApplicationCode (\ s a -> s{_adApplicationCode = a});++-- | Timestamp when the application version was created.+adCreateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)+adCreateTimestamp = lens _adCreateTimestamp (\ s a -> s{_adCreateTimestamp = a}) . mapping _Time;++-- | Timestamp when the application was last updated.+adLastUpdateTimestamp :: Lens' ApplicationDetail (Maybe UTCTime)+adLastUpdateTimestamp = lens _adLastUpdateTimestamp (\ s a -> s{_adLastUpdateTimestamp = a}) . mapping _Time;++-- | Name of the application.+adApplicationName :: Lens' ApplicationDetail Text+adApplicationName = lens _adApplicationName (\ s a -> s{_adApplicationName = a});++-- | ARN of the application.+adApplicationARN :: Lens' ApplicationDetail Text+adApplicationARN = lens _adApplicationARN (\ s a -> s{_adApplicationARN = a});++-- | Status of the application.+adApplicationStatus :: Lens' ApplicationDetail ApplicationStatus+adApplicationStatus = lens _adApplicationStatus (\ s a -> s{_adApplicationStatus = a});++-- | Provides the current application version.+adApplicationVersionId :: Lens' ApplicationDetail Natural+adApplicationVersionId = lens _adApplicationVersionId (\ s a -> s{_adApplicationVersionId = a}) . _Nat;++instance FromJSON ApplicationDetail where+        parseJSON+          = withObject "ApplicationDetail"+              (\ x ->+                 ApplicationDetail' <$>+                   (x .:? "ApplicationDescription") <*>+                     (x .:? "OutputDescriptions" .!= mempty)+                     <*>+                     (x .:? "CloudWatchLoggingOptionDescriptions" .!=+                        mempty)+                     <*>+                     (x .:? "ReferenceDataSourceDescriptions" .!= mempty)+                     <*> (x .:? "InputDescriptions" .!= mempty)+                     <*> (x .:? "ApplicationCode")+                     <*> (x .:? "CreateTimestamp")+                     <*> (x .:? "LastUpdateTimestamp")+                     <*> (x .: "ApplicationName")+                     <*> (x .: "ApplicationARN")+                     <*> (x .: "ApplicationStatus")+                     <*> (x .: "ApplicationVersionId"))++instance Hashable ApplicationDetail where++instance NFData ApplicationDetail where++-- | Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.+--+--+--+-- /See:/ 'applicationSummary' smart constructor.+data ApplicationSummary = ApplicationSummary'+  { _asApplicationName   :: !Text+  , _asApplicationARN    :: !Text+  , _asApplicationStatus :: !ApplicationStatus+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+applicationSummary+    :: Text -- ^ 'asApplicationName'+    -> Text -- ^ 'asApplicationARN'+    -> ApplicationStatus -- ^ 'asApplicationStatus'+    -> ApplicationSummary+applicationSummary pApplicationName_ pApplicationARN_ pApplicationStatus_ =+  ApplicationSummary'+  { _asApplicationName = pApplicationName_+  , _asApplicationARN = pApplicationARN_+  , _asApplicationStatus = pApplicationStatus_+  }+++-- | Name of the application.+asApplicationName :: Lens' ApplicationSummary Text+asApplicationName = lens _asApplicationName (\ s a -> s{_asApplicationName = a});++-- | ARN of the application.+asApplicationARN :: Lens' ApplicationSummary Text+asApplicationARN = lens _asApplicationARN (\ s a -> s{_asApplicationARN = a});++-- | Status of the application.+asApplicationStatus :: Lens' ApplicationSummary ApplicationStatus+asApplicationStatus = lens _asApplicationStatus (\ s a -> s{_asApplicationStatus = a});++instance FromJSON ApplicationSummary where+        parseJSON+          = withObject "ApplicationSummary"+              (\ x ->+                 ApplicationSummary' <$>+                   (x .: "ApplicationName") <*> (x .: "ApplicationARN")+                     <*> (x .: "ApplicationStatus"))++instance Hashable ApplicationSummary where++instance NFData ApplicationSummary where++-- | Describes updates to apply to an existing Amazon Kinesis Analytics application.+--+--+--+-- /See:/ 'applicationUpdate' smart constructor.+data ApplicationUpdate = ApplicationUpdate'+  { _auReferenceDataSourceUpdates :: !(Maybe [ReferenceDataSourceUpdate])+  , _auInputUpdates :: !(Maybe [InputUpdate])+  , _auCloudWatchLoggingOptionUpdates :: !(Maybe [CloudWatchLoggingOptionUpdate])+  , _auOutputUpdates :: !(Maybe [OutputUpdate])+  , _auApplicationCodeUpdate :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+applicationUpdate+    :: ApplicationUpdate+applicationUpdate =+  ApplicationUpdate'+  { _auReferenceDataSourceUpdates = Nothing+  , _auInputUpdates = Nothing+  , _auCloudWatchLoggingOptionUpdates = Nothing+  , _auOutputUpdates = Nothing+  , _auApplicationCodeUpdate = Nothing+  }+++-- | Describes application reference data source updates.+auReferenceDataSourceUpdates :: Lens' ApplicationUpdate [ReferenceDataSourceUpdate]+auReferenceDataSourceUpdates = lens _auReferenceDataSourceUpdates (\ s a -> s{_auReferenceDataSourceUpdates = a}) . _Default . _Coerce;++-- | Describes application input configuration updates.+auInputUpdates :: Lens' ApplicationUpdate [InputUpdate]+auInputUpdates = lens _auInputUpdates (\ s a -> s{_auInputUpdates = a}) . _Default . _Coerce;++-- | Describes application CloudWatch logging option updates.+auCloudWatchLoggingOptionUpdates :: Lens' ApplicationUpdate [CloudWatchLoggingOptionUpdate]+auCloudWatchLoggingOptionUpdates = lens _auCloudWatchLoggingOptionUpdates (\ s a -> s{_auCloudWatchLoggingOptionUpdates = a}) . _Default . _Coerce;++-- | Describes application output configuration updates.+auOutputUpdates :: Lens' ApplicationUpdate [OutputUpdate]+auOutputUpdates = lens _auOutputUpdates (\ s a -> s{_auOutputUpdates = a}) . _Default . _Coerce;++-- | Describes application code updates.+auApplicationCodeUpdate :: Lens' ApplicationUpdate (Maybe Text)+auApplicationCodeUpdate = lens _auApplicationCodeUpdate (\ s a -> s{_auApplicationCodeUpdate = a});++instance Hashable ApplicationUpdate where++instance NFData ApplicationUpdate where++instance ToJSON ApplicationUpdate where+        toJSON ApplicationUpdate'{..}+          = object+              (catMaybes+                 [("ReferenceDataSourceUpdates" .=) <$>+                    _auReferenceDataSourceUpdates,+                  ("InputUpdates" .=) <$> _auInputUpdates,+                  ("CloudWatchLoggingOptionUpdates" .=) <$>+                    _auCloudWatchLoggingOptionUpdates,+                  ("OutputUpdates" .=) <$> _auOutputUpdates,+                  ("ApplicationCodeUpdate" .=) <$>+                    _auApplicationCodeUpdate])++-- | 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.+data CSVMappingParameters = CSVMappingParameters'+  { _cmpRecordRowDelimiter    :: !Text+  , _cmpRecordColumnDelimiter :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+csvMappingParameters+    :: Text -- ^ 'cmpRecordRowDelimiter'+    -> Text -- ^ 'cmpRecordColumnDelimiter'+    -> CSVMappingParameters+csvMappingParameters pRecordRowDelimiter_ pRecordColumnDelimiter_ =+  CSVMappingParameters'+  { _cmpRecordRowDelimiter = pRecordRowDelimiter_+  , _cmpRecordColumnDelimiter = pRecordColumnDelimiter_+  }+++-- | Row delimiter. For example, in a CSV format, /'\n'/ is the typical row delimiter.+cmpRecordRowDelimiter :: Lens' CSVMappingParameters Text+cmpRecordRowDelimiter = lens _cmpRecordRowDelimiter (\ s a -> s{_cmpRecordRowDelimiter = a});++-- | Column delimiter. For example, in a CSV format, a comma (",") is the typical column delimiter.+cmpRecordColumnDelimiter :: Lens' CSVMappingParameters Text+cmpRecordColumnDelimiter = lens _cmpRecordColumnDelimiter (\ s a -> s{_cmpRecordColumnDelimiter = a});++instance FromJSON CSVMappingParameters where+        parseJSON+          = withObject "CSVMappingParameters"+              (\ x ->+                 CSVMappingParameters' <$>+                   (x .: "RecordRowDelimiter") <*>+                     (x .: "RecordColumnDelimiter"))++instance Hashable CSVMappingParameters where++instance NFData CSVMappingParameters where++instance ToJSON CSVMappingParameters where+        toJSON CSVMappingParameters'{..}+          = object+              (catMaybes+                 [Just+                    ("RecordRowDelimiter" .= _cmpRecordRowDelimiter),+                  Just+                    ("RecordColumnDelimiter" .=+                       _cmpRecordColumnDelimiter)])++-- | Provides a description of CloudWatch logging options, including the log stream Amazon Resource Name (ARN) and the role ARN.+--+--+--+-- /See:/ 'cloudWatchLoggingOption' smart constructor.+data CloudWatchLoggingOption = CloudWatchLoggingOption'+  { _cwloLogStreamARN :: !Text+  , _cwloRoleARN      :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+cloudWatchLoggingOption+    :: Text -- ^ 'cwloLogStreamARN'+    -> Text -- ^ 'cwloRoleARN'+    -> CloudWatchLoggingOption+cloudWatchLoggingOption pLogStreamARN_ pRoleARN_ =+  CloudWatchLoggingOption'+  {_cwloLogStreamARN = pLogStreamARN_, _cwloRoleARN = pRoleARN_}+++-- | ARN of the CloudWatch log to receive application messages.+cwloLogStreamARN :: Lens' CloudWatchLoggingOption Text+cwloLogStreamARN = lens _cwloLogStreamARN (\ s a -> s{_cwloLogStreamARN = a});++-- | 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.+cwloRoleARN :: Lens' CloudWatchLoggingOption Text+cwloRoleARN = lens _cwloRoleARN (\ s a -> s{_cwloRoleARN = a});++instance Hashable CloudWatchLoggingOption where++instance NFData CloudWatchLoggingOption where++instance ToJSON CloudWatchLoggingOption where+        toJSON CloudWatchLoggingOption'{..}+          = object+              (catMaybes+                 [Just ("LogStreamARN" .= _cwloLogStreamARN),+                  Just ("RoleARN" .= _cwloRoleARN)])++-- | Description of the CloudWatch logging option.+--+--+--+-- /See:/ 'cloudWatchLoggingOptionDescription' smart constructor.+data CloudWatchLoggingOptionDescription = CloudWatchLoggingOptionDescription'+  { _cwlodCloudWatchLoggingOptionId :: !(Maybe Text)+  , _cwlodLogStreamARN              :: !Text+  , _cwlodRoleARN                   :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+cloudWatchLoggingOptionDescription+    :: Text -- ^ 'cwlodLogStreamARN'+    -> Text -- ^ 'cwlodRoleARN'+    -> CloudWatchLoggingOptionDescription+cloudWatchLoggingOptionDescription pLogStreamARN_ pRoleARN_ =+  CloudWatchLoggingOptionDescription'+  { _cwlodCloudWatchLoggingOptionId = Nothing+  , _cwlodLogStreamARN = pLogStreamARN_+  , _cwlodRoleARN = pRoleARN_+  }+++-- | ID of the CloudWatch logging option description.+cwlodCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionDescription (Maybe Text)+cwlodCloudWatchLoggingOptionId = lens _cwlodCloudWatchLoggingOptionId (\ s a -> s{_cwlodCloudWatchLoggingOptionId = a});++-- | ARN of the CloudWatch log to receive application messages.+cwlodLogStreamARN :: Lens' CloudWatchLoggingOptionDescription Text+cwlodLogStreamARN = lens _cwlodLogStreamARN (\ s a -> s{_cwlodLogStreamARN = a});++-- | 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.+cwlodRoleARN :: Lens' CloudWatchLoggingOptionDescription Text+cwlodRoleARN = lens _cwlodRoleARN (\ s a -> s{_cwlodRoleARN = a});++instance FromJSON CloudWatchLoggingOptionDescription+         where+        parseJSON+          = withObject "CloudWatchLoggingOptionDescription"+              (\ x ->+                 CloudWatchLoggingOptionDescription' <$>+                   (x .:? "CloudWatchLoggingOptionId") <*>+                     (x .: "LogStreamARN")+                     <*> (x .: "RoleARN"))++instance Hashable CloudWatchLoggingOptionDescription+         where++instance NFData CloudWatchLoggingOptionDescription+         where++-- | Describes CloudWatch logging option updates.+--+--+--+-- /See:/ 'cloudWatchLoggingOptionUpdate' smart constructor.+data CloudWatchLoggingOptionUpdate = CloudWatchLoggingOptionUpdate'+  { _cwlouRoleARNUpdate             :: !(Maybe Text)+  , _cwlouLogStreamARNUpdate        :: !(Maybe Text)+  , _cwlouCloudWatchLoggingOptionId :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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+cloudWatchLoggingOptionUpdate+    :: Text -- ^ 'cwlouCloudWatchLoggingOptionId'+    -> CloudWatchLoggingOptionUpdate+cloudWatchLoggingOptionUpdate pCloudWatchLoggingOptionId_ =+  CloudWatchLoggingOptionUpdate'+  { _cwlouRoleARNUpdate = Nothing+  , _cwlouLogStreamARNUpdate = Nothing+  , _cwlouCloudWatchLoggingOptionId = pCloudWatchLoggingOptionId_+  }+++-- | 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.+cwlouRoleARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text)+cwlouRoleARNUpdate = lens _cwlouRoleARNUpdate (\ s a -> s{_cwlouRoleARNUpdate = a});++-- | ARN of the CloudWatch log to receive application messages.+cwlouLogStreamARNUpdate :: Lens' CloudWatchLoggingOptionUpdate (Maybe Text)+cwlouLogStreamARNUpdate = lens _cwlouLogStreamARNUpdate (\ s a -> s{_cwlouLogStreamARNUpdate = a});++-- | ID of the CloudWatch logging option to update+cwlouCloudWatchLoggingOptionId :: Lens' CloudWatchLoggingOptionUpdate Text+cwlouCloudWatchLoggingOptionId = lens _cwlouCloudWatchLoggingOptionId (\ s a -> s{_cwlouCloudWatchLoggingOptionId = a});++instance Hashable CloudWatchLoggingOptionUpdate where++instance NFData CloudWatchLoggingOptionUpdate where++instance ToJSON CloudWatchLoggingOptionUpdate where+        toJSON CloudWatchLoggingOptionUpdate'{..}+          = object+              (catMaybes+                 [("RoleARNUpdate" .=) <$> _cwlouRoleARNUpdate,+                  ("LogStreamARNUpdate" .=) <$>+                    _cwlouLogStreamARNUpdate,+                  Just+                    ("CloudWatchLoggingOptionId" .=+                       _cwlouCloudWatchLoggingOptionId)])++-- | Describes the data format when records are written to the destination. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html Configuring Application Output> .+--+--+--+-- /See:/ 'destinationSchema' smart constructor.+newtype DestinationSchema = DestinationSchema'+  { _dsRecordFormatType :: Maybe RecordFormatType+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+destinationSchema+    :: DestinationSchema+destinationSchema = DestinationSchema' {_dsRecordFormatType = Nothing}+++-- | Specifies the format of the records on the output stream.+dsRecordFormatType :: Lens' DestinationSchema (Maybe RecordFormatType)+dsRecordFormatType = lens _dsRecordFormatType (\ s a -> s{_dsRecordFormatType = a});++instance FromJSON DestinationSchema where+        parseJSON+          = withObject "DestinationSchema"+              (\ x ->+                 DestinationSchema' <$> (x .:? "RecordFormatType"))++instance Hashable DestinationSchema where++instance NFData DestinationSchema where++instance ToJSON DestinationSchema where+        toJSON DestinationSchema'{..}+          = object+              (catMaybes+                 [("RecordFormatType" .=) <$> _dsRecordFormatType])++-- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .+--+--+--+-- /See:/ 'input' smart constructor.+data Input = Input'+  { _iInputParallelism             :: !(Maybe InputParallelism)+  , _iInputProcessingConfiguration :: !(Maybe InputProcessingConfiguration)+  , _iKinesisStreamsInput          :: !(Maybe KinesisStreamsInput)+  , _iKinesisFirehoseInput         :: !(Maybe KinesisFirehoseInput)+  , _iNamePrefix                   :: !Text+  , _iInputSchema                  :: !SourceSchema+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html 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.+input+    :: Text -- ^ 'iNamePrefix'+    -> SourceSchema -- ^ 'iInputSchema'+    -> Input+input pNamePrefix_ pInputSchema_ =+  Input'+  { _iInputParallelism = Nothing+  , _iInputProcessingConfiguration = Nothing+  , _iKinesisStreamsInput = Nothing+  , _iKinesisFirehoseInput = Nothing+  , _iNamePrefix = pNamePrefix_+  , _iInputSchema = pInputSchema_+  }+++-- | Describes the number of in-application streams to create.  Data from your source will be routed to these in-application input streams. (see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .+iInputParallelism :: Lens' Input (Maybe InputParallelism)+iInputParallelism = lens _iInputParallelism (\ s a -> s{_iInputParallelism = a});++-- | 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' .+iInputProcessingConfiguration :: Lens' Input (Maybe InputProcessingConfiguration)+iInputProcessingConfiguration = lens _iInputProcessingConfiguration (\ s a -> s{_iInputProcessingConfiguration = a});++-- | 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.+iKinesisStreamsInput :: Lens' Input (Maybe KinesisStreamsInput)+iKinesisStreamsInput = lens _iKinesisStreamsInput (\ s a -> s{_iKinesisStreamsInput = a});++-- | 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.+iKinesisFirehoseInput :: Lens' Input (Maybe KinesisFirehoseInput)+iKinesisFirehoseInput = lens _iKinesisFirehoseInput (\ s a -> s{_iKinesisFirehoseInput = a});++-- | 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.+iNamePrefix :: Lens' Input Text+iNamePrefix = lens _iNamePrefix (\ s a -> s{_iNamePrefix = a});++-- | 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.+iInputSchema :: Lens' Input SourceSchema+iInputSchema = lens _iInputSchema (\ s a -> s{_iInputSchema = a});++instance Hashable Input where++instance NFData Input where++instance ToJSON Input where+        toJSON Input'{..}+          = object+              (catMaybes+                 [("InputParallelism" .=) <$> _iInputParallelism,+                  ("InputProcessingConfiguration" .=) <$>+                    _iInputProcessingConfiguration,+                  ("KinesisStreamsInput" .=) <$> _iKinesisStreamsInput,+                  ("KinesisFirehoseInput" .=) <$>+                    _iKinesisFirehoseInput,+                  Just ("NamePrefix" .= _iNamePrefix),+                  Just ("InputSchema" .= _iInputSchema)])++-- | 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.+data InputConfiguration = InputConfiguration'+  { _icId                                 :: !Text+  , _icInputStartingPositionConfiguration :: !InputStartingPositionConfiguration+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+inputConfiguration+    :: Text -- ^ 'icId'+    -> InputStartingPositionConfiguration -- ^ 'icInputStartingPositionConfiguration'+    -> InputConfiguration+inputConfiguration pId_ pInputStartingPositionConfiguration_ =+  InputConfiguration'+  { _icId = pId_+  , _icInputStartingPositionConfiguration = pInputStartingPositionConfiguration_+  }+++-- | Input source ID. You can get this ID by calling the 'DescribeApplication' operation.+icId :: Lens' InputConfiguration Text+icId = lens _icId (\ s a -> s{_icId = a});++-- | Point at which you want the application to start processing records from the streaming source.+icInputStartingPositionConfiguration :: Lens' InputConfiguration InputStartingPositionConfiguration+icInputStartingPositionConfiguration = lens _icInputStartingPositionConfiguration (\ s a -> s{_icInputStartingPositionConfiguration = a});++instance Hashable InputConfiguration where++instance NFData InputConfiguration where++instance ToJSON InputConfiguration where+        toJSON InputConfiguration'{..}+          = object+              (catMaybes+                 [Just ("Id" .= _icId),+                  Just+                    ("InputStartingPositionConfiguration" .=+                       _icInputStartingPositionConfiguration)])++-- | Describes the application input configuration. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .+--+--+--+-- /See:/ 'inputDescription' smart constructor.+data InputDescription = InputDescription'+  { _idInputStartingPositionConfiguration :: !(Maybe InputStartingPositionConfiguration)+  , _idInputParallelism :: !(Maybe InputParallelism)+  , _idInputId :: !(Maybe Text)+  , _idInAppStreamNames :: !(Maybe [Text])+  , _idKinesisFirehoseInputDescription :: !(Maybe KinesisFirehoseInputDescription)+  , _idInputSchema :: !(Maybe SourceSchema)+  , _idKinesisStreamsInputDescription :: !(Maybe KinesisStreamsInputDescription)+  , _idNamePrefix :: !(Maybe Text)+  , _idInputProcessingConfigurationDescription :: !(Maybe InputProcessingConfigurationDescription)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+inputDescription+    :: InputDescription+inputDescription =+  InputDescription'+  { _idInputStartingPositionConfiguration = Nothing+  , _idInputParallelism = Nothing+  , _idInputId = Nothing+  , _idInAppStreamNames = Nothing+  , _idKinesisFirehoseInputDescription = Nothing+  , _idInputSchema = Nothing+  , _idKinesisStreamsInputDescription = Nothing+  , _idNamePrefix = Nothing+  , _idInputProcessingConfigurationDescription = Nothing+  }+++-- | Point at which the application is configured to read from the input stream.+idInputStartingPositionConfiguration :: Lens' InputDescription (Maybe InputStartingPositionConfiguration)+idInputStartingPositionConfiguration = lens _idInputStartingPositionConfiguration (\ s a -> s{_idInputStartingPositionConfiguration = a});++-- | Describes the configured parallelism (number of in-application streams mapped to the streaming source).+idInputParallelism :: Lens' InputDescription (Maybe InputParallelism)+idInputParallelism = lens _idInputParallelism (\ s a -> s{_idInputParallelism = a});++-- | 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.+idInputId :: Lens' InputDescription (Maybe Text)+idInputId = lens _idInputId (\ s a -> s{_idInputId = a});++-- | Returns the in-application stream names that are mapped to the stream source.+idInAppStreamNames :: Lens' InputDescription [Text]+idInAppStreamNames = lens _idInAppStreamNames (\ s a -> s{_idInAppStreamNames = a}) . _Default . _Coerce;++-- | 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.+idKinesisFirehoseInputDescription :: Lens' InputDescription (Maybe KinesisFirehoseInputDescription)+idKinesisFirehoseInputDescription = lens _idKinesisFirehoseInputDescription (\ s a -> s{_idKinesisFirehoseInputDescription = a});++-- | 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.+idInputSchema :: Lens' InputDescription (Maybe SourceSchema)+idInputSchema = lens _idInputSchema (\ s a -> s{_idInputSchema = a});++-- | 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.+idKinesisStreamsInputDescription :: Lens' InputDescription (Maybe KinesisStreamsInputDescription)+idKinesisStreamsInputDescription = lens _idKinesisStreamsInputDescription (\ s a -> s{_idKinesisStreamsInputDescription = a});++-- | In-application name prefix.+idNamePrefix :: Lens' InputDescription (Maybe Text)+idNamePrefix = lens _idNamePrefix (\ s a -> s{_idNamePrefix = a});++-- | The description of the preprocessor that executes on records in this input before the application's code is run.+idInputProcessingConfigurationDescription :: Lens' InputDescription (Maybe InputProcessingConfigurationDescription)+idInputProcessingConfigurationDescription = lens _idInputProcessingConfigurationDescription (\ s a -> s{_idInputProcessingConfigurationDescription = a});++instance FromJSON InputDescription where+        parseJSON+          = withObject "InputDescription"+              (\ x ->+                 InputDescription' <$>+                   (x .:? "InputStartingPositionConfiguration") <*>+                     (x .:? "InputParallelism")+                     <*> (x .:? "InputId")+                     <*> (x .:? "InAppStreamNames" .!= mempty)+                     <*> (x .:? "KinesisFirehoseInputDescription")+                     <*> (x .:? "InputSchema")+                     <*> (x .:? "KinesisStreamsInputDescription")+                     <*> (x .:? "NamePrefix")+                     <*>+                     (x .:? "InputProcessingConfigurationDescription"))++instance Hashable InputDescription where++instance NFData InputDescription where++-- | An object that contains the ARN of the <https://aws.amazon.com/documentation/lambda/ 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.+data InputLambdaProcessor = InputLambdaProcessor'+  { _ilpResourceARN :: !Text+  , _ilpRoleARN     :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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 <https://aws.amazon.com/documentation/lambda/ AWS Lambda> function that operates on records in the stream.+--+-- * 'ilpRoleARN' - The ARN of the IAM role used to access the AWS Lambda function.+inputLambdaProcessor+    :: Text -- ^ 'ilpResourceARN'+    -> Text -- ^ 'ilpRoleARN'+    -> InputLambdaProcessor+inputLambdaProcessor pResourceARN_ pRoleARN_ =+  InputLambdaProcessor'+  {_ilpResourceARN = pResourceARN_, _ilpRoleARN = pRoleARN_}+++-- | The ARN of the <https://aws.amazon.com/documentation/lambda/ AWS Lambda> function that operates on records in the stream.+ilpResourceARN :: Lens' InputLambdaProcessor Text+ilpResourceARN = lens _ilpResourceARN (\ s a -> s{_ilpResourceARN = a});++-- | The ARN of the IAM role used to access the AWS Lambda function.+ilpRoleARN :: Lens' InputLambdaProcessor Text+ilpRoleARN = lens _ilpRoleARN (\ s a -> s{_ilpRoleARN = a});++instance Hashable InputLambdaProcessor where++instance NFData InputLambdaProcessor where++instance ToJSON InputLambdaProcessor where+        toJSON InputLambdaProcessor'{..}+          = object+              (catMaybes+                 [Just ("ResourceARN" .= _ilpResourceARN),+                  Just ("RoleARN" .= _ilpRoleARN)])++-- | An object that contains the ARN of the <https://aws.amazon.com/documentation/lambda/ 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.+data InputLambdaProcessorDescription = InputLambdaProcessorDescription'+  { _ilpdResourceARN :: !(Maybe Text)+  , _ilpdRoleARN     :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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 <https://aws.amazon.com/documentation/lambda/ 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.+inputLambdaProcessorDescription+    :: InputLambdaProcessorDescription+inputLambdaProcessorDescription =+  InputLambdaProcessorDescription'+  {_ilpdResourceARN = Nothing, _ilpdRoleARN = Nothing}+++-- | The ARN of the <https://aws.amazon.com/documentation/lambda/ AWS Lambda> function that is used to preprocess the records in the stream.+ilpdResourceARN :: Lens' InputLambdaProcessorDescription (Maybe Text)+ilpdResourceARN = lens _ilpdResourceARN (\ s a -> s{_ilpdResourceARN = a});++-- | The ARN of the IAM role used to access the AWS Lambda function.+ilpdRoleARN :: Lens' InputLambdaProcessorDescription (Maybe Text)+ilpdRoleARN = lens _ilpdRoleARN (\ s a -> s{_ilpdRoleARN = a});++instance FromJSON InputLambdaProcessorDescription+         where+        parseJSON+          = withObject "InputLambdaProcessorDescription"+              (\ x ->+                 InputLambdaProcessorDescription' <$>+                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))++instance Hashable InputLambdaProcessorDescription+         where++instance NFData InputLambdaProcessorDescription where++-- | Represents an update to the 'InputLambdaProcessor' that is used to preprocess the records in the stream.+--+--+--+-- /See:/ 'inputLambdaProcessorUpdate' smart constructor.+data InputLambdaProcessorUpdate = InputLambdaProcessorUpdate'+  { _ilpuRoleARNUpdate     :: !(Maybe Text)+  , _ilpuResourceARNUpdate :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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 <https://aws.amazon.com/documentation/lambda/ AWS Lambda> function that is used to preprocess the records in the stream.+inputLambdaProcessorUpdate+    :: InputLambdaProcessorUpdate+inputLambdaProcessorUpdate =+  InputLambdaProcessorUpdate'+  {_ilpuRoleARNUpdate = Nothing, _ilpuResourceARNUpdate = Nothing}+++-- | The ARN of the new IAM role used to access the AWS Lambda function.+ilpuRoleARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)+ilpuRoleARNUpdate = lens _ilpuRoleARNUpdate (\ s a -> s{_ilpuRoleARNUpdate = a});++-- | The ARN of the new <https://aws.amazon.com/documentation/lambda/ AWS Lambda> function that is used to preprocess the records in the stream.+ilpuResourceARNUpdate :: Lens' InputLambdaProcessorUpdate (Maybe Text)+ilpuResourceARNUpdate = lens _ilpuResourceARNUpdate (\ s a -> s{_ilpuResourceARNUpdate = a});++instance Hashable InputLambdaProcessorUpdate where++instance NFData InputLambdaProcessorUpdate where++instance ToJSON InputLambdaProcessorUpdate where+        toJSON InputLambdaProcessorUpdate'{..}+          = object+              (catMaybes+                 [("RoleARNUpdate" .=) <$> _ilpuRoleARNUpdate,+                  ("ResourceARNUpdate" .=) <$> _ilpuResourceARNUpdate])++-- | Describes the number of in-application streams to create for a given streaming source. For information about parallelism, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html Configuring Application Input> .+--+--+--+-- /See:/ 'inputParallelism' smart constructor.+newtype InputParallelism = InputParallelism'+  { _ipCount :: Maybe Nat+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html Limits> .+inputParallelism+    :: InputParallelism+inputParallelism = InputParallelism' {_ipCount = Nothing}+++-- | Number of in-application streams to create. For more information, see <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html Limits> .+ipCount :: Lens' InputParallelism (Maybe Natural)+ipCount = lens _ipCount (\ s a -> s{_ipCount = a}) . mapping _Nat;++instance FromJSON InputParallelism where+        parseJSON+          = withObject "InputParallelism"+              (\ x -> InputParallelism' <$> (x .:? "Count"))++instance Hashable InputParallelism where++instance NFData InputParallelism where++instance ToJSON InputParallelism where+        toJSON InputParallelism'{..}+          = object (catMaybes [("Count" .=) <$> _ipCount])++-- | Provides updates to the parallelism count.+--+--+--+-- /See:/ 'inputParallelismUpdate' smart constructor.+newtype InputParallelismUpdate = InputParallelismUpdate'+  { _ipuCountUpdate :: Maybe Nat+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+inputParallelismUpdate+    :: InputParallelismUpdate+inputParallelismUpdate = InputParallelismUpdate' {_ipuCountUpdate = Nothing}+++-- | Number of in-application streams to create for the specified streaming source.+ipuCountUpdate :: Lens' InputParallelismUpdate (Maybe Natural)+ipuCountUpdate = lens _ipuCountUpdate (\ s a -> s{_ipuCountUpdate = a}) . mapping _Nat;++instance Hashable InputParallelismUpdate where++instance NFData InputParallelismUpdate where++instance ToJSON InputParallelismUpdate where+        toJSON InputParallelismUpdate'{..}+          = object+              (catMaybes [("CountUpdate" .=) <$> _ipuCountUpdate])++-- | 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 <https://aws.amazon.com/documentation/lambda/ AWS Lambda> .+--+--+--+-- /See:/ 'inputProcessingConfiguration' smart constructor.+newtype InputProcessingConfiguration = InputProcessingConfiguration'+  { _ipcInputLambdaProcessor :: InputLambdaProcessor+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+inputProcessingConfiguration+    :: InputLambdaProcessor -- ^ 'ipcInputLambdaProcessor'+    -> InputProcessingConfiguration+inputProcessingConfiguration pInputLambdaProcessor_ =+  InputProcessingConfiguration'+  {_ipcInputLambdaProcessor = pInputLambdaProcessor_}+++-- | The 'InputLambdaProcessor' that is used to preprocess the records in the stream prior to being processed by your application code.+ipcInputLambdaProcessor :: Lens' InputProcessingConfiguration InputLambdaProcessor+ipcInputLambdaProcessor = lens _ipcInputLambdaProcessor (\ s a -> s{_ipcInputLambdaProcessor = a});++instance Hashable InputProcessingConfiguration where++instance NFData InputProcessingConfiguration where++instance ToJSON InputProcessingConfiguration where+        toJSON InputProcessingConfiguration'{..}+          = object+              (catMaybes+                 [Just+                    ("InputLambdaProcessor" .=+                       _ipcInputLambdaProcessor)])++-- | Provides configuration information about an input processor. Currently, the only input processor available is <https://aws.amazon.com/documentation/lambda/ AWS Lambda> .+--+--+--+-- /See:/ 'inputProcessingConfigurationDescription' smart constructor.+newtype InputProcessingConfigurationDescription = InputProcessingConfigurationDescription'+  { _ipcdInputLambdaProcessorDescription :: Maybe InputLambdaProcessorDescription+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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' .+inputProcessingConfigurationDescription+    :: InputProcessingConfigurationDescription+inputProcessingConfigurationDescription =+  InputProcessingConfigurationDescription'+  {_ipcdInputLambdaProcessorDescription = Nothing}+++-- | Provides configuration information about the associated 'InputLambdaProcessorDescription' .+ipcdInputLambdaProcessorDescription :: Lens' InputProcessingConfigurationDescription (Maybe InputLambdaProcessorDescription)+ipcdInputLambdaProcessorDescription = lens _ipcdInputLambdaProcessorDescription (\ s a -> s{_ipcdInputLambdaProcessorDescription = a});++instance FromJSON+           InputProcessingConfigurationDescription+         where+        parseJSON+          = withObject+              "InputProcessingConfigurationDescription"+              (\ x ->+                 InputProcessingConfigurationDescription' <$>+                   (x .:? "InputLambdaProcessorDescription"))++instance Hashable+           InputProcessingConfigurationDescription+         where++instance NFData+           InputProcessingConfigurationDescription+         where++-- | Describes updates to an 'InputProcessingConfiguration' .+--+--+--+-- /See:/ 'inputProcessingConfigurationUpdate' smart constructor.+newtype InputProcessingConfigurationUpdate = InputProcessingConfigurationUpdate'+  { _ipcuInputLambdaProcessorUpdate :: InputLambdaProcessorUpdate+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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' .+inputProcessingConfigurationUpdate+    :: InputLambdaProcessorUpdate -- ^ 'ipcuInputLambdaProcessorUpdate'+    -> InputProcessingConfigurationUpdate+inputProcessingConfigurationUpdate pInputLambdaProcessorUpdate_ =+  InputProcessingConfigurationUpdate'+  {_ipcuInputLambdaProcessorUpdate = pInputLambdaProcessorUpdate_}+++-- | Provides update information for an 'InputLambdaProcessor' .+ipcuInputLambdaProcessorUpdate :: Lens' InputProcessingConfigurationUpdate InputLambdaProcessorUpdate+ipcuInputLambdaProcessorUpdate = lens _ipcuInputLambdaProcessorUpdate (\ s a -> s{_ipcuInputLambdaProcessorUpdate = a});++instance Hashable InputProcessingConfigurationUpdate+         where++instance NFData InputProcessingConfigurationUpdate+         where++instance ToJSON InputProcessingConfigurationUpdate+         where+        toJSON InputProcessingConfigurationUpdate'{..}+          = object+              (catMaybes+                 [Just+                    ("InputLambdaProcessorUpdate" .=+                       _ipcuInputLambdaProcessorUpdate)])++-- | Describes updates for the application's input schema.+--+--+--+-- /See:/ 'inputSchemaUpdate' smart constructor.+data InputSchemaUpdate = InputSchemaUpdate'+  { _isuRecordFormatUpdate   :: !(Maybe RecordFormat)+  , _isuRecordEncodingUpdate :: !(Maybe Text)+  , _isuRecordColumnUpdates  :: !(Maybe (List1 RecordColumn))+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+inputSchemaUpdate+    :: InputSchemaUpdate+inputSchemaUpdate =+  InputSchemaUpdate'+  { _isuRecordFormatUpdate = Nothing+  , _isuRecordEncodingUpdate = Nothing+  , _isuRecordColumnUpdates = Nothing+  }+++-- | Specifies the format of the records on the streaming source.+isuRecordFormatUpdate :: Lens' InputSchemaUpdate (Maybe RecordFormat)+isuRecordFormatUpdate = lens _isuRecordFormatUpdate (\ s a -> s{_isuRecordFormatUpdate = a});++-- | Specifies the encoding of the records in the streaming source. For example, UTF-8.+isuRecordEncodingUpdate :: Lens' InputSchemaUpdate (Maybe Text)+isuRecordEncodingUpdate = lens _isuRecordEncodingUpdate (\ s a -> s{_isuRecordEncodingUpdate = a});++-- | A list of @RecordColumn@ objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.+isuRecordColumnUpdates :: Lens' InputSchemaUpdate (Maybe (NonEmpty RecordColumn))+isuRecordColumnUpdates = lens _isuRecordColumnUpdates (\ s a -> s{_isuRecordColumnUpdates = a}) . mapping _List1;++instance Hashable InputSchemaUpdate where++instance NFData InputSchemaUpdate where++instance ToJSON InputSchemaUpdate where+        toJSON InputSchemaUpdate'{..}+          = object+              (catMaybes+                 [("RecordFormatUpdate" .=) <$>+                    _isuRecordFormatUpdate,+                  ("RecordEncodingUpdate" .=) <$>+                    _isuRecordEncodingUpdate,+                  ("RecordColumnUpdates" .=) <$>+                    _isuRecordColumnUpdates])++-- | Describes the point at which the application reads from the streaming source.+--+--+--+-- /See:/ 'inputStartingPositionConfiguration' smart constructor.+newtype InputStartingPositionConfiguration = InputStartingPositionConfiguration'+  { _ispcInputStartingPosition :: Maybe InputStartingPosition+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+inputStartingPositionConfiguration+    :: InputStartingPositionConfiguration+inputStartingPositionConfiguration =+  InputStartingPositionConfiguration' {_ispcInputStartingPosition = Nothing}+++-- | 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)+ispcInputStartingPosition = lens _ispcInputStartingPosition (\ s a -> s{_ispcInputStartingPosition = a});++instance FromJSON InputStartingPositionConfiguration+         where+        parseJSON+          = withObject "InputStartingPositionConfiguration"+              (\ x ->+                 InputStartingPositionConfiguration' <$>+                   (x .:? "InputStartingPosition"))++instance Hashable InputStartingPositionConfiguration+         where++instance NFData InputStartingPositionConfiguration+         where++instance ToJSON InputStartingPositionConfiguration+         where+        toJSON InputStartingPositionConfiguration'{..}+          = object+              (catMaybes+                 [("InputStartingPosition" .=) <$>+                    _ispcInputStartingPosition])++-- | Describes updates to a specific input configuration (identified by the @InputId@ of an application).+--+--+--+-- /See:/ 'inputUpdate' smart constructor.+data InputUpdate = InputUpdate'+  { _iuInputProcessingConfigurationUpdate :: !(Maybe InputProcessingConfigurationUpdate)+  , _iuKinesisStreamsInputUpdate :: !(Maybe KinesisStreamsInputUpdate)+  , _iuInputParallelismUpdate :: !(Maybe InputParallelismUpdate)+  , _iuNamePrefixUpdate :: !(Maybe Text)+  , _iuInputSchemaUpdate :: !(Maybe InputSchemaUpdate)+  , _iuKinesisFirehoseInputUpdate :: !(Maybe KinesisFirehoseInputUpdate)+  , _iuInputId :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+inputUpdate+    :: Text -- ^ 'iuInputId'+    -> InputUpdate+inputUpdate pInputId_ =+  InputUpdate'+  { _iuInputProcessingConfigurationUpdate = Nothing+  , _iuKinesisStreamsInputUpdate = Nothing+  , _iuInputParallelismUpdate = Nothing+  , _iuNamePrefixUpdate = Nothing+  , _iuInputSchemaUpdate = Nothing+  , _iuKinesisFirehoseInputUpdate = Nothing+  , _iuInputId = pInputId_+  }+++-- | Describes updates for an input processing configuration.+iuInputProcessingConfigurationUpdate :: Lens' InputUpdate (Maybe InputProcessingConfigurationUpdate)+iuInputProcessingConfigurationUpdate = lens _iuInputProcessingConfigurationUpdate (\ s a -> s{_iuInputProcessingConfigurationUpdate = a});++-- | If a Amazon Kinesis stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.+iuKinesisStreamsInputUpdate :: Lens' InputUpdate (Maybe KinesisStreamsInputUpdate)+iuKinesisStreamsInputUpdate = lens _iuKinesisStreamsInputUpdate (\ s a -> s{_iuKinesisStreamsInputUpdate = a});++-- | Describes the parallelism updates (the number in-application streams Amazon Kinesis Analytics creates for the specific streaming source).+iuInputParallelismUpdate :: Lens' InputUpdate (Maybe InputParallelismUpdate)+iuInputParallelismUpdate = lens _iuInputParallelismUpdate (\ s a -> s{_iuInputParallelismUpdate = a});++-- | Name prefix for in-application streams that Amazon Kinesis Analytics creates for the specific streaming source.+iuNamePrefixUpdate :: Lens' InputUpdate (Maybe Text)+iuNamePrefixUpdate = lens _iuNamePrefixUpdate (\ s a -> s{_iuNamePrefixUpdate = a});++-- | 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.+iuInputSchemaUpdate :: Lens' InputUpdate (Maybe InputSchemaUpdate)+iuInputSchemaUpdate = lens _iuInputSchemaUpdate (\ s a -> s{_iuInputSchemaUpdate = a});++-- | 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.+iuKinesisFirehoseInputUpdate :: Lens' InputUpdate (Maybe KinesisFirehoseInputUpdate)+iuKinesisFirehoseInputUpdate = lens _iuKinesisFirehoseInputUpdate (\ s a -> s{_iuKinesisFirehoseInputUpdate = a});++-- | Input ID of the application input to be updated.+iuInputId :: Lens' InputUpdate Text+iuInputId = lens _iuInputId (\ s a -> s{_iuInputId = a});++instance Hashable InputUpdate where++instance NFData InputUpdate where++instance ToJSON InputUpdate where+        toJSON InputUpdate'{..}+          = object+              (catMaybes+                 [("InputProcessingConfigurationUpdate" .=) <$>+                    _iuInputProcessingConfigurationUpdate,+                  ("KinesisStreamsInputUpdate" .=) <$>+                    _iuKinesisStreamsInputUpdate,+                  ("InputParallelismUpdate" .=) <$>+                    _iuInputParallelismUpdate,+                  ("NamePrefixUpdate" .=) <$> _iuNamePrefixUpdate,+                  ("InputSchemaUpdate" .=) <$> _iuInputSchemaUpdate,+                  ("KinesisFirehoseInputUpdate" .=) <$>+                    _iuKinesisFirehoseInputUpdate,+                  Just ("InputId" .= _iuInputId)])++-- | Provides additional mapping information when JSON is the record format on the streaming source.+--+--+--+-- /See:/ 'jsonMappingParameters' smart constructor.+newtype JSONMappingParameters = JSONMappingParameters'+  { _jmpRecordRowPath :: Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+jsonMappingParameters+    :: Text -- ^ 'jmpRecordRowPath'+    -> JSONMappingParameters+jsonMappingParameters pRecordRowPath_ =+  JSONMappingParameters' {_jmpRecordRowPath = pRecordRowPath_}+++-- | Path to the top-level parent that contains the records.+jmpRecordRowPath :: Lens' JSONMappingParameters Text+jmpRecordRowPath = lens _jmpRecordRowPath (\ s a -> s{_jmpRecordRowPath = a});++instance FromJSON JSONMappingParameters where+        parseJSON+          = withObject "JSONMappingParameters"+              (\ x ->+                 JSONMappingParameters' <$> (x .: "RecordRowPath"))++instance Hashable JSONMappingParameters where++instance NFData JSONMappingParameters where++instance ToJSON JSONMappingParameters where+        toJSON JSONMappingParameters'{..}+          = object+              (catMaybes+                 [Just ("RecordRowPath" .= _jmpRecordRowPath)])++-- | 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.+data KinesisFirehoseInput = KinesisFirehoseInput'+  { _kfiResourceARN :: !Text+  , _kfiRoleARN     :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisFirehoseInput+    :: Text -- ^ 'kfiResourceARN'+    -> Text -- ^ 'kfiRoleARN'+    -> KinesisFirehoseInput+kinesisFirehoseInput pResourceARN_ pRoleARN_ =+  KinesisFirehoseInput'+  {_kfiResourceARN = pResourceARN_, _kfiRoleARN = pRoleARN_}+++-- | ARN of the input Firehose delivery stream.+kfiResourceARN :: Lens' KinesisFirehoseInput Text+kfiResourceARN = lens _kfiResourceARN (\ s a -> s{_kfiResourceARN = a});++-- | 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.+kfiRoleARN :: Lens' KinesisFirehoseInput Text+kfiRoleARN = lens _kfiRoleARN (\ s a -> s{_kfiRoleARN = a});++instance Hashable KinesisFirehoseInput where++instance NFData KinesisFirehoseInput where++instance ToJSON KinesisFirehoseInput where+        toJSON KinesisFirehoseInput'{..}+          = object+              (catMaybes+                 [Just ("ResourceARN" .= _kfiResourceARN),+                  Just ("RoleARN" .= _kfiRoleARN)])++-- | Describes the Amazon Kinesis Firehose delivery stream that is configured as the streaming source in the application input configuration.+--+--+--+-- /See:/ 'kinesisFirehoseInputDescription' smart constructor.+data KinesisFirehoseInputDescription = KinesisFirehoseInputDescription'+  { _kfidResourceARN :: !(Maybe Text)+  , _kfidRoleARN     :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisFirehoseInputDescription+    :: KinesisFirehoseInputDescription+kinesisFirehoseInputDescription =+  KinesisFirehoseInputDescription'+  {_kfidResourceARN = Nothing, _kfidRoleARN = Nothing}+++-- | Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.+kfidResourceARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)+kfidResourceARN = lens _kfidResourceARN (\ s a -> s{_kfidResourceARN = a});++-- | ARN of the IAM role that Amazon Kinesis Analytics assumes to access the stream.+kfidRoleARN :: Lens' KinesisFirehoseInputDescription (Maybe Text)+kfidRoleARN = lens _kfidRoleARN (\ s a -> s{_kfidRoleARN = a});++instance FromJSON KinesisFirehoseInputDescription+         where+        parseJSON+          = withObject "KinesisFirehoseInputDescription"+              (\ x ->+                 KinesisFirehoseInputDescription' <$>+                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))++instance Hashable KinesisFirehoseInputDescription+         where++instance NFData KinesisFirehoseInputDescription where++-- | When updating application input configuration, provides information about an Amazon Kinesis Firehose delivery stream as the streaming source.+--+--+--+-- /See:/ 'kinesisFirehoseInputUpdate' smart constructor.+data KinesisFirehoseInputUpdate = KinesisFirehoseInputUpdate'+  { _kfiuRoleARNUpdate     :: !(Maybe Text)+  , _kfiuResourceARNUpdate :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisFirehoseInputUpdate+    :: KinesisFirehoseInputUpdate+kinesisFirehoseInputUpdate =+  KinesisFirehoseInputUpdate'+  {_kfiuRoleARNUpdate = Nothing, _kfiuResourceARNUpdate = Nothing}+++-- | 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.+kfiuRoleARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)+kfiuRoleARNUpdate = lens _kfiuRoleARNUpdate (\ s a -> s{_kfiuRoleARNUpdate = a});++-- | ARN of the input Amazon Kinesis Firehose delivery stream to read.+kfiuResourceARNUpdate :: Lens' KinesisFirehoseInputUpdate (Maybe Text)+kfiuResourceARNUpdate = lens _kfiuResourceARNUpdate (\ s a -> s{_kfiuResourceARNUpdate = a});++instance Hashable KinesisFirehoseInputUpdate where++instance NFData KinesisFirehoseInputUpdate where++instance ToJSON KinesisFirehoseInputUpdate where+        toJSON KinesisFirehoseInputUpdate'{..}+          = object+              (catMaybes+                 [("RoleARNUpdate" .=) <$> _kfiuRoleARNUpdate,+                  ("ResourceARNUpdate" .=) <$> _kfiuResourceARNUpdate])++-- | 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.+data KinesisFirehoseOutput = KinesisFirehoseOutput'+  { _kfoResourceARN :: !Text+  , _kfoRoleARN     :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisFirehoseOutput+    :: Text -- ^ 'kfoResourceARN'+    -> Text -- ^ 'kfoRoleARN'+    -> KinesisFirehoseOutput+kinesisFirehoseOutput pResourceARN_ pRoleARN_ =+  KinesisFirehoseOutput'+  {_kfoResourceARN = pResourceARN_, _kfoRoleARN = pRoleARN_}+++-- | ARN of the destination Amazon Kinesis Firehose delivery stream to write to.+kfoResourceARN :: Lens' KinesisFirehoseOutput Text+kfoResourceARN = lens _kfoResourceARN (\ s a -> s{_kfoResourceARN = a});++-- | 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.+kfoRoleARN :: Lens' KinesisFirehoseOutput Text+kfoRoleARN = lens _kfoRoleARN (\ s a -> s{_kfoRoleARN = a});++instance Hashable KinesisFirehoseOutput where++instance NFData KinesisFirehoseOutput where++instance ToJSON KinesisFirehoseOutput where+        toJSON KinesisFirehoseOutput'{..}+          = object+              (catMaybes+                 [Just ("ResourceARN" .= _kfoResourceARN),+                  Just ("RoleARN" .= _kfoRoleARN)])++-- | For an application output, describes the Amazon Kinesis Firehose delivery stream configured as its destination.+--+--+--+-- /See:/ 'kinesisFirehoseOutputDescription' smart constructor.+data KinesisFirehoseOutputDescription = KinesisFirehoseOutputDescription'+  { _kfodResourceARN :: !(Maybe Text)+  , _kfodRoleARN     :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisFirehoseOutputDescription+    :: KinesisFirehoseOutputDescription+kinesisFirehoseOutputDescription =+  KinesisFirehoseOutputDescription'+  {_kfodResourceARN = Nothing, _kfodRoleARN = Nothing}+++-- | Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream.+kfodResourceARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)+kfodResourceARN = lens _kfodResourceARN (\ s a -> s{_kfodResourceARN = a});++-- | ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.+kfodRoleARN :: Lens' KinesisFirehoseOutputDescription (Maybe Text)+kfodRoleARN = lens _kfodRoleARN (\ s a -> s{_kfodRoleARN = a});++instance FromJSON KinesisFirehoseOutputDescription+         where+        parseJSON+          = withObject "KinesisFirehoseOutputDescription"+              (\ x ->+                 KinesisFirehoseOutputDescription' <$>+                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))++instance Hashable KinesisFirehoseOutputDescription+         where++instance NFData KinesisFirehoseOutputDescription+         where++-- | 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.+data KinesisFirehoseOutputUpdate = KinesisFirehoseOutputUpdate'+  { _kfouRoleARNUpdate     :: !(Maybe Text)+  , _kfouResourceARNUpdate :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisFirehoseOutputUpdate+    :: KinesisFirehoseOutputUpdate+kinesisFirehoseOutputUpdate =+  KinesisFirehoseOutputUpdate'+  {_kfouRoleARNUpdate = Nothing, _kfouResourceARNUpdate = Nothing}+++-- | 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.+kfouRoleARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)+kfouRoleARNUpdate = lens _kfouRoleARNUpdate (\ s a -> s{_kfouRoleARNUpdate = a});++-- | Amazon Resource Name (ARN) of the Amazon Kinesis Firehose delivery stream to write to.+kfouResourceARNUpdate :: Lens' KinesisFirehoseOutputUpdate (Maybe Text)+kfouResourceARNUpdate = lens _kfouResourceARNUpdate (\ s a -> s{_kfouResourceARNUpdate = a});++instance Hashable KinesisFirehoseOutputUpdate where++instance NFData KinesisFirehoseOutputUpdate where++instance ToJSON KinesisFirehoseOutputUpdate where+        toJSON KinesisFirehoseOutputUpdate'{..}+          = object+              (catMaybes+                 [("RoleARNUpdate" .=) <$> _kfouRoleARNUpdate,+                  ("ResourceARNUpdate" .=) <$> _kfouResourceARNUpdate])++-- | 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.+data KinesisStreamsInput = KinesisStreamsInput'+  { _ksiResourceARN :: !Text+  , _ksiRoleARN     :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisStreamsInput+    :: Text -- ^ 'ksiResourceARN'+    -> Text -- ^ 'ksiRoleARN'+    -> KinesisStreamsInput+kinesisStreamsInput pResourceARN_ pRoleARN_ =+  KinesisStreamsInput'+  {_ksiResourceARN = pResourceARN_, _ksiRoleARN = pRoleARN_}+++-- | ARN of the input Amazon Kinesis stream to read.+ksiResourceARN :: Lens' KinesisStreamsInput Text+ksiResourceARN = lens _ksiResourceARN (\ s a -> s{_ksiResourceARN = a});++-- | 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.+ksiRoleARN :: Lens' KinesisStreamsInput Text+ksiRoleARN = lens _ksiRoleARN (\ s a -> s{_ksiRoleARN = a});++instance Hashable KinesisStreamsInput where++instance NFData KinesisStreamsInput where++instance ToJSON KinesisStreamsInput where+        toJSON KinesisStreamsInput'{..}+          = object+              (catMaybes+                 [Just ("ResourceARN" .= _ksiResourceARN),+                  Just ("RoleARN" .= _ksiRoleARN)])++-- | Describes the Amazon Kinesis stream that is configured as the streaming source in the application input configuration.+--+--+--+-- /See:/ 'kinesisStreamsInputDescription' smart constructor.+data KinesisStreamsInputDescription = KinesisStreamsInputDescription'+  { _ksidResourceARN :: !(Maybe Text)+  , _ksidRoleARN     :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisStreamsInputDescription+    :: KinesisStreamsInputDescription+kinesisStreamsInputDescription =+  KinesisStreamsInputDescription'+  {_ksidResourceARN = Nothing, _ksidRoleARN = Nothing}+++-- | Amazon Resource Name (ARN) of the Amazon Kinesis stream.+ksidResourceARN :: Lens' KinesisStreamsInputDescription (Maybe Text)+ksidResourceARN = lens _ksidResourceARN (\ s a -> s{_ksidResourceARN = a});++-- | ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.+ksidRoleARN :: Lens' KinesisStreamsInputDescription (Maybe Text)+ksidRoleARN = lens _ksidRoleARN (\ s a -> s{_ksidRoleARN = a});++instance FromJSON KinesisStreamsInputDescription+         where+        parseJSON+          = withObject "KinesisStreamsInputDescription"+              (\ x ->+                 KinesisStreamsInputDescription' <$>+                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))++instance Hashable KinesisStreamsInputDescription+         where++instance NFData KinesisStreamsInputDescription where++-- | When updating application input configuration, provides information about an Amazon Kinesis stream as the streaming source.+--+--+--+-- /See:/ 'kinesisStreamsInputUpdate' smart constructor.+data KinesisStreamsInputUpdate = KinesisStreamsInputUpdate'+  { _ksiuRoleARNUpdate     :: !(Maybe Text)+  , _ksiuResourceARNUpdate :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisStreamsInputUpdate+    :: KinesisStreamsInputUpdate+kinesisStreamsInputUpdate =+  KinesisStreamsInputUpdate'+  {_ksiuRoleARNUpdate = Nothing, _ksiuResourceARNUpdate = Nothing}+++-- | 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.+ksiuRoleARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)+ksiuRoleARNUpdate = lens _ksiuRoleARNUpdate (\ s a -> s{_ksiuRoleARNUpdate = a});++-- | Amazon Resource Name (ARN) of the input Amazon Kinesis stream to read.+ksiuResourceARNUpdate :: Lens' KinesisStreamsInputUpdate (Maybe Text)+ksiuResourceARNUpdate = lens _ksiuResourceARNUpdate (\ s a -> s{_ksiuResourceARNUpdate = a});++instance Hashable KinesisStreamsInputUpdate where++instance NFData KinesisStreamsInputUpdate where++instance ToJSON KinesisStreamsInputUpdate where+        toJSON KinesisStreamsInputUpdate'{..}+          = object+              (catMaybes+                 [("RoleARNUpdate" .=) <$> _ksiuRoleARNUpdate,+                  ("ResourceARNUpdate" .=) <$> _ksiuResourceARNUpdate])++-- | 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.+data KinesisStreamsOutput = KinesisStreamsOutput'+  { _ksoResourceARN :: !Text+  , _ksoRoleARN     :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisStreamsOutput+    :: Text -- ^ 'ksoResourceARN'+    -> Text -- ^ 'ksoRoleARN'+    -> KinesisStreamsOutput+kinesisStreamsOutput pResourceARN_ pRoleARN_ =+  KinesisStreamsOutput'+  {_ksoResourceARN = pResourceARN_, _ksoRoleARN = pRoleARN_}+++-- | ARN of the destination Amazon Kinesis stream to write to.+ksoResourceARN :: Lens' KinesisStreamsOutput Text+ksoResourceARN = lens _ksoResourceARN (\ s a -> s{_ksoResourceARN = a});++-- | 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.+ksoRoleARN :: Lens' KinesisStreamsOutput Text+ksoRoleARN = lens _ksoRoleARN (\ s a -> s{_ksoRoleARN = a});++instance Hashable KinesisStreamsOutput where++instance NFData KinesisStreamsOutput where++instance ToJSON KinesisStreamsOutput where+        toJSON KinesisStreamsOutput'{..}+          = object+              (catMaybes+                 [Just ("ResourceARN" .= _ksoResourceARN),+                  Just ("RoleARN" .= _ksoRoleARN)])++-- | For an application output, describes the Amazon Kinesis stream configured as its destination.+--+--+--+-- /See:/ 'kinesisStreamsOutputDescription' smart constructor.+data KinesisStreamsOutputDescription = KinesisStreamsOutputDescription'+  { _ksodResourceARN :: !(Maybe Text)+  , _ksodRoleARN     :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisStreamsOutputDescription+    :: KinesisStreamsOutputDescription+kinesisStreamsOutputDescription =+  KinesisStreamsOutputDescription'+  {_ksodResourceARN = Nothing, _ksodRoleARN = Nothing}+++-- | Amazon Resource Name (ARN) of the Amazon Kinesis stream.+ksodResourceARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)+ksodResourceARN = lens _ksodResourceARN (\ s a -> s{_ksodResourceARN = a});++-- | ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream.+ksodRoleARN :: Lens' KinesisStreamsOutputDescription (Maybe Text)+ksodRoleARN = lens _ksodRoleARN (\ s a -> s{_ksodRoleARN = a});++instance FromJSON KinesisStreamsOutputDescription+         where+        parseJSON+          = withObject "KinesisStreamsOutputDescription"+              (\ x ->+                 KinesisStreamsOutputDescription' <$>+                   (x .:? "ResourceARN") <*> (x .:? "RoleARN"))++instance Hashable KinesisStreamsOutputDescription+         where++instance NFData KinesisStreamsOutputDescription where++-- | When updating an output configuration using the 'UpdateApplication' operation, provides information about an Amazon Kinesis stream configured as the destination.+--+--+--+-- /See:/ 'kinesisStreamsOutputUpdate' smart constructor.+data KinesisStreamsOutputUpdate = KinesisStreamsOutputUpdate'+  { _ksouRoleARNUpdate     :: !(Maybe Text)+  , _ksouResourceARNUpdate :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+kinesisStreamsOutputUpdate+    :: KinesisStreamsOutputUpdate+kinesisStreamsOutputUpdate =+  KinesisStreamsOutputUpdate'+  {_ksouRoleARNUpdate = Nothing, _ksouResourceARNUpdate = Nothing}+++-- | 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.+ksouRoleARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)+ksouRoleARNUpdate = lens _ksouRoleARNUpdate (\ s a -> s{_ksouRoleARNUpdate = a});++-- | Amazon Resource Name (ARN) of the Amazon Kinesis stream where you want to write the output.+ksouResourceARNUpdate :: Lens' KinesisStreamsOutputUpdate (Maybe Text)+ksouResourceARNUpdate = lens _ksouResourceARNUpdate (\ s a -> s{_ksouResourceARNUpdate = a});++instance Hashable KinesisStreamsOutputUpdate where++instance NFData KinesisStreamsOutputUpdate where++instance ToJSON KinesisStreamsOutputUpdate where+        toJSON KinesisStreamsOutputUpdate'{..}+          = object+              (catMaybes+                 [("RoleARNUpdate" .=) <$> _ksouRoleARNUpdate,+                  ("ResourceARNUpdate" .=) <$> _ksouResourceARNUpdate])++-- | 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.+data MappingParameters = MappingParameters'+  { _mpCSVMappingParameters  :: !(Maybe CSVMappingParameters)+  , _mpJSONMappingParameters :: !(Maybe JSONMappingParameters)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+mappingParameters+    :: MappingParameters+mappingParameters =+  MappingParameters'+  {_mpCSVMappingParameters = Nothing, _mpJSONMappingParameters = Nothing}+++-- | Provides additional mapping information when the record format uses delimiters (for example, CSV).+mpCSVMappingParameters :: Lens' MappingParameters (Maybe CSVMappingParameters)+mpCSVMappingParameters = lens _mpCSVMappingParameters (\ s a -> s{_mpCSVMappingParameters = a});++-- | Provides additional mapping information when JSON is the record format on the streaming source.+mpJSONMappingParameters :: Lens' MappingParameters (Maybe JSONMappingParameters)+mpJSONMappingParameters = lens _mpJSONMappingParameters (\ s a -> s{_mpJSONMappingParameters = a});++instance FromJSON MappingParameters where+        parseJSON+          = withObject "MappingParameters"+              (\ x ->+                 MappingParameters' <$>+                   (x .:? "CSVMappingParameters") <*>+                     (x .:? "JSONMappingParameters"))++instance Hashable MappingParameters where++instance NFData MappingParameters where++instance ToJSON MappingParameters where+        toJSON MappingParameters'{..}+          = object+              (catMaybes+                 [("CSVMappingParameters" .=) <$>+                    _mpCSVMappingParameters,+                  ("JSONMappingParameters" .=) <$>+                    _mpJSONMappingParameters])++-- | 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 <http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html Limits> .+--+--+-- /See:/ 'output' smart constructor.+data Output = Output'+  { _oKinesisStreamsOutput  :: !(Maybe KinesisStreamsOutput)+  , _oKinesisFirehoseOutput :: !(Maybe KinesisFirehoseOutput)+  , _oName                  :: !Text+  , _oDestinationSchema     :: !DestinationSchema+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+output+    :: Text -- ^ 'oName'+    -> DestinationSchema -- ^ 'oDestinationSchema'+    -> Output+output pName_ pDestinationSchema_ =+  Output'+  { _oKinesisStreamsOutput = Nothing+  , _oKinesisFirehoseOutput = Nothing+  , _oName = pName_+  , _oDestinationSchema = pDestinationSchema_+  }+++-- | Identifies an Amazon Kinesis stream as the destination.+oKinesisStreamsOutput :: Lens' Output (Maybe KinesisStreamsOutput)+oKinesisStreamsOutput = lens _oKinesisStreamsOutput (\ s a -> s{_oKinesisStreamsOutput = a});++-- | Identifies an Amazon Kinesis Firehose delivery stream as the destination.+oKinesisFirehoseOutput :: Lens' Output (Maybe KinesisFirehoseOutput)+oKinesisFirehoseOutput = lens _oKinesisFirehoseOutput (\ s a -> s{_oKinesisFirehoseOutput = a});++-- | Name of the in-application stream.+oName :: Lens' Output Text+oName = lens _oName (\ s a -> s{_oName = a});++-- | Undocumented member.+oDestinationSchema :: Lens' Output DestinationSchema+oDestinationSchema = lens _oDestinationSchema (\ s a -> s{_oDestinationSchema = a});++instance Hashable Output where++instance NFData Output where++instance ToJSON Output where+        toJSON Output'{..}+          = object+              (catMaybes+                 [("KinesisStreamsOutput" .=) <$>+                    _oKinesisStreamsOutput,+                  ("KinesisFirehoseOutput" .=) <$>+                    _oKinesisFirehoseOutput,+                  Just ("Name" .= _oName),+                  Just ("DestinationSchema" .= _oDestinationSchema)])++-- | 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.+data OutputDescription = OutputDescription'+  { _odOutputId :: !(Maybe Text)+  , _odDestinationSchema :: !(Maybe DestinationSchema)+  , _odKinesisFirehoseOutputDescription :: !(Maybe KinesisFirehoseOutputDescription)+  , _odKinesisStreamsOutputDescription :: !(Maybe KinesisStreamsOutputDescription)+  , _odName :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+outputDescription+    :: OutputDescription+outputDescription =+  OutputDescription'+  { _odOutputId = Nothing+  , _odDestinationSchema = Nothing+  , _odKinesisFirehoseOutputDescription = Nothing+  , _odKinesisStreamsOutputDescription = Nothing+  , _odName = Nothing+  }+++-- | A unique identifier for the output configuration.+odOutputId :: Lens' OutputDescription (Maybe Text)+odOutputId = lens _odOutputId (\ s a -> s{_odOutputId = a});++-- | Data format used for writing data to the destination.+odDestinationSchema :: Lens' OutputDescription (Maybe DestinationSchema)+odDestinationSchema = lens _odDestinationSchema (\ s a -> s{_odDestinationSchema = a});++-- | Describes the Amazon Kinesis Firehose delivery stream configured as the destination where output is written.+odKinesisFirehoseOutputDescription :: Lens' OutputDescription (Maybe KinesisFirehoseOutputDescription)+odKinesisFirehoseOutputDescription = lens _odKinesisFirehoseOutputDescription (\ s a -> s{_odKinesisFirehoseOutputDescription = a});++-- | Describes Amazon Kinesis stream configured as the destination where output is written.+odKinesisStreamsOutputDescription :: Lens' OutputDescription (Maybe KinesisStreamsOutputDescription)+odKinesisStreamsOutputDescription = lens _odKinesisStreamsOutputDescription (\ s a -> s{_odKinesisStreamsOutputDescription = a});++-- | Name of the in-application stream configured as output.+odName :: Lens' OutputDescription (Maybe Text)+odName = lens _odName (\ s a -> s{_odName = a});++instance FromJSON OutputDescription where+        parseJSON+          = withObject "OutputDescription"+              (\ x ->+                 OutputDescription' <$>+                   (x .:? "OutputId") <*> (x .:? "DestinationSchema")+                     <*> (x .:? "KinesisFirehoseOutputDescription")+                     <*> (x .:? "KinesisStreamsOutputDescription")+                     <*> (x .:? "Name"))++instance Hashable OutputDescription where++instance NFData OutputDescription where++-- | Describes updates to the output configuration identified by the @OutputId@ .+--+--+--+-- /See:/ 'outputUpdate' smart constructor.+data OutputUpdate = OutputUpdate'+  { _ouKinesisStreamsOutputUpdate  :: !(Maybe KinesisStreamsOutputUpdate)+  , _ouDestinationSchemaUpdate     :: !(Maybe DestinationSchema)+  , _ouKinesisFirehoseOutputUpdate :: !(Maybe KinesisFirehoseOutputUpdate)+  , _ouNameUpdate                  :: !(Maybe Text)+  , _ouOutputId                    :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+outputUpdate+    :: Text -- ^ 'ouOutputId'+    -> OutputUpdate+outputUpdate pOutputId_ =+  OutputUpdate'+  { _ouKinesisStreamsOutputUpdate = Nothing+  , _ouDestinationSchemaUpdate = Nothing+  , _ouKinesisFirehoseOutputUpdate = Nothing+  , _ouNameUpdate = Nothing+  , _ouOutputId = pOutputId_+  }+++-- | Describes an Amazon Kinesis stream as the destination for the output.+ouKinesisStreamsOutputUpdate :: Lens' OutputUpdate (Maybe KinesisStreamsOutputUpdate)+ouKinesisStreamsOutputUpdate = lens _ouKinesisStreamsOutputUpdate (\ s a -> s{_ouKinesisStreamsOutputUpdate = a});++-- | Undocumented member.+ouDestinationSchemaUpdate :: Lens' OutputUpdate (Maybe DestinationSchema)+ouDestinationSchemaUpdate = lens _ouDestinationSchemaUpdate (\ s a -> s{_ouDestinationSchemaUpdate = a});++-- | Describes a Amazon Kinesis Firehose delivery stream as the destination for the output.+ouKinesisFirehoseOutputUpdate :: Lens' OutputUpdate (Maybe KinesisFirehoseOutputUpdate)+ouKinesisFirehoseOutputUpdate = lens _ouKinesisFirehoseOutputUpdate (\ s a -> s{_ouKinesisFirehoseOutputUpdate = a});++-- | 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.+ouNameUpdate :: Lens' OutputUpdate (Maybe Text)+ouNameUpdate = lens _ouNameUpdate (\ s a -> s{_ouNameUpdate = a});++-- | Identifies the specific output configuration that you want to update.+ouOutputId :: Lens' OutputUpdate Text+ouOutputId = lens _ouOutputId (\ s a -> s{_ouOutputId = a});++instance Hashable OutputUpdate where++instance NFData OutputUpdate where++instance ToJSON OutputUpdate where+        toJSON OutputUpdate'{..}+          = object+              (catMaybes+                 [("KinesisStreamsOutputUpdate" .=) <$>+                    _ouKinesisStreamsOutputUpdate,+                  ("DestinationSchemaUpdate" .=) <$>+                    _ouDestinationSchemaUpdate,+                  ("KinesisFirehoseOutputUpdate" .=) <$>+                    _ouKinesisFirehoseOutputUpdate,+                  ("NameUpdate" .=) <$> _ouNameUpdate,+                  Just ("OutputId" .= _ouOutputId)])++-- | 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.+data RecordColumn = RecordColumn'+  { _rcMapping :: !(Maybe Text)+  , _rcName    :: !Text+  , _rcSqlType :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+recordColumn+    :: Text -- ^ 'rcName'+    -> Text -- ^ 'rcSqlType'+    -> RecordColumn+recordColumn pName_ pSqlType_ =+  RecordColumn' {_rcMapping = Nothing, _rcName = pName_, _rcSqlType = pSqlType_}+++-- | Reference to the data element in the streaming input of the reference data source.+rcMapping :: Lens' RecordColumn (Maybe Text)+rcMapping = lens _rcMapping (\ s a -> s{_rcMapping = a});++-- | Name of the column created in the in-application input stream or reference table.+rcName :: Lens' RecordColumn Text+rcName = lens _rcName (\ s a -> s{_rcName = a});++-- | Type of column created in the in-application input stream or reference table.+rcSqlType :: Lens' RecordColumn Text+rcSqlType = lens _rcSqlType (\ s a -> s{_rcSqlType = a});++instance FromJSON RecordColumn where+        parseJSON+          = withObject "RecordColumn"+              (\ x ->+                 RecordColumn' <$>+                   (x .:? "Mapping") <*> (x .: "Name") <*>+                     (x .: "SqlType"))++instance Hashable RecordColumn where++instance NFData RecordColumn where++instance ToJSON RecordColumn where+        toJSON RecordColumn'{..}+          = object+              (catMaybes+                 [("Mapping" .=) <$> _rcMapping,+                  Just ("Name" .= _rcName),+                  Just ("SqlType" .= _rcSqlType)])++-- | Describes the record format and relevant mapping information that should be applied to schematize the records on the stream.+--+--+--+-- /See:/ 'recordFormat' smart constructor.+data RecordFormat = RecordFormat'+  { _rfMappingParameters :: !(Maybe MappingParameters)+  , _rfRecordFormatType  :: !RecordFormatType+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+recordFormat+    :: RecordFormatType -- ^ 'rfRecordFormatType'+    -> RecordFormat+recordFormat pRecordFormatType_ =+  RecordFormat'+  {_rfMappingParameters = Nothing, _rfRecordFormatType = pRecordFormatType_}+++-- | Undocumented member.+rfMappingParameters :: Lens' RecordFormat (Maybe MappingParameters)+rfMappingParameters = lens _rfMappingParameters (\ s a -> s{_rfMappingParameters = a});++-- | The type of record format.+rfRecordFormatType :: Lens' RecordFormat RecordFormatType+rfRecordFormatType = lens _rfRecordFormatType (\ s a -> s{_rfRecordFormatType = a});++instance FromJSON RecordFormat where+        parseJSON+          = withObject "RecordFormat"+              (\ x ->+                 RecordFormat' <$>+                   (x .:? "MappingParameters") <*>+                     (x .: "RecordFormatType"))++instance Hashable RecordFormat where++instance NFData RecordFormat where++instance ToJSON RecordFormat where+        toJSON RecordFormat'{..}+          = object+              (catMaybes+                 [("MappingParameters" .=) <$> _rfMappingParameters,+                  Just ("RecordFormatType" .= _rfRecordFormatType)])++-- | 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.+data ReferenceDataSource = ReferenceDataSource'+  { _rdsS3ReferenceDataSource :: !(Maybe S3ReferenceDataSource)+  , _rdsTableName             :: !Text+  , _rdsReferenceSchema       :: !SourceSchema+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+referenceDataSource+    :: Text -- ^ 'rdsTableName'+    -> SourceSchema -- ^ 'rdsReferenceSchema'+    -> ReferenceDataSource+referenceDataSource pTableName_ pReferenceSchema_ =+  ReferenceDataSource'+  { _rdsS3ReferenceDataSource = Nothing+  , _rdsTableName = pTableName_+  , _rdsReferenceSchema = pReferenceSchema_+  }+++-- | Undocumented member.+rdsS3ReferenceDataSource :: Lens' ReferenceDataSource (Maybe S3ReferenceDataSource)+rdsS3ReferenceDataSource = lens _rdsS3ReferenceDataSource (\ s a -> s{_rdsS3ReferenceDataSource = a});++-- | Name of the in-application table to create.+rdsTableName :: Lens' ReferenceDataSource Text+rdsTableName = lens _rdsTableName (\ s a -> s{_rdsTableName = a});++-- | Undocumented member.+rdsReferenceSchema :: Lens' ReferenceDataSource SourceSchema+rdsReferenceSchema = lens _rdsReferenceSchema (\ s a -> s{_rdsReferenceSchema = a});++instance Hashable ReferenceDataSource where++instance NFData ReferenceDataSource where++instance ToJSON ReferenceDataSource where+        toJSON ReferenceDataSource'{..}+          = object+              (catMaybes+                 [("S3ReferenceDataSource" .=) <$>+                    _rdsS3ReferenceDataSource,+                  Just ("TableName" .= _rdsTableName),+                  Just ("ReferenceSchema" .= _rdsReferenceSchema)])++-- | Describes the reference data source configured for an application.+--+--+--+-- /See:/ 'referenceDataSourceDescription' smart constructor.+data ReferenceDataSourceDescription = ReferenceDataSourceDescription'+  { _rdsdReferenceSchema                  :: !(Maybe SourceSchema)+  , _rdsdReferenceId                      :: !Text+  , _rdsdTableName                        :: !Text+  , _rdsdS3ReferenceDataSourceDescription :: !S3ReferenceDataSourceDescription+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+referenceDataSourceDescription+    :: Text -- ^ 'rdsdReferenceId'+    -> Text -- ^ 'rdsdTableName'+    -> S3ReferenceDataSourceDescription -- ^ 'rdsdS3ReferenceDataSourceDescription'+    -> ReferenceDataSourceDescription+referenceDataSourceDescription pReferenceId_ pTableName_ pS3ReferenceDataSourceDescription_ =+  ReferenceDataSourceDescription'+  { _rdsdReferenceSchema = Nothing+  , _rdsdReferenceId = pReferenceId_+  , _rdsdTableName = pTableName_+  , _rdsdS3ReferenceDataSourceDescription = pS3ReferenceDataSourceDescription_+  }+++-- | Undocumented member.+rdsdReferenceSchema :: Lens' ReferenceDataSourceDescription (Maybe SourceSchema)+rdsdReferenceSchema = lens _rdsdReferenceSchema (\ s a -> s{_rdsdReferenceSchema = a});++-- | 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.+rdsdReferenceId :: Lens' ReferenceDataSourceDescription Text+rdsdReferenceId = lens _rdsdReferenceId (\ s a -> s{_rdsdReferenceId = a});++-- | The in-application table name created by the specific reference data source configuration.+rdsdTableName :: Lens' ReferenceDataSourceDescription Text+rdsdTableName = lens _rdsdTableName (\ s a -> s{_rdsdTableName = a});++-- | 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.+rdsdS3ReferenceDataSourceDescription :: Lens' ReferenceDataSourceDescription S3ReferenceDataSourceDescription+rdsdS3ReferenceDataSourceDescription = lens _rdsdS3ReferenceDataSourceDescription (\ s a -> s{_rdsdS3ReferenceDataSourceDescription = a});++instance FromJSON ReferenceDataSourceDescription+         where+        parseJSON+          = withObject "ReferenceDataSourceDescription"+              (\ x ->+                 ReferenceDataSourceDescription' <$>+                   (x .:? "ReferenceSchema") <*> (x .: "ReferenceId")+                     <*> (x .: "TableName")+                     <*> (x .: "S3ReferenceDataSourceDescription"))++instance Hashable ReferenceDataSourceDescription+         where++instance NFData ReferenceDataSourceDescription where++-- | 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.+data ReferenceDataSourceUpdate = ReferenceDataSourceUpdate'+  { _rdsuTableNameUpdate             :: !(Maybe Text)+  , _rdsuS3ReferenceDataSourceUpdate :: !(Maybe S3ReferenceDataSourceUpdate)+  , _rdsuReferenceSchemaUpdate       :: !(Maybe SourceSchema)+  , _rdsuReferenceId                 :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+referenceDataSourceUpdate+    :: Text -- ^ 'rdsuReferenceId'+    -> ReferenceDataSourceUpdate+referenceDataSourceUpdate pReferenceId_ =+  ReferenceDataSourceUpdate'+  { _rdsuTableNameUpdate = Nothing+  , _rdsuS3ReferenceDataSourceUpdate = Nothing+  , _rdsuReferenceSchemaUpdate = Nothing+  , _rdsuReferenceId = pReferenceId_+  }+++-- | In-application table name that is created by this update.+rdsuTableNameUpdate :: Lens' ReferenceDataSourceUpdate (Maybe Text)+rdsuTableNameUpdate = lens _rdsuTableNameUpdate (\ s a -> s{_rdsuTableNameUpdate = a});++-- | 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.+rdsuS3ReferenceDataSourceUpdate :: Lens' ReferenceDataSourceUpdate (Maybe S3ReferenceDataSourceUpdate)+rdsuS3ReferenceDataSourceUpdate = lens _rdsuS3ReferenceDataSourceUpdate (\ s a -> s{_rdsuS3ReferenceDataSourceUpdate = a});++-- | Undocumented member.+rdsuReferenceSchemaUpdate :: Lens' ReferenceDataSourceUpdate (Maybe SourceSchema)+rdsuReferenceSchemaUpdate = lens _rdsuReferenceSchemaUpdate (\ s a -> s{_rdsuReferenceSchemaUpdate = a});++-- | ID of the reference data source being updated. You can use the 'DescribeApplication' operation to get this value.+rdsuReferenceId :: Lens' ReferenceDataSourceUpdate Text+rdsuReferenceId = lens _rdsuReferenceId (\ s a -> s{_rdsuReferenceId = a});++instance Hashable ReferenceDataSourceUpdate where++instance NFData ReferenceDataSourceUpdate where++instance ToJSON ReferenceDataSourceUpdate where+        toJSON ReferenceDataSourceUpdate'{..}+          = object+              (catMaybes+                 [("TableNameUpdate" .=) <$> _rdsuTableNameUpdate,+                  ("S3ReferenceDataSourceUpdate" .=) <$>+                    _rdsuS3ReferenceDataSourceUpdate,+                  ("ReferenceSchemaUpdate" .=) <$>+                    _rdsuReferenceSchemaUpdate,+                  Just ("ReferenceId" .= _rdsuReferenceId)])++-- | /See:/ 's3Configuration' smart constructor.+data S3Configuration = S3Configuration'+  { _scRoleARN   :: !Text+  , _scBucketARN :: !Text+  , _scFileKey   :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+s3Configuration+    :: Text -- ^ 'scRoleARN'+    -> Text -- ^ 'scBucketARN'+    -> Text -- ^ 'scFileKey'+    -> S3Configuration+s3Configuration pRoleARN_ pBucketARN_ pFileKey_ =+  S3Configuration'+  {_scRoleARN = pRoleARN_, _scBucketARN = pBucketARN_, _scFileKey = pFileKey_}+++-- | Undocumented member.+scRoleARN :: Lens' S3Configuration Text+scRoleARN = lens _scRoleARN (\ s a -> s{_scRoleARN = a});++-- | Undocumented member.+scBucketARN :: Lens' S3Configuration Text+scBucketARN = lens _scBucketARN (\ s a -> s{_scBucketARN = a});++-- | Undocumented member.+scFileKey :: Lens' S3Configuration Text+scFileKey = lens _scFileKey (\ s a -> s{_scFileKey = a});++instance Hashable S3Configuration where++instance NFData S3Configuration where++instance ToJSON S3Configuration where+        toJSON S3Configuration'{..}+          = object+              (catMaybes+                 [Just ("RoleARN" .= _scRoleARN),+                  Just ("BucketARN" .= _scBucketARN),+                  Just ("FileKey" .= _scFileKey)])++-- | 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.+data S3ReferenceDataSource = S3ReferenceDataSource'+  { _srdsBucketARN        :: !Text+  , _srdsFileKey          :: !Text+  , _srdsReferenceRoleARN :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+s3ReferenceDataSource+    :: Text -- ^ 'srdsBucketARN'+    -> Text -- ^ 'srdsFileKey'+    -> Text -- ^ 'srdsReferenceRoleARN'+    -> S3ReferenceDataSource+s3ReferenceDataSource pBucketARN_ pFileKey_ pReferenceRoleARN_ =+  S3ReferenceDataSource'+  { _srdsBucketARN = pBucketARN_+  , _srdsFileKey = pFileKey_+  , _srdsReferenceRoleARN = pReferenceRoleARN_+  }+++-- | Amazon Resource Name (ARN) of the S3 bucket.+srdsBucketARN :: Lens' S3ReferenceDataSource Text+srdsBucketARN = lens _srdsBucketARN (\ s a -> s{_srdsBucketARN = a});++-- | Object key name containing reference data.+srdsFileKey :: Lens' S3ReferenceDataSource Text+srdsFileKey = lens _srdsFileKey (\ s a -> s{_srdsFileKey = a});++-- | 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.+srdsReferenceRoleARN :: Lens' S3ReferenceDataSource Text+srdsReferenceRoleARN = lens _srdsReferenceRoleARN (\ s a -> s{_srdsReferenceRoleARN = a});++instance Hashable S3ReferenceDataSource where++instance NFData S3ReferenceDataSource where++instance ToJSON S3ReferenceDataSource where+        toJSON S3ReferenceDataSource'{..}+          = object+              (catMaybes+                 [Just ("BucketARN" .= _srdsBucketARN),+                  Just ("FileKey" .= _srdsFileKey),+                  Just ("ReferenceRoleARN" .= _srdsReferenceRoleARN)])++-- | Provides the bucket name and object key name that stores the reference data.+--+--+--+-- /See:/ 's3ReferenceDataSourceDescription' smart constructor.+data S3ReferenceDataSourceDescription = S3ReferenceDataSourceDescription'+  { _srdsdBucketARN        :: !Text+  , _srdsdFileKey          :: !Text+  , _srdsdReferenceRoleARN :: !Text+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+s3ReferenceDataSourceDescription+    :: Text -- ^ 'srdsdBucketARN'+    -> Text -- ^ 'srdsdFileKey'+    -> Text -- ^ 'srdsdReferenceRoleARN'+    -> S3ReferenceDataSourceDescription+s3ReferenceDataSourceDescription pBucketARN_ pFileKey_ pReferenceRoleARN_ =+  S3ReferenceDataSourceDescription'+  { _srdsdBucketARN = pBucketARN_+  , _srdsdFileKey = pFileKey_+  , _srdsdReferenceRoleARN = pReferenceRoleARN_+  }+++-- | Amazon Resource Name (ARN) of the S3 bucket.+srdsdBucketARN :: Lens' S3ReferenceDataSourceDescription Text+srdsdBucketARN = lens _srdsdBucketARN (\ s a -> s{_srdsdBucketARN = a});++-- | Amazon S3 object key name.+srdsdFileKey :: Lens' S3ReferenceDataSourceDescription Text+srdsdFileKey = lens _srdsdFileKey (\ s a -> s{_srdsdFileKey = a});++-- | 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.+srdsdReferenceRoleARN :: Lens' S3ReferenceDataSourceDescription Text+srdsdReferenceRoleARN = lens _srdsdReferenceRoleARN (\ s a -> s{_srdsdReferenceRoleARN = a});++instance FromJSON S3ReferenceDataSourceDescription+         where+        parseJSON+          = withObject "S3ReferenceDataSourceDescription"+              (\ x ->+                 S3ReferenceDataSourceDescription' <$>+                   (x .: "BucketARN") <*> (x .: "FileKey") <*>+                     (x .: "ReferenceRoleARN"))++instance Hashable S3ReferenceDataSourceDescription+         where++instance NFData S3ReferenceDataSourceDescription+         where++-- | 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.+data S3ReferenceDataSourceUpdate = S3ReferenceDataSourceUpdate'+  { _srdsuBucketARNUpdate        :: !(Maybe Text)+  , _srdsuFileKeyUpdate          :: !(Maybe Text)+  , _srdsuReferenceRoleARNUpdate :: !(Maybe Text)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+s3ReferenceDataSourceUpdate+    :: S3ReferenceDataSourceUpdate+s3ReferenceDataSourceUpdate =+  S3ReferenceDataSourceUpdate'+  { _srdsuBucketARNUpdate = Nothing+  , _srdsuFileKeyUpdate = Nothing+  , _srdsuReferenceRoleARNUpdate = Nothing+  }+++-- | Amazon Resource Name (ARN) of the S3 bucket.+srdsuBucketARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)+srdsuBucketARNUpdate = lens _srdsuBucketARNUpdate (\ s a -> s{_srdsuBucketARNUpdate = a});++-- | Object key name.+srdsuFileKeyUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)+srdsuFileKeyUpdate = lens _srdsuFileKeyUpdate (\ s a -> s{_srdsuFileKeyUpdate = a});++-- | ARN of the IAM role that Amazon Kinesis Analytics can assume to read the Amazon S3 object and populate the in-application.+srdsuReferenceRoleARNUpdate :: Lens' S3ReferenceDataSourceUpdate (Maybe Text)+srdsuReferenceRoleARNUpdate = lens _srdsuReferenceRoleARNUpdate (\ s a -> s{_srdsuReferenceRoleARNUpdate = a});++instance Hashable S3ReferenceDataSourceUpdate where++instance NFData S3ReferenceDataSourceUpdate where++instance ToJSON S3ReferenceDataSourceUpdate where+        toJSON S3ReferenceDataSourceUpdate'{..}+          = object+              (catMaybes+                 [("BucketARNUpdate" .=) <$> _srdsuBucketARNUpdate,+                  ("FileKeyUpdate" .=) <$> _srdsuFileKeyUpdate,+                  ("ReferenceRoleARNUpdate" .=) <$>+                    _srdsuReferenceRoleARNUpdate])++-- | 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.+data SourceSchema = SourceSchema'+  { _ssRecordEncoding :: !(Maybe Text)+  , _ssRecordFormat   :: !RecordFormat+  , _ssRecordColumns  :: !(List1 RecordColumn)+  } deriving (Eq, Read, Show, Data, Typeable, Generic)+++-- | 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.+sourceSchema+    :: RecordFormat -- ^ 'ssRecordFormat'+    -> NonEmpty RecordColumn -- ^ 'ssRecordColumns'+    -> SourceSchema+sourceSchema pRecordFormat_ pRecordColumns_ =+  SourceSchema'+  { _ssRecordEncoding = Nothing+  , _ssRecordFormat = pRecordFormat_+  , _ssRecordColumns = _List1 # pRecordColumns_+  }+++-- | Specifies the encoding of the records in the streaming source. For example, UTF-8.+ssRecordEncoding :: Lens' SourceSchema (Maybe Text)+ssRecordEncoding = lens _ssRecordEncoding (\ s a -> s{_ssRecordEncoding = a});++-- | Specifies the format of the records on the streaming source.+ssRecordFormat :: Lens' SourceSchema RecordFormat+ssRecordFormat = lens _ssRecordFormat (\ s a -> s{_ssRecordFormat = a});++-- | A list of @RecordColumn@ objects.+ssRecordColumns :: Lens' SourceSchema (NonEmpty RecordColumn)+ssRecordColumns = lens _ssRecordColumns (\ s a -> s{_ssRecordColumns = a}) . _List1;++instance FromJSON SourceSchema where+        parseJSON+          = withObject "SourceSchema"+              (\ x ->+                 SourceSchema' <$>+                   (x .:? "RecordEncoding") <*> (x .: "RecordFormat")+                     <*> (x .: "RecordColumns"))++instance Hashable SourceSchema where++instance NFData SourceSchema where  instance ToJSON SourceSchema where         toJSON SourceSchema'{..}