File Coverage

blib/lib/Paws/KinesisAnalytics.pm
Criterion Covered Total %
statement 3 3 100.0
branch n/a
condition n/a
subroutine 1 1 100.0
pod n/a
total 4 4 100.0


line stmt bran cond sub pod time code
1             package Paws::KinesisAnalytics;
2 1     1   3064 use Moose;
  1         3  
  1         8  
3             sub service { 'kinesisanalytics' }
4             sub version { '2015-08-14' }
5             sub target_prefix { 'KinesisAnalytics_20150814' }
6             sub json_version { "1.1" }
7             has max_attempts => (is => 'ro', isa => 'Int', default => 5);
8             has retry => (is => 'ro', isa => 'HashRef', default => sub {
9             { base => 'rand', type => 'exponential', growth_factor => 2 }
10             });
11             has retriables => (is => 'ro', isa => 'ArrayRef', default => sub { [
12             ] });
13              
14             with 'Paws::API::Caller', 'Paws::API::EndpointResolver', 'Paws::Net::V4Signature', 'Paws::Net::JsonCaller', 'Paws::Net::JsonResponse';
15              
16            
17             sub AddApplicationCloudWatchLoggingOption {
18             my $self = shift;
19             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::AddApplicationCloudWatchLoggingOption', @_);
20             return $self->caller->do_call($self, $call_object);
21             }
22             sub AddApplicationInput {
23             my $self = shift;
24             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::AddApplicationInput', @_);
25             return $self->caller->do_call($self, $call_object);
26             }
27             sub AddApplicationOutput {
28             my $self = shift;
29             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::AddApplicationOutput', @_);
30             return $self->caller->do_call($self, $call_object);
31             }
32             sub AddApplicationReferenceDataSource {
33             my $self = shift;
34             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::AddApplicationReferenceDataSource', @_);
35             return $self->caller->do_call($self, $call_object);
36             }
37             sub CreateApplication {
38             my $self = shift;
39             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::CreateApplication', @_);
40             return $self->caller->do_call($self, $call_object);
41             }
42             sub DeleteApplication {
43             my $self = shift;
44             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::DeleteApplication', @_);
45             return $self->caller->do_call($self, $call_object);
46             }
47             sub DeleteApplicationCloudWatchLoggingOption {
48             my $self = shift;
49             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::DeleteApplicationCloudWatchLoggingOption', @_);
50             return $self->caller->do_call($self, $call_object);
51             }
52             sub DeleteApplicationOutput {
53             my $self = shift;
54             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::DeleteApplicationOutput', @_);
55             return $self->caller->do_call($self, $call_object);
56             }
57             sub DeleteApplicationReferenceDataSource {
58             my $self = shift;
59             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::DeleteApplicationReferenceDataSource', @_);
60             return $self->caller->do_call($self, $call_object);
61             }
62             sub DescribeApplication {
63             my $self = shift;
64             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::DescribeApplication', @_);
65             return $self->caller->do_call($self, $call_object);
66             }
67             sub DiscoverInputSchema {
68             my $self = shift;
69             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::DiscoverInputSchema', @_);
70             return $self->caller->do_call($self, $call_object);
71             }
72             sub ListApplications {
73             my $self = shift;
74             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::ListApplications', @_);
75             return $self->caller->do_call($self, $call_object);
76             }
77             sub StartApplication {
78             my $self = shift;
79             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::StartApplication', @_);
80             return $self->caller->do_call($self, $call_object);
81             }
82             sub StopApplication {
83             my $self = shift;
84             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::StopApplication', @_);
85             return $self->caller->do_call($self, $call_object);
86             }
87             sub UpdateApplication {
88             my $self = shift;
89             my $call_object = $self->new_with_coercions('Paws::KinesisAnalytics::UpdateApplication', @_);
90             return $self->caller->do_call($self, $call_object);
91             }
92            
93              
94              
95             sub operations { qw/AddApplicationCloudWatchLoggingOption AddApplicationInput AddApplicationOutput AddApplicationReferenceDataSource CreateApplication DeleteApplication DeleteApplicationCloudWatchLoggingOption DeleteApplicationOutput DeleteApplicationReferenceDataSource DescribeApplication DiscoverInputSchema ListApplications StartApplication StopApplication UpdateApplication / }
96              
97             1;
98              
99             ### main pod documentation begin ###
100              
101             =head1 NAME
102              
103             Paws::KinesisAnalytics - Perl Interface to AWS Amazon Kinesis Analytics
104              
105             =head1 SYNOPSIS
106              
107             use Paws;
108              
109             my $obj = Paws->service('KinesisAnalytics');
110             my $res = $obj->Method(
111             Arg1 => $val1,
112             Arg2 => [ 'V1', 'V2' ],
113             # if Arg3 is an object, the HashRef will be used as arguments to the constructor
114             # of the arguments type
115             Arg3 => { Att1 => 'Val1' },
116             # if Arg4 is an array of objects, the HashRefs will be passed as arguments to
117             # the constructor of the arguments type
118             Arg4 => [ { Att1 => 'Val1' }, { Att1 => 'Val2' } ],
119             );
120              
121             =head1 DESCRIPTION
122              
123              
124              
125             =head1 METHODS
126              
127             =head2 AddApplicationCloudWatchLoggingOption(ApplicationName => Str, CloudWatchLoggingOption => L<Paws::KinesisAnalytics::CloudWatchLoggingOption>, CurrentApplicationVersionId => Int)
128              
129             Each argument is described in detail in: L<Paws::KinesisAnalytics::AddApplicationCloudWatchLoggingOption>
130              
131             Returns: a L<Paws::KinesisAnalytics::AddApplicationCloudWatchLoggingOptionResponse> instance
132              
133             Adds a CloudWatch log stream to monitor application configuration
134             errors. For more information about using CloudWatch log streams with
135             Amazon Kinesis Analytics applications, see Monitoring Configuration
136             Errors.
137              
138              
139             =head2 AddApplicationInput(ApplicationName => Str, CurrentApplicationVersionId => Int, Input => L<Paws::KinesisAnalytics::Input>)
140              
141             Each argument is described in detail in: L<Paws::KinesisAnalytics::AddApplicationInput>
142              
143             Returns: a L<Paws::KinesisAnalytics::AddApplicationInputResponse> instance
144              
145             Adds a streaming source to your Amazon Kinesis application. For
146             conceptual information, see Configuring Application Input.
147              
148             You can add a streaming source either when you create an application or
149             you can use this operation to add a streaming source after you create
150             an application. For more information, see CreateApplication.
151              
152             Any configuration update, including adding a streaming source using
153             this operation, results in a new version of the application. You can
154             use the DescribeApplication operation to find the current application
155             version.
156              
157             This operation requires permissions to perform the
158             C<kinesisanalytics:AddApplicationInput> action.
159              
160              
161             =head2 AddApplicationOutput(ApplicationName => Str, CurrentApplicationVersionId => Int, Output => L<Paws::KinesisAnalytics::Output>)
162              
163             Each argument is described in detail in: L<Paws::KinesisAnalytics::AddApplicationOutput>
164              
165             Returns: a L<Paws::KinesisAnalytics::AddApplicationOutputResponse> instance
166              
167             Adds an external destination to your Amazon Kinesis Analytics
168             application.
169              
170             If you want Amazon Kinesis Analytics to deliver data from an
171             in-application stream within your application to an external
172             destination (such as an Amazon Kinesis stream or a Firehose delivery
173             stream), you add the relevant configuration to your application using
174             this operation. You can configure one or more outputs for your
175             application. Each output configuration maps an in-application stream
176             and an external destination.
177              
178             You can use one of the output configurations to deliver data from your
179             in-application error stream to an external destination so that you can
180             analyze the errors. For conceptual information, see Understanding
181             Application Output (Destination).
182              
183             Note that any configuration update, including adding a streaming source
184             using this operation, results in a new version of the application. You
185             can use the DescribeApplication operation to find the current
186             application version.
187              
188             For the limits on the number of application inputs and outputs you can
189             configure, see Limits.
190              
191             This operation requires permissions to perform the
192             C<kinesisanalytics:AddApplicationOutput> action.
193              
194              
195             =head2 AddApplicationReferenceDataSource(ApplicationName => Str, CurrentApplicationVersionId => Int, ReferenceDataSource => L<Paws::KinesisAnalytics::ReferenceDataSource>)
196              
197             Each argument is described in detail in: L<Paws::KinesisAnalytics::AddApplicationReferenceDataSource>
198              
199             Returns: a L<Paws::KinesisAnalytics::AddApplicationReferenceDataSourceResponse> instance
200              
201             Adds a reference data source to an existing application.
202              
203             Amazon Kinesis Analytics reads reference data (that is, an Amazon S3
204             object) and creates an in-application table within your application. In
205             the request, you provide the source (S3 bucket name and object key
206             name), name of the in-application table to create, and the necessary
207             mapping information that describes how data in Amazon S3 object maps to
208             columns in the resulting in-application table.
209              
210             For conceptual information, see Configuring Application Input. For the
211             limits on data sources you can add to your application, see Limits.
212              
213             This operation requires permissions to perform the
214             C<kinesisanalytics:AddApplicationOutput> action.
215              
216              
217             =head2 CreateApplication(ApplicationName => Str, [ApplicationCode => Str, ApplicationDescription => Str, CloudWatchLoggingOptions => ArrayRef[L<Paws::KinesisAnalytics::CloudWatchLoggingOption>], Inputs => ArrayRef[L<Paws::KinesisAnalytics::Input>], Outputs => ArrayRef[L<Paws::KinesisAnalytics::Output>]])
218              
219             Each argument is described in detail in: L<Paws::KinesisAnalytics::CreateApplication>
220              
221             Returns: a L<Paws::KinesisAnalytics::CreateApplicationResponse> instance
222              
223             Creates an Amazon Kinesis Analytics application. You can configure each
224             application with one streaming source as input, application code to
225             process the input, and up to five streaming destinations where you want
226             Amazon Kinesis Analytics to write the output data from your
227             application. For an overview, see How it Works.
228              
229             In the input configuration, you map the streaming source to an
230             in-application stream, which you can think of as a constantly updating
231             table. In the mapping, you must provide a schema for the in-application
232             stream and map each data column in the in-application stream to a data
233             element in the streaming source.
234              
235             Your application code is one or more SQL statements that read input
236             data, transform it, and generate output. Your application code can
237             create one or more SQL artifacts like SQL streams or pumps.
238              
239             In the output configuration, you can configure the application to write
240             data from in-application streams created in your applications to up to
241             five streaming destinations.
242              
243             To read data from your source stream or write data to destination
244             streams, Amazon Kinesis Analytics needs your permissions. You grant
245             these permissions by creating IAM roles. This operation requires
246             permissions to perform the C<kinesisanalytics:CreateApplication>
247             action.
248              
249             For introductory exercises to create an Amazon Kinesis Analytics
250             application, see Getting Started.
251              
252              
253             =head2 DeleteApplication(ApplicationName => Str, CreateTimestamp => Str)
254              
255             Each argument is described in detail in: L<Paws::KinesisAnalytics::DeleteApplication>
256              
257             Returns: a L<Paws::KinesisAnalytics::DeleteApplicationResponse> instance
258              
259             Deletes the specified application. Amazon Kinesis Analytics halts
260             application execution and deletes the application, including any
261             application artifacts (such as in-application streams, reference table,
262             and application code).
263              
264             This operation requires permissions to perform the
265             C<kinesisanalytics:DeleteApplication> action.
266              
267              
268             =head2 DeleteApplicationCloudWatchLoggingOption(ApplicationName => Str, CloudWatchLoggingOptionId => Str, CurrentApplicationVersionId => Int)
269              
270             Each argument is described in detail in: L<Paws::KinesisAnalytics::DeleteApplicationCloudWatchLoggingOption>
271              
272             Returns: a L<Paws::KinesisAnalytics::DeleteApplicationCloudWatchLoggingOptionResponse> instance
273              
274             Deletes a CloudWatch log stream from an application. For more
275             information about using CloudWatch log streams with Amazon Kinesis
276             Analytics applications, see Monitoring Configuration Errors.
277              
278              
279             =head2 DeleteApplicationOutput(ApplicationName => Str, CurrentApplicationVersionId => Int, OutputId => Str)
280              
281             Each argument is described in detail in: L<Paws::KinesisAnalytics::DeleteApplicationOutput>
282              
283             Returns: a L<Paws::KinesisAnalytics::DeleteApplicationOutputResponse> instance
284              
285             Deletes output destination configuration from your application
286             configuration. Amazon Kinesis Analytics will no longer write data from
287             the corresponding in-application stream to the external output
288             destination.
289              
290             This operation requires permissions to perform the
291             C<kinesisanalytics:DeleteApplicationOutput> action.
292              
293              
294             =head2 DeleteApplicationReferenceDataSource(ApplicationName => Str, CurrentApplicationVersionId => Int, ReferenceId => Str)
295              
296             Each argument is described in detail in: L<Paws::KinesisAnalytics::DeleteApplicationReferenceDataSource>
297              
298             Returns: a L<Paws::KinesisAnalytics::DeleteApplicationReferenceDataSourceResponse> instance
299              
300             Deletes a reference data source configuration from the specified
301             application configuration.
302              
303             If the application is running, Amazon Kinesis Analytics immediately
304             removes the in-application table that you created using the
305             AddApplicationReferenceDataSource operation.
306              
307             This operation requires permissions to perform the
308             C<kinesisanalytics.DeleteApplicationReferenceDataSource> action.
309              
310              
311             =head2 DescribeApplication(ApplicationName => Str)
312              
313             Each argument is described in detail in: L<Paws::KinesisAnalytics::DescribeApplication>
314              
315             Returns: a L<Paws::KinesisAnalytics::DescribeApplicationResponse> instance
316              
317             Returns information about a specific Amazon Kinesis Analytics
318             application.
319              
320             If you want to retrieve a list of all applications in your account, use
321             the ListApplications operation.
322              
323             This operation requires permissions to perform the
324             C<kinesisanalytics:DescribeApplication> action. You can use
325             C<DescribeApplication> to get the current application versionId, which
326             you need to call other operations such as C<Update>.
327              
328              
329             =head2 DiscoverInputSchema(InputStartingPositionConfiguration => L<Paws::KinesisAnalytics::InputStartingPositionConfiguration>, ResourceARN => Str, RoleARN => Str)
330              
331             Each argument is described in detail in: L<Paws::KinesisAnalytics::DiscoverInputSchema>
332              
333             Returns: a L<Paws::KinesisAnalytics::DiscoverInputSchemaResponse> instance
334              
335             Infers a schema by evaluating sample records on the specified streaming
336             source (Amazon Kinesis stream or Amazon Kinesis Firehose delivery
337             stream). In the response, the operation returns the inferred schema and
338             also the sample records that the operation used to infer the schema.
339              
340             You can use the inferred schema when configuring a streaming source for
341             your application. For conceptual information, see Configuring
342             Application Input. Note that when you create an application using the
343             Amazon Kinesis Analytics console, the console uses this operation to
344             infer a schema and show it in the console user interface.
345              
346             This operation requires permissions to perform the
347             C<kinesisanalytics:DiscoverInputSchema> action.
348              
349              
350             =head2 ListApplications([ExclusiveStartApplicationName => Str, Limit => Int])
351              
352             Each argument is described in detail in: L<Paws::KinesisAnalytics::ListApplications>
353              
354             Returns: a L<Paws::KinesisAnalytics::ListApplicationsResponse> instance
355              
356             Returns a list of Amazon Kinesis Analytics applications in your
357             account. For each application, the response includes the application
358             name, Amazon Resource Name (ARN), and status. If the response returns
359             the C<HasMoreApplications> value as true, you can send another request
360             by adding the C<ExclusiveStartApplicationName> in the request body, and
361             set the value of this to the last application name from the previous
362             response.
363              
364             If you want detailed information about a specific application, use
365             DescribeApplication.
366              
367             This operation requires permissions to perform the
368             C<kinesisanalytics:ListApplications> action.
369              
370              
371             =head2 StartApplication(ApplicationName => Str, InputConfigurations => ArrayRef[L<Paws::KinesisAnalytics::InputConfiguration>])
372              
373             Each argument is described in detail in: L<Paws::KinesisAnalytics::StartApplication>
374              
375             Returns: a L<Paws::KinesisAnalytics::StartApplicationResponse> instance
376              
377             Starts the specified Amazon Kinesis Analytics application. After
378             creating an application, you must exclusively call this operation to
379             start your application.
380              
381             After the application starts, it begins consuming the input data,
382             processes it, and writes the output to the configured destination.
383              
384             The application status must be C<READY> for you to start an
385             application. You can get the application status in the console or using
386             the DescribeApplication operation.
387              
388             After you start the application, you can stop the application from
389             processing the input by calling the StopApplication operation.
390              
391             This operation requires permissions to perform the
392             C<kinesisanalytics:StartApplication> action.
393              
394              
395             =head2 StopApplication(ApplicationName => Str)
396              
397             Each argument is described in detail in: L<Paws::KinesisAnalytics::StopApplication>
398              
399             Returns: a L<Paws::KinesisAnalytics::StopApplicationResponse> instance
400              
401             Stops the application from processing input data. You can stop an
402             application only if it is in the running state. You can use the
403             DescribeApplication operation to find the application state. After the
404             application is stopped, Amazon Kinesis Analytics stops reading data
405             from the input, the application stops processing data, and there is no
406             output written to the destination.
407              
408             This operation requires permissions to perform the
409             C<kinesisanalytics:StopApplication> action.
410              
411              
412             =head2 UpdateApplication(ApplicationName => Str, ApplicationUpdate => L<Paws::KinesisAnalytics::ApplicationUpdate>, CurrentApplicationVersionId => Int)
413              
414             Each argument is described in detail in: L<Paws::KinesisAnalytics::UpdateApplication>
415              
416             Returns: a L<Paws::KinesisAnalytics::UpdateApplicationResponse> instance
417              
418             Updates an existing Amazon Kinesis Analytics application. Using this
419             API, you can update application code, input configuration, and output
420             configuration.
421              
422             Note that Amazon Kinesis Analytics updates the
423             C<CurrentApplicationVersionId> each time you update your application.
424              
425             This operation requires permission for the
426             C<kinesisanalytics:UpdateApplication> action.
427              
428              
429              
430              
431             =head1 PAGINATORS
432              
433             Paginator methods are helpers that repetively call methods that return partial results
434              
435              
436              
437              
438             =head1 SEE ALSO
439              
440             This service class forms part of L<Paws>
441              
442             =head1 BUGS and CONTRIBUTIONS
443              
444             The source code is located here: https://github.com/pplu/aws-sdk-perl
445              
446             Please report bugs to: https://github.com/pplu/aws-sdk-perl/issues
447              
448             =cut
449