KinesisAnalyticsV2 class

Amazon Kinesis Data Analytics is a fully managed service that you can use to process and analyze streaming data using Java, SQL, or Scala. The service enables you to quickly author and run Java, SQL, or Scala code against streaming sources to perform time series analytics, feed real-time dashboards, and create real-time metrics.

Constructors

KinesisAnalyticsV2({required String region, AwsClientCredentials? credentials, AwsClientCredentialsProvider? credentialsProvider, Client? client, String? endpointUrl})

Properties

hashCode → int
The hash code for this object.
no setterinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited

Methods

addApplicationCloudWatchLoggingOption({required String applicationName, required CloudWatchLoggingOption cloudWatchLoggingOption, required int currentApplicationVersionId}) → Future<AddApplicationCloudWatchLoggingOptionResponse>
Adds an Amazon CloudWatch log stream to monitor application configuration errors.
addApplicationInput({required String applicationName, required int currentApplicationVersionId, required Input input}) → Future<AddApplicationInputResponse>
Adds a streaming source to your SQL-based Kinesis Data Analytics application.
addApplicationInputProcessingConfiguration({required String applicationName, required int currentApplicationVersionId, required String inputId, required InputProcessingConfiguration inputProcessingConfiguration}) → Future<AddApplicationInputProcessingConfigurationResponse>
Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application. An input processor pre-processes records on the input stream before the application's SQL code executes. Currently, the only input processor available is AWS Lambda.
addApplicationOutput({required String applicationName, required int currentApplicationVersionId, required Output output}) → Future<AddApplicationOutputResponse>
Adds an external destination to your SQL-based Kinesis Data Analytics application.
addApplicationReferenceDataSource({required String applicationName, required int currentApplicationVersionId, required ReferenceDataSource referenceDataSource}) → Future<AddApplicationReferenceDataSourceResponse>
Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.
addApplicationVpcConfiguration({required String applicationName, required int currentApplicationVersionId, required VpcConfiguration vpcConfiguration}) → Future<AddApplicationVpcConfigurationResponse>
Adds a Virtual Private Cloud (VPC) configuration to the application. Applications can use VPCs to store and access resources securely.
close() → void
Closes the internal HTTP client if none was provided at creation. If a client was passed as a constructor argument, this becomes a noop.
createApplication({required String applicationName, required RuntimeEnvironment runtimeEnvironment, required String serviceExecutionRole, ApplicationConfiguration? applicationConfiguration, String? applicationDescription, List<CloudWatchLoggingOption>? cloudWatchLoggingOptions, List<Tag>? tags}) → Future<CreateApplicationResponse>
Creates a Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics application, see Creating an Application.
createApplicationPresignedUrl({required String applicationName, required UrlType urlType, int? sessionExpirationDurationInSeconds}) → Future<CreateApplicationPresignedUrlResponse>
Creates and returns a URL that you can use to connect to an application's extension. Currently, the only available extension is the Apache Flink dashboard.
createApplicationSnapshot({required String applicationName, required String snapshotName}) → Future<void>
Creates a snapshot of the application's state data.
deleteApplication({required String applicationName, required DateTime createTimestamp}) → Future<void>
Deletes the specified application. Kinesis Data Analytics halts application execution and deletes the application.
deleteApplicationCloudWatchLoggingOption({required String applicationName, required String cloudWatchLoggingOptionId, required int currentApplicationVersionId}) → Future<DeleteApplicationCloudWatchLoggingOptionResponse>
Deletes an Amazon CloudWatch log stream from an Kinesis Data Analytics application.
deleteApplicationInputProcessingConfiguration({required String applicationName, required int currentApplicationVersionId, required String inputId}) → Future<DeleteApplicationInputProcessingConfigurationResponse>
Deletes an InputProcessingConfiguration from an input.
deleteApplicationOutput({required String applicationName, required int currentApplicationVersionId, required String outputId}) → Future<DeleteApplicationOutputResponse>
Deletes the output destination configuration from your SQL-based Kinesis Data Analytics application's configuration. Kinesis Data Analytics will no longer write data from the corresponding in-application stream to the external output destination.
deleteApplicationReferenceDataSource({required String applicationName, required int currentApplicationVersionId, required String referenceId}) → Future<DeleteApplicationReferenceDataSourceResponse>
Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's configuration.
deleteApplicationSnapshot({required String applicationName, required DateTime snapshotCreationTimestamp, required String snapshotName}) → Future<void>
Deletes a snapshot of application state.
deleteApplicationVpcConfiguration({required String applicationName, required int currentApplicationVersionId, required String vpcConfigurationId}) → Future<DeleteApplicationVpcConfigurationResponse>
Removes a VPC configuration from a Kinesis Data Analytics application.
describeApplication({required String applicationName, bool? includeAdditionalDetails}) → Future<DescribeApplicationResponse>
Returns information about a specific Kinesis Data Analytics application.
describeApplicationSnapshot({required String applicationName, required String snapshotName}) → Future<DescribeApplicationSnapshotResponse>
Returns information about a snapshot of application state data.
discoverInputSchema({required String serviceExecutionRole, InputProcessingConfiguration? inputProcessingConfiguration, InputStartingPositionConfiguration? inputStartingPositionConfiguration, String? resourceARN, S3Configuration? s3Configuration}) → Future<DiscoverInputSchemaResponse>
Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object. In the response, the operation returns the inferred schema and also the sample records that the operation used to infer the schema.
listApplications({int? limit, String? nextToken}) → Future<ListApplicationsResponse>
Returns a list of Kinesis Data Analytics applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status.
listApplicationSnapshots({required String applicationName, int? limit, String? nextToken}) → Future<ListApplicationSnapshotsResponse>
Lists information about the current application snapshots.
listTagsForResource({required String resourceARN}) → Future<ListTagsForResourceResponse>
Retrieves the list of key-value tags assigned to the application. For more information, see Using Tagging.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
startApplication({required String applicationName, required RunConfiguration runConfiguration}) → Future<void>
Starts the specified Kinesis Data Analytics application. After creating an application, you must exclusively call this operation to start your application.
stopApplication({required String applicationName, bool? force}) → Future<void>
Stops the application from processing data. You can stop an application only if it is in the running status, unless you set the Force parameter to true.
tagResource({required String resourceARN, required List<Tag> tags}) → Future<void>
Adds one or more key-value tags to a Kinesis Data Analytics application. Note that the maximum number of application tags includes system tags. The maximum number of user-defined application tags is 50. For more information, see Using Tagging.
toString() → String
A string representation of this object.
inherited
untagResource({required String resourceARN, required List<String> tagKeys}) → Future<void>
Removes one or more tags from a Kinesis Data Analytics application. For more information, see Using Tagging.
updateApplication({required String applicationName, required int currentApplicationVersionId, ApplicationConfigurationUpdate? applicationConfigurationUpdate, List<CloudWatchLoggingOptionUpdate>? cloudWatchLoggingOptionUpdates, RunConfigurationUpdate? runConfigurationUpdate, String? serviceExecutionRoleUpdate}) → Future<UpdateApplicationResponse>
Updates an existing Kinesis Data Analytics application. Using this operation, you can update application code, input configuration, and output configuration.

Operators

operator ==(Object other) → bool
The equality operator.
inherited