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 Amazon Lambda.

addApplicationOutput

inline suspend fun KinesisAnalyticsV2Client.addApplicationOutput(crossinline block: AddApplicationOutputRequest.Builder.() -> Unit): AddApplicationOutputResponse

Adds an external destination to your SQL-based Kinesis Data Analytics application.

addApplicationReferenceDataSource

inline suspend fun KinesisAnalyticsV2Client.addApplicationReferenceDataSource(crossinline block: AddApplicationReferenceDataSourceRequest.Builder.() -> Unit): AddApplicationReferenceDataSourceResponse

Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.

addApplicationVpcConfiguration

inline suspend fun KinesisAnalyticsV2Client.addApplicationVpcConfiguration(crossinline block: AddApplicationVpcConfigurationRequest.Builder.() -> Unit): AddApplicationVpcConfigurationResponse

Adds a Virtual Private Cloud (VPC) configuration to the application. Applications can use VPCs to store and access resources securely.

createApplication

inline suspend fun KinesisAnalyticsV2Client.createApplication(crossinline block: CreateApplicationRequest.Builder.() -> Unit): CreateApplicationResponse

Creates a Managed Service for Apache Flink application. For information about creating a Managed Service for Apache Flink application, see Creating an Application.

createApplicationPresignedUrl

inline suspend fun KinesisAnalyticsV2Client.createApplicationPresignedUrl(crossinline block: CreateApplicationPresignedUrlRequest.Builder.() -> Unit): CreateApplicationPresignedUrlResponse

Creates and returns a URL that you can use to connect to an application's extension.

createApplicationSnapshot

inline suspend fun KinesisAnalyticsV2Client.createApplicationSnapshot(crossinline block: CreateApplicationSnapshotRequest.Builder.() -> Unit): CreateApplicationSnapshotResponse

Creates a snapshot of the application's state data.

deleteApplication

inline suspend fun KinesisAnalyticsV2Client.deleteApplication(crossinline block: DeleteApplicationRequest.Builder.() -> Unit): DeleteApplicationResponse

Deletes the specified application. Managed Service for Apache Flink halts application execution and deletes the application.

deleteApplicationCloudWatchLoggingOption

inline suspend fun KinesisAnalyticsV2Client.deleteApplicationCloudWatchLoggingOption(crossinline block: DeleteApplicationCloudWatchLoggingOptionRequest.Builder.() -> Unit): DeleteApplicationCloudWatchLoggingOptionResponse

Deletes an Amazon CloudWatch log stream from an SQL-based Kinesis Data Analytics application.

deleteApplicationInputProcessingConfiguration

inline suspend fun KinesisAnalyticsV2Client.deleteApplicationInputProcessingConfiguration(crossinline block: DeleteApplicationInputProcessingConfigurationRequest.Builder.() -> Unit): DeleteApplicationInputProcessingConfigurationResponse

Deletes an InputProcessingConfiguration from an input.

deleteApplicationOutput

inline suspend fun KinesisAnalyticsV2Client.deleteApplicationOutput(crossinline block: DeleteApplicationOutputRequest.Builder.() -> Unit): 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

inline suspend fun KinesisAnalyticsV2Client.deleteApplicationReferenceDataSource(crossinline block: DeleteApplicationReferenceDataSourceRequest.Builder.() -> Unit): DeleteApplicationReferenceDataSourceResponse

Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's configuration.

deleteApplicationSnapshot

inline suspend fun KinesisAnalyticsV2Client.deleteApplicationSnapshot(crossinline block: DeleteApplicationSnapshotRequest.Builder.() -> Unit): DeleteApplicationSnapshotResponse

Deletes a snapshot of application state.

deleteApplicationVpcConfiguration

inline suspend fun KinesisAnalyticsV2Client.deleteApplicationVpcConfiguration(crossinline block: DeleteApplicationVpcConfigurationRequest.Builder.() -> Unit): DeleteApplicationVpcConfigurationResponse

Removes a VPC configuration from a Managed Service for Apache Flink application.

describeApplication

inline suspend fun KinesisAnalyticsV2Client.describeApplication(crossinline block: DescribeApplicationRequest.Builder.() -> Unit): DescribeApplicationResponse

Returns information about a specific Managed Service for Apache Flink application.

describeApplicationOperation

inline suspend fun KinesisAnalyticsV2Client.describeApplicationOperation(crossinline block: DescribeApplicationOperationRequest.Builder.() -> Unit): DescribeApplicationOperationResponse

Returns information about a specific operation performed on a Managed Service for Apache Flink application

describeApplicationSnapshot

inline suspend fun KinesisAnalyticsV2Client.describeApplicationSnapshot(crossinline block: DescribeApplicationSnapshotRequest.Builder.() -> Unit): DescribeApplicationSnapshotResponse

Returns information about a snapshot of application state data.

describeApplicationVersion

inline suspend fun KinesisAnalyticsV2Client.describeApplicationVersion(crossinline block: DescribeApplicationVersionRequest.Builder.() -> Unit): DescribeApplicationVersionResponse

Provides a detailed description of a specified version of the application. To see a list of all the versions of an application, invoke the ListApplicationVersions operation.

discoverInputSchema

inline suspend fun KinesisAnalyticsV2Client.discoverInputSchema(crossinline block: DiscoverInputSchemaRequest.Builder.() -> Unit): 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.

listApplicationOperations

inline suspend fun KinesisAnalyticsV2Client.listApplicationOperations(crossinline block: ListApplicationOperationsRequest.Builder.() -> Unit): ListApplicationOperationsResponse

Lists information about operations performed on a Managed Service for Apache Flink application

listApplications

inline suspend fun KinesisAnalyticsV2Client.listApplications(crossinline block: ListApplicationsRequest.Builder.() -> Unit): ListApplicationsResponse

Returns a list of Managed Service for Apache Flink applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status.

listApplicationSnapshots

inline suspend fun KinesisAnalyticsV2Client.listApplicationSnapshots(crossinline block: ListApplicationSnapshotsRequest.Builder.() -> Unit): ListApplicationSnapshotsResponse

Lists information about the current application snapshots.

listApplicationVersions

inline suspend fun KinesisAnalyticsV2Client.listApplicationVersions(crossinline block: ListApplicationVersionsRequest.Builder.() -> Unit): ListApplicationVersionsResponse

Lists all the versions for the specified application, including versions that were rolled back. The response also includes a summary of the configuration associated with each version.

listTagsForResource

inline suspend fun KinesisAnalyticsV2Client.listTagsForResource(crossinline block: ListTagsForResourceRequest.Builder.() -> Unit): ListTagsForResourceResponse

Retrieves the list of key-value tags assigned to the application. For more information, see Using Tagging.

rollbackApplication

inline suspend fun KinesisAnalyticsV2Client.rollbackApplication(crossinline block: RollbackApplicationRequest.Builder.() -> Unit): RollbackApplicationResponse

Reverts the application to the previous running version. You can roll back an application if you suspect it is stuck in a transient status or in the running status.

startApplication

inline suspend fun KinesisAnalyticsV2Client.startApplication(crossinline block: StartApplicationRequest.Builder.() -> Unit): StartApplicationResponse

Starts the specified Managed Service for Apache Flink application. After creating an application, you must exclusively call this operation to start your application.

stopApplication

inline suspend fun KinesisAnalyticsV2Client.stopApplication(crossinline block: StopApplicationRequest.Builder.() -> Unit): StopApplicationResponse

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

inline suspend fun KinesisAnalyticsV2Client.tagResource(crossinline block: TagResourceRequest.Builder.() -> Unit): TagResourceResponse

Adds one or more key-value tags to a Managed Service for Apache Flink 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.

untagResource

inline suspend fun KinesisAnalyticsV2Client.untagResource(crossinline block: UntagResourceRequest.Builder.() -> Unit): UntagResourceResponse

Removes one or more tags from a Managed Service for Apache Flink application. For more information, see Using Tagging.

updateApplication

inline suspend fun KinesisAnalyticsV2Client.updateApplication(crossinline block: UpdateApplicationRequest.Builder.() -> Unit): UpdateApplicationResponse

Updates an existing Managed Service for Apache Flink application. Using this operation, you can update application code, input configuration, and output configuration.

updateApplicationMaintenanceConfiguration

inline suspend fun KinesisAnalyticsV2Client.updateApplicationMaintenanceConfiguration(crossinline block: UpdateApplicationMaintenanceConfigurationRequest.Builder.() -> Unit): UpdateApplicationMaintenanceConfigurationResponse

Updates the maintenance configuration of the Managed Service for Apache Flink application.

withConfig

fun KinesisAnalyticsV2Client.withConfig(block: KinesisAnalyticsV2Client.Config.Builder.() -> Unit): KinesisAnalyticsV2Client

Create a copy of the client with one or more configuration values overridden. This method allows the caller to perform scoped config overrides for one or more client operations.