@Generated(value="software.amazon.awssdk:codegen") public interface KinesisAnalyticsV2AsyncClient extends SdkClient
builder()
method.
Documentation for Kinesis Data Analytics API v2
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<AddApplicationCloudWatchLoggingOptionResponse> |
addApplicationCloudWatchLoggingOption(AddApplicationCloudWatchLoggingOptionRequest addApplicationCloudWatchLoggingOptionRequest)
Adds an Amazon CloudWatch log stream to monitor application configuration errors.
|
default CompletableFuture<AddApplicationCloudWatchLoggingOptionResponse> |
addApplicationCloudWatchLoggingOption(Consumer<AddApplicationCloudWatchLoggingOptionRequest.Builder> addApplicationCloudWatchLoggingOptionRequest)
Adds an Amazon CloudWatch log stream to monitor application configuration errors.
|
default CompletableFuture<AddApplicationInputResponse> |
addApplicationInput(AddApplicationInputRequest addApplicationInputRequest)
Adds a streaming source to your SQL-based Amazon Kinesis Data Analytics application.
|
default CompletableFuture<AddApplicationInputResponse> |
addApplicationInput(Consumer<AddApplicationInputRequest.Builder> addApplicationInputRequest)
Adds a streaming source to your SQL-based Amazon Kinesis Data Analytics application.
|
default CompletableFuture<AddApplicationInputProcessingConfigurationResponse> |
addApplicationInputProcessingConfiguration(AddApplicationInputProcessingConfigurationRequest addApplicationInputProcessingConfigurationRequest)
Adds an InputProcessingConfiguration to an SQL-based Kinesis Data Analytics application.
|
default CompletableFuture<AddApplicationInputProcessingConfigurationResponse> |
addApplicationInputProcessingConfiguration(Consumer<AddApplicationInputProcessingConfigurationRequest.Builder> addApplicationInputProcessingConfigurationRequest)
Adds an InputProcessingConfiguration to an SQL-based Kinesis Data Analytics application.
|
default CompletableFuture<AddApplicationOutputResponse> |
addApplicationOutput(AddApplicationOutputRequest addApplicationOutputRequest)
Adds an external destination to your SQL-based Amazon Kinesis Data Analytics application.
|
default CompletableFuture<AddApplicationOutputResponse> |
addApplicationOutput(Consumer<AddApplicationOutputRequest.Builder> addApplicationOutputRequest)
Adds an external destination to your SQL-based Amazon Kinesis Data Analytics application.
|
default CompletableFuture<AddApplicationReferenceDataSourceResponse> |
addApplicationReferenceDataSource(AddApplicationReferenceDataSourceRequest addApplicationReferenceDataSourceRequest)
Adds a reference data source to an existing SQL-based Amazon Kinesis Data Analytics application.
|
default CompletableFuture<AddApplicationReferenceDataSourceResponse> |
addApplicationReferenceDataSource(Consumer<AddApplicationReferenceDataSourceRequest.Builder> addApplicationReferenceDataSourceRequest)
Adds a reference data source to an existing SQL-based Amazon Kinesis Data Analytics application.
|
static KinesisAnalyticsV2AsyncClientBuilder |
builder()
Create a builder that can be used to configure and create a
KinesisAnalyticsV2AsyncClient . |
static KinesisAnalyticsV2AsyncClient |
create()
Create a
KinesisAnalyticsV2AsyncClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider . |
default CompletableFuture<CreateApplicationResponse> |
createApplication(Consumer<CreateApplicationRequest.Builder> createApplicationRequest)
Creates an Amazon Kinesis Data Analytics application.
|
default CompletableFuture<CreateApplicationResponse> |
createApplication(CreateApplicationRequest createApplicationRequest)
Creates an Amazon Kinesis Data Analytics application.
|
default CompletableFuture<CreateApplicationSnapshotResponse> |
createApplicationSnapshot(Consumer<CreateApplicationSnapshotRequest.Builder> createApplicationSnapshotRequest)
Creates a snapshot of the application's state data.
|
default CompletableFuture<CreateApplicationSnapshotResponse> |
createApplicationSnapshot(CreateApplicationSnapshotRequest createApplicationSnapshotRequest)
Creates a snapshot of the application's state data.
|
default CompletableFuture<DeleteApplicationResponse> |
deleteApplication(Consumer<DeleteApplicationRequest.Builder> deleteApplicationRequest)
Deletes the specified application.
|
default CompletableFuture<DeleteApplicationResponse> |
deleteApplication(DeleteApplicationRequest deleteApplicationRequest)
Deletes the specified application.
|
default CompletableFuture<DeleteApplicationCloudWatchLoggingOptionResponse> |
deleteApplicationCloudWatchLoggingOption(Consumer<DeleteApplicationCloudWatchLoggingOptionRequest.Builder> deleteApplicationCloudWatchLoggingOptionRequest)
Deletes an Amazon CloudWatch log stream from an Amazon Kinesis Data Analytics application.
|
default CompletableFuture<DeleteApplicationCloudWatchLoggingOptionResponse> |
deleteApplicationCloudWatchLoggingOption(DeleteApplicationCloudWatchLoggingOptionRequest deleteApplicationCloudWatchLoggingOptionRequest)
Deletes an Amazon CloudWatch log stream from an Amazon Kinesis Data Analytics application.
|
default CompletableFuture<DeleteApplicationInputProcessingConfigurationResponse> |
deleteApplicationInputProcessingConfiguration(Consumer<DeleteApplicationInputProcessingConfigurationRequest.Builder> deleteApplicationInputProcessingConfigurationRequest)
Deletes an InputProcessingConfiguration from an input.
|
default CompletableFuture<DeleteApplicationInputProcessingConfigurationResponse> |
deleteApplicationInputProcessingConfiguration(DeleteApplicationInputProcessingConfigurationRequest deleteApplicationInputProcessingConfigurationRequest)
Deletes an InputProcessingConfiguration from an input.
|
default CompletableFuture<DeleteApplicationOutputResponse> |
deleteApplicationOutput(Consumer<DeleteApplicationOutputRequest.Builder> deleteApplicationOutputRequest)
Deletes the output destination configuration from your SQL-based Amazon Kinesis Data Analytics application's
configuration.
|
default CompletableFuture<DeleteApplicationOutputResponse> |
deleteApplicationOutput(DeleteApplicationOutputRequest deleteApplicationOutputRequest)
Deletes the output destination configuration from your SQL-based Amazon Kinesis Data Analytics application's
configuration.
|
default CompletableFuture<DeleteApplicationReferenceDataSourceResponse> |
deleteApplicationReferenceDataSource(Consumer<DeleteApplicationReferenceDataSourceRequest.Builder> deleteApplicationReferenceDataSourceRequest)
Deletes a reference data source configuration from the specified SQL-based Amazon Kinesis Data Analytics
application's configuration.
|
default CompletableFuture<DeleteApplicationReferenceDataSourceResponse> |
deleteApplicationReferenceDataSource(DeleteApplicationReferenceDataSourceRequest deleteApplicationReferenceDataSourceRequest)
Deletes a reference data source configuration from the specified SQL-based Amazon Kinesis Data Analytics
application's configuration.
|
default CompletableFuture<DeleteApplicationSnapshotResponse> |
deleteApplicationSnapshot(Consumer<DeleteApplicationSnapshotRequest.Builder> deleteApplicationSnapshotRequest)
Deletes a snapshot of application state.
|
default CompletableFuture<DeleteApplicationSnapshotResponse> |
deleteApplicationSnapshot(DeleteApplicationSnapshotRequest deleteApplicationSnapshotRequest)
Deletes a snapshot of application state.
|
default CompletableFuture<DescribeApplicationResponse> |
describeApplication(Consumer<DescribeApplicationRequest.Builder> describeApplicationRequest)
Returns information about a specific Amazon Kinesis Data Analytics application.
|
default CompletableFuture<DescribeApplicationResponse> |
describeApplication(DescribeApplicationRequest describeApplicationRequest)
Returns information about a specific Amazon Kinesis Data Analytics application.
|
default CompletableFuture<DescribeApplicationSnapshotResponse> |
describeApplicationSnapshot(Consumer<DescribeApplicationSnapshotRequest.Builder> describeApplicationSnapshotRequest)
Returns information about a snapshot of application state data.
|
default CompletableFuture<DescribeApplicationSnapshotResponse> |
describeApplicationSnapshot(DescribeApplicationSnapshotRequest describeApplicationSnapshotRequest)
Returns information about a snapshot of application state data.
|
default CompletableFuture<DiscoverInputSchemaResponse> |
discoverInputSchema(Consumer<DiscoverInputSchemaRequest.Builder> discoverInputSchemaRequest)
Infers a schema for an SQL-based Amazon 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.
|
default CompletableFuture<DiscoverInputSchemaResponse> |
discoverInputSchema(DiscoverInputSchemaRequest discoverInputSchemaRequest)
Infers a schema for an SQL-based Amazon 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.
|
default CompletableFuture<ListApplicationsResponse> |
listApplications()
Returns a list of Amazon Kinesis Data Analytics applications in your account.
|
default CompletableFuture<ListApplicationsResponse> |
listApplications(Consumer<ListApplicationsRequest.Builder> listApplicationsRequest)
Returns a list of Amazon Kinesis Data Analytics applications in your account.
|
default CompletableFuture<ListApplicationsResponse> |
listApplications(ListApplicationsRequest listApplicationsRequest)
Returns a list of Amazon Kinesis Data Analytics applications in your account.
|
default CompletableFuture<ListApplicationSnapshotsResponse> |
listApplicationSnapshots(Consumer<ListApplicationSnapshotsRequest.Builder> listApplicationSnapshotsRequest)
Lists information about the current application snapshots.
|
default CompletableFuture<ListApplicationSnapshotsResponse> |
listApplicationSnapshots(ListApplicationSnapshotsRequest listApplicationSnapshotsRequest)
Lists information about the current application snapshots.
|
default CompletableFuture<StartApplicationResponse> |
startApplication(Consumer<StartApplicationRequest.Builder> startApplicationRequest)
Starts the specified Amazon Kinesis Data Analytics application.
|
default CompletableFuture<StartApplicationResponse> |
startApplication(StartApplicationRequest startApplicationRequest)
Starts the specified Amazon Kinesis Data Analytics application.
|
default CompletableFuture<StopApplicationResponse> |
stopApplication(Consumer<StopApplicationRequest.Builder> stopApplicationRequest)
Stops the application from processing data.
|
default CompletableFuture<StopApplicationResponse> |
stopApplication(StopApplicationRequest stopApplicationRequest)
Stops the application from processing data.
|
default CompletableFuture<UpdateApplicationResponse> |
updateApplication(Consumer<UpdateApplicationRequest.Builder> updateApplicationRequest)
Updates an existing Amazon Kinesis Data Analytics application.
|
default CompletableFuture<UpdateApplicationResponse> |
updateApplication(UpdateApplicationRequest updateApplicationRequest)
Updates an existing Amazon Kinesis Data Analytics application.
|
serviceName
close
static final String SERVICE_NAME
static KinesisAnalyticsV2AsyncClient create()
KinesisAnalyticsV2AsyncClient
with the region loaded from the
DefaultAwsRegionProviderChain
and credentials loaded from the
DefaultCredentialsProvider
.static KinesisAnalyticsV2AsyncClientBuilder builder()
KinesisAnalyticsV2AsyncClient
.default CompletableFuture<AddApplicationCloudWatchLoggingOptionResponse> addApplicationCloudWatchLoggingOption(AddApplicationCloudWatchLoggingOptionRequest addApplicationCloudWatchLoggingOptionRequest)
Adds an Amazon CloudWatch log stream to monitor application configuration errors.
addApplicationCloudWatchLoggingOptionRequest
- default CompletableFuture<AddApplicationCloudWatchLoggingOptionResponse> addApplicationCloudWatchLoggingOption(Consumer<AddApplicationCloudWatchLoggingOptionRequest.Builder> addApplicationCloudWatchLoggingOptionRequest)
Adds an Amazon CloudWatch log stream to monitor application configuration errors.
This is a convenience which creates an instance of the
AddApplicationCloudWatchLoggingOptionRequest.Builder
avoiding the need to create one manually via
AddApplicationCloudWatchLoggingOptionRequest.builder()
addApplicationCloudWatchLoggingOptionRequest
- A Consumer
that will call methods on AddApplicationCloudWatchLoggingOptionRequest.Builder
to create a request.default CompletableFuture<AddApplicationInputResponse> addApplicationInput(AddApplicationInputRequest addApplicationInputRequest)
Adds a streaming source to your SQL-based Amazon Kinesis Data Analytics application.
You can add a streaming source when you create an application, or you can use this operation to add a streaming source after you create an application. For more information, see CreateApplication.
Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the DescribeApplication operation to find the current application version.
addApplicationInputRequest
- default CompletableFuture<AddApplicationInputResponse> addApplicationInput(Consumer<AddApplicationInputRequest.Builder> addApplicationInputRequest)
Adds a streaming source to your SQL-based Amazon Kinesis Data Analytics application.
You can add a streaming source when you create an application, or you can use this operation to add a streaming source after you create an application. For more information, see CreateApplication.
Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the DescribeApplication operation to find the current application version.
This is a convenience which creates an instance of the AddApplicationInputRequest.Builder
avoiding the
need to create one manually via AddApplicationInputRequest.builder()
addApplicationInputRequest
- A Consumer
that will call methods on AddApplicationInputRequest.Builder
to create a
request.default CompletableFuture<AddApplicationInputProcessingConfigurationResponse> addApplicationInputProcessingConfiguration(AddApplicationInputProcessingConfigurationRequest addApplicationInputProcessingConfigurationRequest)
Adds an InputProcessingConfiguration to an 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.
addApplicationInputProcessingConfigurationRequest
- default CompletableFuture<AddApplicationInputProcessingConfigurationResponse> addApplicationInputProcessingConfiguration(Consumer<AddApplicationInputProcessingConfigurationRequest.Builder> addApplicationInputProcessingConfigurationRequest)
Adds an InputProcessingConfiguration to an 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.
This is a convenience which creates an instance of the
AddApplicationInputProcessingConfigurationRequest.Builder
avoiding the need to create one manually via
AddApplicationInputProcessingConfigurationRequest.builder()
addApplicationInputProcessingConfigurationRequest
- A Consumer
that will call methods on
AddApplicationInputProcessingConfigurationRequest.Builder
to create a request.default CompletableFuture<AddApplicationOutputResponse> addApplicationOutput(AddApplicationOutputRequest addApplicationOutputRequest)
Adds an external destination to your SQL-based Amazon Kinesis Data Analytics application.
If you want Kinesis Data Analytics to deliver data from an in-application stream within your application to an external destination (such as an Kinesis data stream, a Kinesis Data Firehose delivery stream, or an AWS Lambda function), you add the relevant configuration to your application using this operation. You can configure one or more outputs for your application. Each output configuration maps an in-application stream and an external destination.
You can use one of the output configurations to deliver data from your in-application error stream to an external destination so that you can analyze the errors.
Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the DescribeApplication operation to find the current application version.
addApplicationOutputRequest
- default CompletableFuture<AddApplicationOutputResponse> addApplicationOutput(Consumer<AddApplicationOutputRequest.Builder> addApplicationOutputRequest)
Adds an external destination to your SQL-based Amazon Kinesis Data Analytics application.
If you want Kinesis Data Analytics to deliver data from an in-application stream within your application to an external destination (such as an Kinesis data stream, a Kinesis Data Firehose delivery stream, or an AWS Lambda function), you add the relevant configuration to your application using this operation. You can configure one or more outputs for your application. Each output configuration maps an in-application stream and an external destination.
You can use one of the output configurations to deliver data from your in-application error stream to an external destination so that you can analyze the errors.
Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the DescribeApplication operation to find the current application version.
This is a convenience which creates an instance of the AddApplicationOutputRequest.Builder
avoiding the
need to create one manually via AddApplicationOutputRequest.builder()
addApplicationOutputRequest
- A Consumer
that will call methods on AddApplicationOutputRequest.Builder
to create a
request.default CompletableFuture<AddApplicationReferenceDataSourceResponse> addApplicationReferenceDataSource(AddApplicationReferenceDataSourceRequest addApplicationReferenceDataSourceRequest)
Adds a reference data source to an existing SQL-based Amazon Kinesis Data Analytics application.
Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an in-application table within your application. In the request, you provide the source (S3 bucket name and object key name), name of the in-application table to create, and the necessary mapping information that describes how data in an Amazon S3 object maps to columns in the resulting in-application table.
addApplicationReferenceDataSourceRequest
- default CompletableFuture<AddApplicationReferenceDataSourceResponse> addApplicationReferenceDataSource(Consumer<AddApplicationReferenceDataSourceRequest.Builder> addApplicationReferenceDataSourceRequest)
Adds a reference data source to an existing SQL-based Amazon Kinesis Data Analytics application.
Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an in-application table within your application. In the request, you provide the source (S3 bucket name and object key name), name of the in-application table to create, and the necessary mapping information that describes how data in an Amazon S3 object maps to columns in the resulting in-application table.
This is a convenience which creates an instance of the AddApplicationReferenceDataSourceRequest.Builder
avoiding the need to create one manually via AddApplicationReferenceDataSourceRequest.builder()
addApplicationReferenceDataSourceRequest
- A Consumer
that will call methods on AddApplicationReferenceDataSourceRequest.Builder
to
create a request.default CompletableFuture<CreateApplicationResponse> createApplication(CreateApplicationRequest createApplicationRequest)
Creates an Amazon Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics application, see Creating an Application.
SQL is not enabled for this private beta release. Using SQL parameters (such as SqlApplicationConfiguration) will result in an error.
createApplicationRequest
- default CompletableFuture<CreateApplicationResponse> createApplication(Consumer<CreateApplicationRequest.Builder> createApplicationRequest)
Creates an Amazon Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics application, see Creating an Application.
SQL is not enabled for this private beta release. Using SQL parameters (such as SqlApplicationConfiguration) will result in an error.
This is a convenience which creates an instance of the CreateApplicationRequest.Builder
avoiding the need
to create one manually via CreateApplicationRequest.builder()
createApplicationRequest
- A Consumer
that will call methods on CreateApplicationRequest.Builder
to create a request.default CompletableFuture<CreateApplicationSnapshotResponse> createApplicationSnapshot(CreateApplicationSnapshotRequest createApplicationSnapshotRequest)
Creates a snapshot of the application's state data.
createApplicationSnapshotRequest
- default CompletableFuture<CreateApplicationSnapshotResponse> createApplicationSnapshot(Consumer<CreateApplicationSnapshotRequest.Builder> createApplicationSnapshotRequest)
Creates a snapshot of the application's state data.
This is a convenience which creates an instance of the CreateApplicationSnapshotRequest.Builder
avoiding
the need to create one manually via CreateApplicationSnapshotRequest.builder()
createApplicationSnapshotRequest
- A Consumer
that will call methods on CreateApplicationSnapshotRequest.Builder
to create a
request.default CompletableFuture<DeleteApplicationResponse> deleteApplication(DeleteApplicationRequest deleteApplicationRequest)
Deletes the specified application. Kinesis Data Analytics halts application execution and deletes the application.
deleteApplicationRequest
- default CompletableFuture<DeleteApplicationResponse> deleteApplication(Consumer<DeleteApplicationRequest.Builder> deleteApplicationRequest)
Deletes the specified application. Kinesis Data Analytics halts application execution and deletes the application.
This is a convenience which creates an instance of the DeleteApplicationRequest.Builder
avoiding the need
to create one manually via DeleteApplicationRequest.builder()
deleteApplicationRequest
- A Consumer
that will call methods on DeleteApplicationRequest.Builder
to create a request.default CompletableFuture<DeleteApplicationCloudWatchLoggingOptionResponse> deleteApplicationCloudWatchLoggingOption(DeleteApplicationCloudWatchLoggingOptionRequest deleteApplicationCloudWatchLoggingOptionRequest)
Deletes an Amazon CloudWatch log stream from an Amazon Kinesis Data Analytics application.
deleteApplicationCloudWatchLoggingOptionRequest
- default CompletableFuture<DeleteApplicationCloudWatchLoggingOptionResponse> deleteApplicationCloudWatchLoggingOption(Consumer<DeleteApplicationCloudWatchLoggingOptionRequest.Builder> deleteApplicationCloudWatchLoggingOptionRequest)
Deletes an Amazon CloudWatch log stream from an Amazon Kinesis Data Analytics application.
This is a convenience which creates an instance of the
DeleteApplicationCloudWatchLoggingOptionRequest.Builder
avoiding the need to create one manually via
DeleteApplicationCloudWatchLoggingOptionRequest.builder()
deleteApplicationCloudWatchLoggingOptionRequest
- A Consumer
that will call methods on
DeleteApplicationCloudWatchLoggingOptionRequest.Builder
to create a request.default CompletableFuture<DeleteApplicationInputProcessingConfigurationResponse> deleteApplicationInputProcessingConfiguration(DeleteApplicationInputProcessingConfigurationRequest deleteApplicationInputProcessingConfigurationRequest)
Deletes an InputProcessingConfiguration from an input.
deleteApplicationInputProcessingConfigurationRequest
- default CompletableFuture<DeleteApplicationInputProcessingConfigurationResponse> deleteApplicationInputProcessingConfiguration(Consumer<DeleteApplicationInputProcessingConfigurationRequest.Builder> deleteApplicationInputProcessingConfigurationRequest)
Deletes an InputProcessingConfiguration from an input.
This is a convenience which creates an instance of the
DeleteApplicationInputProcessingConfigurationRequest.Builder
avoiding the need to create one manually via
DeleteApplicationInputProcessingConfigurationRequest.builder()
deleteApplicationInputProcessingConfigurationRequest
- A Consumer
that will call methods on
DeleteApplicationInputProcessingConfigurationRequest.Builder
to create a request.default CompletableFuture<DeleteApplicationOutputResponse> deleteApplicationOutput(DeleteApplicationOutputRequest deleteApplicationOutputRequest)
Deletes the output destination configuration from your SQL-based Amazon 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.
deleteApplicationOutputRequest
- default CompletableFuture<DeleteApplicationOutputResponse> deleteApplicationOutput(Consumer<DeleteApplicationOutputRequest.Builder> deleteApplicationOutputRequest)
Deletes the output destination configuration from your SQL-based Amazon 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.
This is a convenience which creates an instance of the DeleteApplicationOutputRequest.Builder
avoiding
the need to create one manually via DeleteApplicationOutputRequest.builder()
deleteApplicationOutputRequest
- A Consumer
that will call methods on DeleteApplicationOutputRequest.Builder
to create a
request.default CompletableFuture<DeleteApplicationReferenceDataSourceResponse> deleteApplicationReferenceDataSource(DeleteApplicationReferenceDataSourceRequest deleteApplicationReferenceDataSourceRequest)
Deletes a reference data source configuration from the specified SQL-based Amazon Kinesis Data Analytics application's configuration.
If the application is running, Kinesis Data Analytics immediately removes the in-application table that you created using the AddApplicationReferenceDataSource operation.
deleteApplicationReferenceDataSourceRequest
- default CompletableFuture<DeleteApplicationReferenceDataSourceResponse> deleteApplicationReferenceDataSource(Consumer<DeleteApplicationReferenceDataSourceRequest.Builder> deleteApplicationReferenceDataSourceRequest)
Deletes a reference data source configuration from the specified SQL-based Amazon Kinesis Data Analytics application's configuration.
If the application is running, Kinesis Data Analytics immediately removes the in-application table that you created using the AddApplicationReferenceDataSource operation.
This is a convenience which creates an instance of the
DeleteApplicationReferenceDataSourceRequest.Builder
avoiding the need to create one manually via
DeleteApplicationReferenceDataSourceRequest.builder()
deleteApplicationReferenceDataSourceRequest
- A Consumer
that will call methods on DeleteApplicationReferenceDataSourceRequest.Builder
to create a request.default CompletableFuture<DeleteApplicationSnapshotResponse> deleteApplicationSnapshot(DeleteApplicationSnapshotRequest deleteApplicationSnapshotRequest)
Deletes a snapshot of application state.
deleteApplicationSnapshotRequest
- default CompletableFuture<DeleteApplicationSnapshotResponse> deleteApplicationSnapshot(Consumer<DeleteApplicationSnapshotRequest.Builder> deleteApplicationSnapshotRequest)
Deletes a snapshot of application state.
This is a convenience which creates an instance of the DeleteApplicationSnapshotRequest.Builder
avoiding
the need to create one manually via DeleteApplicationSnapshotRequest.builder()
deleteApplicationSnapshotRequest
- A Consumer
that will call methods on DeleteApplicationSnapshotRequest.Builder
to create a
request.default CompletableFuture<DescribeApplicationResponse> describeApplication(DescribeApplicationRequest describeApplicationRequest)
Returns information about a specific Amazon Kinesis Data Analytics application.
If you want to retrieve a list of all applications in your account, use the ListApplications operation.
describeApplicationRequest
- default CompletableFuture<DescribeApplicationResponse> describeApplication(Consumer<DescribeApplicationRequest.Builder> describeApplicationRequest)
Returns information about a specific Amazon Kinesis Data Analytics application.
If you want to retrieve a list of all applications in your account, use the ListApplications operation.
This is a convenience which creates an instance of the DescribeApplicationRequest.Builder
avoiding the
need to create one manually via DescribeApplicationRequest.builder()
describeApplicationRequest
- A Consumer
that will call methods on DescribeApplicationRequest.Builder
to create a
request.default CompletableFuture<DescribeApplicationSnapshotResponse> describeApplicationSnapshot(DescribeApplicationSnapshotRequest describeApplicationSnapshotRequest)
Returns information about a snapshot of application state data.
describeApplicationSnapshotRequest
- default CompletableFuture<DescribeApplicationSnapshotResponse> describeApplicationSnapshot(Consumer<DescribeApplicationSnapshotRequest.Builder> describeApplicationSnapshotRequest)
Returns information about a snapshot of application state data.
This is a convenience which creates an instance of the DescribeApplicationSnapshotRequest.Builder
avoiding the need to create one manually via DescribeApplicationSnapshotRequest.builder()
describeApplicationSnapshotRequest
- A Consumer
that will call methods on DescribeApplicationSnapshotRequest.Builder
to create
a request.default CompletableFuture<DiscoverInputSchemaResponse> discoverInputSchema(DiscoverInputSchemaRequest discoverInputSchemaRequest)
Infers a schema for an SQL-based Amazon 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.
You can use the inferred schema when configuring a streaming source for your application. When you create an application using the Kinesis Data Analytics console, the console uses this operation to infer a schema and show it in the console user interface.
discoverInputSchemaRequest
- ProvisionedThroughputExceededException
. For
more information, see GetRecords in the
Amazon Kinesis Streams API Reference.default CompletableFuture<DiscoverInputSchemaResponse> discoverInputSchema(Consumer<DiscoverInputSchemaRequest.Builder> discoverInputSchemaRequest)
Infers a schema for an SQL-based Amazon 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.
You can use the inferred schema when configuring a streaming source for your application. When you create an application using the Kinesis Data Analytics console, the console uses this operation to infer a schema and show it in the console user interface.
This is a convenience which creates an instance of the DiscoverInputSchemaRequest.Builder
avoiding the
need to create one manually via DiscoverInputSchemaRequest.builder()
discoverInputSchemaRequest
- A Consumer
that will call methods on DiscoverInputSchemaRequest.Builder
to create a
request.ProvisionedThroughputExceededException
. For
more information, see GetRecords in the
Amazon Kinesis Streams API Reference.default CompletableFuture<ListApplicationSnapshotsResponse> listApplicationSnapshots(ListApplicationSnapshotsRequest listApplicationSnapshotsRequest)
Lists information about the current application snapshots.
listApplicationSnapshotsRequest
- default CompletableFuture<ListApplicationSnapshotsResponse> listApplicationSnapshots(Consumer<ListApplicationSnapshotsRequest.Builder> listApplicationSnapshotsRequest)
Lists information about the current application snapshots.
This is a convenience which creates an instance of the ListApplicationSnapshotsRequest.Builder
avoiding
the need to create one manually via ListApplicationSnapshotsRequest.builder()
listApplicationSnapshotsRequest
- A Consumer
that will call methods on ListApplicationSnapshotsRequest.Builder
to create a
request.default CompletableFuture<ListApplicationsResponse> listApplications(ListApplicationsRequest listApplicationsRequest)
Returns a list of Amazon Kinesis Data Analytics applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status.
If you want detailed information about a specific application, use DescribeApplication.
listApplicationsRequest
- default CompletableFuture<ListApplicationsResponse> listApplications(Consumer<ListApplicationsRequest.Builder> listApplicationsRequest)
Returns a list of Amazon Kinesis Data Analytics applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status.
If you want detailed information about a specific application, use DescribeApplication.
This is a convenience which creates an instance of the ListApplicationsRequest.Builder
avoiding the need
to create one manually via ListApplicationsRequest.builder()
listApplicationsRequest
- A Consumer
that will call methods on ListApplicationsRequest.Builder
to create a request.default CompletableFuture<ListApplicationsResponse> listApplications()
Returns a list of Amazon Kinesis Data Analytics applications in your account. For each application, the response includes the application name, Amazon Resource Name (ARN), and status.
If you want detailed information about a specific application, use DescribeApplication.
default CompletableFuture<StartApplicationResponse> startApplication(StartApplicationRequest startApplicationRequest)
Starts the specified Amazon Kinesis Data Analytics application. After creating an application, you must exclusively call this operation to start your application.
SQL is not enabled for this private beta. Using SQL parameters (such as RunConfiguration$SqlRunConfigurations) will result in an error.
startApplicationRequest
- default CompletableFuture<StartApplicationResponse> startApplication(Consumer<StartApplicationRequest.Builder> startApplicationRequest)
Starts the specified Amazon Kinesis Data Analytics application. After creating an application, you must exclusively call this operation to start your application.
SQL is not enabled for this private beta. Using SQL parameters (such as RunConfiguration$SqlRunConfigurations) will result in an error.
This is a convenience which creates an instance of the StartApplicationRequest.Builder
avoiding the need
to create one manually via StartApplicationRequest.builder()
startApplicationRequest
- A Consumer
that will call methods on StartApplicationRequest.Builder
to create a request.default CompletableFuture<StopApplicationResponse> stopApplication(StopApplicationRequest stopApplicationRequest)
Stops the application from processing data. You can stop an application only if it is in the running state. You can use the DescribeApplication operation to find the application state.
stopApplicationRequest
- default CompletableFuture<StopApplicationResponse> stopApplication(Consumer<StopApplicationRequest.Builder> stopApplicationRequest)
Stops the application from processing data. You can stop an application only if it is in the running state. You can use the DescribeApplication operation to find the application state.
This is a convenience which creates an instance of the StopApplicationRequest.Builder
avoiding the need
to create one manually via StopApplicationRequest.builder()
stopApplicationRequest
- A Consumer
that will call methods on StopApplicationRequest.Builder
to create a request.default CompletableFuture<UpdateApplicationResponse> updateApplication(UpdateApplicationRequest updateApplicationRequest)
Updates an existing Amazon Kinesis Data Analytics application. Using this operation, you can update application code, input configuration, and output configuration.
Kinesis Data Analytics updates the ApplicationVersionId
each time you update your application.
SQL is not enabled for this private beta. Using SQL parameters (such as SqlApplicationConfigurationUpdate) will result in an error.
updateApplicationRequest
- default CompletableFuture<UpdateApplicationResponse> updateApplication(Consumer<UpdateApplicationRequest.Builder> updateApplicationRequest)
Updates an existing Amazon Kinesis Data Analytics application. Using this operation, you can update application code, input configuration, and output configuration.
Kinesis Data Analytics updates the ApplicationVersionId
each time you update your application.
SQL is not enabled for this private beta. Using SQL parameters (such as SqlApplicationConfigurationUpdate) will result in an error.
This is a convenience which creates an instance of the UpdateApplicationRequest.Builder
avoiding the need
to create one manually via UpdateApplicationRequest.builder()
updateApplicationRequest
- A Consumer
that will call methods on UpdateApplicationRequest.Builder
to create a request.Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.