{-# 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 #-}
module Network.AWS.KinesisAnalytics.DiscoverInputSchema
(
discoverInputSchema
, DiscoverInputSchema
, disInputStartingPositionConfiguration
, disInputProcessingConfiguration
, disS3Configuration
, disResourceARN
, disRoleARN
, discoverInputSchemaResponse
, DiscoverInputSchemaResponse
, 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
data DiscoverInputSchema = DiscoverInputSchema'
{ _disInputStartingPositionConfiguration :: !(Maybe InputStartingPositionConfiguration)
, _disInputProcessingConfiguration :: !(Maybe InputProcessingConfiguration)
, _disS3Configuration :: !(Maybe S3Configuration)
, _disResourceARN :: !(Maybe Text)
, _disRoleARN :: !(Maybe Text)
} deriving (Eq, Read, Show, Data, Typeable, Generic)
discoverInputSchema
:: DiscoverInputSchema
discoverInputSchema =
DiscoverInputSchema'
{ _disInputStartingPositionConfiguration = Nothing
, _disInputProcessingConfiguration = Nothing
, _disS3Configuration = Nothing
, _disResourceARN = Nothing
, _disRoleARN = Nothing
}
disInputStartingPositionConfiguration :: Lens' DiscoverInputSchema (Maybe InputStartingPositionConfiguration)
disInputStartingPositionConfiguration = lens _disInputStartingPositionConfiguration (\ s a -> s{_disInputStartingPositionConfiguration = a})
disInputProcessingConfiguration :: Lens' DiscoverInputSchema (Maybe InputProcessingConfiguration)
disInputProcessingConfiguration = lens _disInputProcessingConfiguration (\ s a -> s{_disInputProcessingConfiguration = a})
disS3Configuration :: Lens' DiscoverInputSchema (Maybe S3Configuration)
disS3Configuration = lens _disS3Configuration (\ s a -> s{_disS3Configuration = a})
disResourceARN :: Lens' DiscoverInputSchema (Maybe Text)
disResourceARN = lens _disResourceARN (\ s a -> s{_disResourceARN = a})
disRoleARN :: Lens' DiscoverInputSchema (Maybe Text)
disRoleARN = lens _disRoleARN (\ s a -> s{_disRoleARN = a})
instance AWSRequest DiscoverInputSchema where
type Rs DiscoverInputSchema =
DiscoverInputSchemaResponse
request = postJSON kinesisAnalytics
response
= receiveJSON
(\ s h x ->
DiscoverInputSchemaResponse' <$>
(x .?> "RawInputRecords" .!@ mempty) <*>
(x .?> "InputSchema")
<*> (x .?> "ProcessedInputRecords" .!@ mempty)
<*> (x .?> "ParsedInputRecords" .!@ mempty)
<*> (pure (fromEnum s)))
instance Hashable DiscoverInputSchema where
instance NFData DiscoverInputSchema where
instance ToHeaders DiscoverInputSchema where
toHeaders
= const
(mconcat
["X-Amz-Target" =#
("KinesisAnalytics_20150814.DiscoverInputSchema" ::
ByteString),
"Content-Type" =#
("application/x-amz-json-1.1" :: ByteString)])
instance ToJSON DiscoverInputSchema where
toJSON DiscoverInputSchema'{..}
= object
(catMaybes
[("InputStartingPositionConfiguration" .=) <$>
_disInputStartingPositionConfiguration,
("InputProcessingConfiguration" .=) <$>
_disInputProcessingConfiguration,
("S3Configuration" .=) <$> _disS3Configuration,
("ResourceARN" .=) <$> _disResourceARN,
("RoleARN" .=) <$> _disRoleARN])
instance ToPath DiscoverInputSchema where
toPath = const "/"
instance ToQuery DiscoverInputSchema where
toQuery = const mempty
data DiscoverInputSchemaResponse = DiscoverInputSchemaResponse'
{ _disrsRawInputRecords :: !(Maybe [Text])
, _disrsInputSchema :: !(Maybe SourceSchema)
, _disrsProcessedInputRecords :: !(Maybe [Text])
, _disrsParsedInputRecords :: !(Maybe [[Text]])
, _disrsResponseStatus :: !Int
} deriving (Eq, Read, Show, Data, Typeable, Generic)
discoverInputSchemaResponse
:: Int
-> DiscoverInputSchemaResponse
discoverInputSchemaResponse pResponseStatus_ =
DiscoverInputSchemaResponse'
{ _disrsRawInputRecords = Nothing
, _disrsInputSchema = Nothing
, _disrsProcessedInputRecords = Nothing
, _disrsParsedInputRecords = Nothing
, _disrsResponseStatus = pResponseStatus_
}
disrsRawInputRecords :: Lens' DiscoverInputSchemaResponse [Text]
disrsRawInputRecords = lens _disrsRawInputRecords (\ s a -> s{_disrsRawInputRecords = a}) . _Default . _Coerce
disrsInputSchema :: Lens' DiscoverInputSchemaResponse (Maybe SourceSchema)
disrsInputSchema = lens _disrsInputSchema (\ s a -> s{_disrsInputSchema = a})
disrsProcessedInputRecords :: Lens' DiscoverInputSchemaResponse [Text]
disrsProcessedInputRecords = lens _disrsProcessedInputRecords (\ s a -> s{_disrsProcessedInputRecords = a}) . _Default . _Coerce
disrsParsedInputRecords :: Lens' DiscoverInputSchemaResponse [[Text]]
disrsParsedInputRecords = lens _disrsParsedInputRecords (\ s a -> s{_disrsParsedInputRecords = a}) . _Default . _Coerce
disrsResponseStatus :: Lens' DiscoverInputSchemaResponse Int
disrsResponseStatus = lens _disrsResponseStatus (\ s a -> s{_disrsResponseStatus = a})
instance NFData DiscoverInputSchemaResponse where