@Generated(value="software.amazon.awssdk:codegen") public interface IoTAnalyticsAsyncClient extends SdkClient
builder() method.
AWS IoT Analytics allows you to collect large amounts of device data, process messages, and store them. You can then query the data and run sophisticated analytics on it. AWS IoT Analytics enables advanced data exploration through integration with Jupyter Notebooks and data visualization through integration with Amazon QuickSight.
Traditional analytics and business intelligence tools are designed to process structured data. IoT data often comes from devices that record noisy processes (such as temperature, motion, or sound). As a result the data from these devices can have significant gaps, corrupted messages, and false readings that must be cleaned up before analysis can occur. Also, IoT data is often only meaningful in the context of other data from external sources.
AWS IoT Analytics automates the steps required to analyze data from IoT devices. AWS IoT Analytics filters, transforms, and enriches IoT data before storing it in a time-series data store for analysis. You can set up the service to collect only the data you need from your devices, apply mathematical transforms to process the data, and enrich the data with device-specific metadata such as device type and location before storing it. Then, you can analyze your data by running queries using the built-in SQL query engine, or perform more complex analytics and machine learning inference. AWS IoT Analytics includes pre-built models for common IoT use cases so you can answer questions like which devices are about to fail or which customers are at risk of abandoning their wearable devices.
| Modifier and Type | Field and Description |
|---|---|
static String |
SERVICE_NAME |
serviceNameclosestatic final String SERVICE_NAME
static IoTAnalyticsAsyncClient create()
IoTAnalyticsAsyncClient with the region loaded from the
DefaultAwsRegionProviderChain and credentials loaded from the
DefaultCredentialsProvider.static IoTAnalyticsAsyncClientBuilder builder()
IoTAnalyticsAsyncClient.default CompletableFuture<BatchPutMessageResponse> batchPutMessage(BatchPutMessageRequest batchPutMessageRequest)
Sends messages to a channel.
batchPutMessageRequest - default CompletableFuture<BatchPutMessageResponse> batchPutMessage(Consumer<BatchPutMessageRequest.Builder> batchPutMessageRequest)
Sends messages to a channel.
This is a convenience which creates an instance of the BatchPutMessageRequest.Builder avoiding the need
to create one manually via BatchPutMessageRequest.builder()
batchPutMessageRequest - A Consumer that will call methods on BatchPutMessageRequest.Builder to create a request.default CompletableFuture<CancelPipelineReprocessingResponse> cancelPipelineReprocessing(CancelPipelineReprocessingRequest cancelPipelineReprocessingRequest)
Cancels the reprocessing of data through the pipeline.
cancelPipelineReprocessingRequest - default CompletableFuture<CancelPipelineReprocessingResponse> cancelPipelineReprocessing(Consumer<CancelPipelineReprocessingRequest.Builder> cancelPipelineReprocessingRequest)
Cancels the reprocessing of data through the pipeline.
This is a convenience which creates an instance of the CancelPipelineReprocessingRequest.Builder avoiding
the need to create one manually via CancelPipelineReprocessingRequest.builder()
cancelPipelineReprocessingRequest - A Consumer that will call methods on CancelPipelineReprocessingRequest.Builder to create a
request.default CompletableFuture<CreateChannelResponse> createChannel(CreateChannelRequest createChannelRequest)
Creates a channel. A channel collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline.
createChannelRequest - default CompletableFuture<CreateChannelResponse> createChannel(Consumer<CreateChannelRequest.Builder> createChannelRequest)
Creates a channel. A channel collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline.
This is a convenience which creates an instance of the CreateChannelRequest.Builder avoiding the need to
create one manually via CreateChannelRequest.builder()
createChannelRequest - A Consumer that will call methods on CreateChannelRequest.Builder to create a request.default CompletableFuture<CreateDatasetResponse> createDataset(CreateDatasetRequest createDatasetRequest)
Creates a data set. A data set stores data retrieved from a data store by applying a "queryAction" (a SQL query) or a "containerAction" (executing a containerized application). This operation creates the skeleton of a data set. The data set can be populated manually by calling "CreateDatasetContent" or automatically according to a "trigger" you specify.
createDatasetRequest - default CompletableFuture<CreateDatasetResponse> createDataset(Consumer<CreateDatasetRequest.Builder> createDatasetRequest)
Creates a data set. A data set stores data retrieved from a data store by applying a "queryAction" (a SQL query) or a "containerAction" (executing a containerized application). This operation creates the skeleton of a data set. The data set can be populated manually by calling "CreateDatasetContent" or automatically according to a "trigger" you specify.
This is a convenience which creates an instance of the CreateDatasetRequest.Builder avoiding the need to
create one manually via CreateDatasetRequest.builder()
createDatasetRequest - A Consumer that will call methods on CreateDatasetRequest.Builder to create a request.default CompletableFuture<CreateDatasetContentResponse> createDatasetContent(CreateDatasetContentRequest createDatasetContentRequest)
Creates the content of a data set by applying a SQL action.
createDatasetContentRequest - default CompletableFuture<CreateDatasetContentResponse> createDatasetContent(Consumer<CreateDatasetContentRequest.Builder> createDatasetContentRequest)
Creates the content of a data set by applying a SQL action.
This is a convenience which creates an instance of the CreateDatasetContentRequest.Builder avoiding the
need to create one manually via CreateDatasetContentRequest.builder()
createDatasetContentRequest - A Consumer that will call methods on CreateDatasetContentRequest.Builder to create a
request.default CompletableFuture<CreateDatastoreResponse> createDatastore(CreateDatastoreRequest createDatastoreRequest)
Creates a data store, which is a repository for messages.
createDatastoreRequest - default CompletableFuture<CreateDatastoreResponse> createDatastore(Consumer<CreateDatastoreRequest.Builder> createDatastoreRequest)
Creates a data store, which is a repository for messages.
This is a convenience which creates an instance of the CreateDatastoreRequest.Builder avoiding the need
to create one manually via CreateDatastoreRequest.builder()
createDatastoreRequest - A Consumer that will call methods on CreateDatastoreRequest.Builder to create a request.default CompletableFuture<CreatePipelineResponse> createPipeline(CreatePipelineRequest createPipelineRequest)
Creates a pipeline. A pipeline consumes messages from one or more channels and allows you to process the messages before storing them in a data store.
createPipelineRequest - default CompletableFuture<CreatePipelineResponse> createPipeline(Consumer<CreatePipelineRequest.Builder> createPipelineRequest)
Creates a pipeline. A pipeline consumes messages from one or more channels and allows you to process the messages before storing them in a data store.
This is a convenience which creates an instance of the CreatePipelineRequest.Builder avoiding the need to
create one manually via CreatePipelineRequest.builder()
createPipelineRequest - A Consumer that will call methods on CreatePipelineRequest.Builder to create a request.default CompletableFuture<DeleteChannelResponse> deleteChannel(DeleteChannelRequest deleteChannelRequest)
Deletes the specified channel.
deleteChannelRequest - default CompletableFuture<DeleteChannelResponse> deleteChannel(Consumer<DeleteChannelRequest.Builder> deleteChannelRequest)
Deletes the specified channel.
This is a convenience which creates an instance of the DeleteChannelRequest.Builder avoiding the need to
create one manually via DeleteChannelRequest.builder()
deleteChannelRequest - A Consumer that will call methods on DeleteChannelRequest.Builder to create a request.default CompletableFuture<DeleteDatasetResponse> deleteDataset(DeleteDatasetRequest deleteDatasetRequest)
Deletes the specified data set.
You do not have to delete the content of the data set before you perform this operation.
deleteDatasetRequest - default CompletableFuture<DeleteDatasetResponse> deleteDataset(Consumer<DeleteDatasetRequest.Builder> deleteDatasetRequest)
Deletes the specified data set.
You do not have to delete the content of the data set before you perform this operation.
This is a convenience which creates an instance of the DeleteDatasetRequest.Builder avoiding the need to
create one manually via DeleteDatasetRequest.builder()
deleteDatasetRequest - A Consumer that will call methods on DeleteDatasetRequest.Builder to create a request.default CompletableFuture<DeleteDatasetContentResponse> deleteDatasetContent(DeleteDatasetContentRequest deleteDatasetContentRequest)
Deletes the content of the specified data set.
deleteDatasetContentRequest - default CompletableFuture<DeleteDatasetContentResponse> deleteDatasetContent(Consumer<DeleteDatasetContentRequest.Builder> deleteDatasetContentRequest)
Deletes the content of the specified data set.
This is a convenience which creates an instance of the DeleteDatasetContentRequest.Builder avoiding the
need to create one manually via DeleteDatasetContentRequest.builder()
deleteDatasetContentRequest - A Consumer that will call methods on DeleteDatasetContentRequest.Builder to create a
request.default CompletableFuture<DeleteDatastoreResponse> deleteDatastore(DeleteDatastoreRequest deleteDatastoreRequest)
Deletes the specified data store.
deleteDatastoreRequest - default CompletableFuture<DeleteDatastoreResponse> deleteDatastore(Consumer<DeleteDatastoreRequest.Builder> deleteDatastoreRequest)
Deletes the specified data store.
This is a convenience which creates an instance of the DeleteDatastoreRequest.Builder avoiding the need
to create one manually via DeleteDatastoreRequest.builder()
deleteDatastoreRequest - A Consumer that will call methods on DeleteDatastoreRequest.Builder to create a request.default CompletableFuture<DeletePipelineResponse> deletePipeline(DeletePipelineRequest deletePipelineRequest)
Deletes the specified pipeline.
deletePipelineRequest - default CompletableFuture<DeletePipelineResponse> deletePipeline(Consumer<DeletePipelineRequest.Builder> deletePipelineRequest)
Deletes the specified pipeline.
This is a convenience which creates an instance of the DeletePipelineRequest.Builder avoiding the need to
create one manually via DeletePipelineRequest.builder()
deletePipelineRequest - A Consumer that will call methods on DeletePipelineRequest.Builder to create a request.default CompletableFuture<DescribeChannelResponse> describeChannel(DescribeChannelRequest describeChannelRequest)
Retrieves information about a channel.
describeChannelRequest - default CompletableFuture<DescribeChannelResponse> describeChannel(Consumer<DescribeChannelRequest.Builder> describeChannelRequest)
Retrieves information about a channel.
This is a convenience which creates an instance of the DescribeChannelRequest.Builder avoiding the need
to create one manually via DescribeChannelRequest.builder()
describeChannelRequest - A Consumer that will call methods on DescribeChannelRequest.Builder to create a request.default CompletableFuture<DescribeDatasetResponse> describeDataset(DescribeDatasetRequest describeDatasetRequest)
Retrieves information about a data set.
describeDatasetRequest - default CompletableFuture<DescribeDatasetResponse> describeDataset(Consumer<DescribeDatasetRequest.Builder> describeDatasetRequest)
Retrieves information about a data set.
This is a convenience which creates an instance of the DescribeDatasetRequest.Builder avoiding the need
to create one manually via DescribeDatasetRequest.builder()
describeDatasetRequest - A Consumer that will call methods on DescribeDatasetRequest.Builder to create a request.default CompletableFuture<DescribeDatastoreResponse> describeDatastore(DescribeDatastoreRequest describeDatastoreRequest)
Retrieves information about a data store.
describeDatastoreRequest - default CompletableFuture<DescribeDatastoreResponse> describeDatastore(Consumer<DescribeDatastoreRequest.Builder> describeDatastoreRequest)
Retrieves information about a data store.
This is a convenience which creates an instance of the DescribeDatastoreRequest.Builder avoiding the need
to create one manually via DescribeDatastoreRequest.builder()
describeDatastoreRequest - A Consumer that will call methods on DescribeDatastoreRequest.Builder to create a request.default CompletableFuture<DescribeLoggingOptionsResponse> describeLoggingOptions(DescribeLoggingOptionsRequest describeLoggingOptionsRequest)
Retrieves the current settings of the AWS IoT Analytics logging options.
describeLoggingOptionsRequest - default CompletableFuture<DescribeLoggingOptionsResponse> describeLoggingOptions(Consumer<DescribeLoggingOptionsRequest.Builder> describeLoggingOptionsRequest)
Retrieves the current settings of the AWS IoT Analytics logging options.
This is a convenience which creates an instance of the DescribeLoggingOptionsRequest.Builder avoiding the
need to create one manually via DescribeLoggingOptionsRequest.builder()
describeLoggingOptionsRequest - A Consumer that will call methods on DescribeLoggingOptionsRequest.Builder to create a
request.default CompletableFuture<DescribePipelineResponse> describePipeline(DescribePipelineRequest describePipelineRequest)
Retrieves information about a pipeline.
describePipelineRequest - default CompletableFuture<DescribePipelineResponse> describePipeline(Consumer<DescribePipelineRequest.Builder> describePipelineRequest)
Retrieves information about a pipeline.
This is a convenience which creates an instance of the DescribePipelineRequest.Builder avoiding the need
to create one manually via DescribePipelineRequest.builder()
describePipelineRequest - A Consumer that will call methods on DescribePipelineRequest.Builder to create a request.default CompletableFuture<GetDatasetContentResponse> getDatasetContent(GetDatasetContentRequest getDatasetContentRequest)
Retrieves the contents of a data set as pre-signed URIs.
getDatasetContentRequest - default CompletableFuture<GetDatasetContentResponse> getDatasetContent(Consumer<GetDatasetContentRequest.Builder> getDatasetContentRequest)
Retrieves the contents of a data set as pre-signed URIs.
This is a convenience which creates an instance of the GetDatasetContentRequest.Builder avoiding the need
to create one manually via GetDatasetContentRequest.builder()
getDatasetContentRequest - A Consumer that will call methods on GetDatasetContentRequest.Builder to create a request.default CompletableFuture<ListChannelsResponse> listChannels(ListChannelsRequest listChannelsRequest)
Retrieves a list of channels.
listChannelsRequest - default CompletableFuture<ListChannelsResponse> listChannels(Consumer<ListChannelsRequest.Builder> listChannelsRequest)
Retrieves a list of channels.
This is a convenience which creates an instance of the ListChannelsRequest.Builder avoiding the need to
create one manually via ListChannelsRequest.builder()
listChannelsRequest - A Consumer that will call methods on ListChannelsRequest.Builder to create a request.default CompletableFuture<ListChannelsResponse> listChannels()
Retrieves a list of channels.
default ListChannelsPublisher listChannelsPaginator()
Retrieves a list of channels.
This is a variant of
listChannels(software.amazon.awssdk.services.iotanalytics.model.ListChannelsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListChannelsPublisher publisher = client.listChannelsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListChannelsPublisher publisher = client.listChannelsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListChannelsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListChannelsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listChannels(software.amazon.awssdk.services.iotanalytics.model.ListChannelsRequest) operation.
default ListChannelsPublisher listChannelsPaginator(ListChannelsRequest listChannelsRequest)
Retrieves a list of channels.
This is a variant of
listChannels(software.amazon.awssdk.services.iotanalytics.model.ListChannelsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListChannelsPublisher publisher = client.listChannelsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListChannelsPublisher publisher = client.listChannelsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListChannelsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListChannelsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listChannels(software.amazon.awssdk.services.iotanalytics.model.ListChannelsRequest) operation.
listChannelsRequest - default ListChannelsPublisher listChannelsPaginator(Consumer<ListChannelsRequest.Builder> listChannelsRequest)
Retrieves a list of channels.
This is a variant of
listChannels(software.amazon.awssdk.services.iotanalytics.model.ListChannelsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListChannelsPublisher publisher = client.listChannelsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListChannelsPublisher publisher = client.listChannelsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListChannelsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListChannelsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listChannels(software.amazon.awssdk.services.iotanalytics.model.ListChannelsRequest) operation.
This is a convenience which creates an instance of the ListChannelsRequest.Builder avoiding the need to
create one manually via ListChannelsRequest.builder()
listChannelsRequest - A Consumer that will call methods on ListChannelsRequest.Builder to create a request.default CompletableFuture<ListDatasetContentsResponse> listDatasetContents(ListDatasetContentsRequest listDatasetContentsRequest)
Lists information about data set contents that have been created.
listDatasetContentsRequest - default CompletableFuture<ListDatasetContentsResponse> listDatasetContents(Consumer<ListDatasetContentsRequest.Builder> listDatasetContentsRequest)
Lists information about data set contents that have been created.
This is a convenience which creates an instance of the ListDatasetContentsRequest.Builder avoiding the
need to create one manually via ListDatasetContentsRequest.builder()
listDatasetContentsRequest - A Consumer that will call methods on ListDatasetContentsRequest.Builder to create a
request.default ListDatasetContentsPublisher listDatasetContentsPaginator(ListDatasetContentsRequest listDatasetContentsRequest)
Lists information about data set contents that have been created.
This is a variant of
listDatasetContents(software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetContentsPublisher publisher = client.listDatasetContentsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetContentsPublisher publisher = client.listDatasetContentsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatasetContents(software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsRequest)
operation.
listDatasetContentsRequest - default ListDatasetContentsPublisher listDatasetContentsPaginator(Consumer<ListDatasetContentsRequest.Builder> listDatasetContentsRequest)
Lists information about data set contents that have been created.
This is a variant of
listDatasetContents(software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsRequest)
operation. The return type is a custom publisher that can be subscribed to request a stream of response pages.
SDK will internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetContentsPublisher publisher = client.listDatasetContentsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetContentsPublisher publisher = client.listDatasetContentsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatasetContents(software.amazon.awssdk.services.iotanalytics.model.ListDatasetContentsRequest)
operation.
This is a convenience which creates an instance of the ListDatasetContentsRequest.Builder avoiding the
need to create one manually via ListDatasetContentsRequest.builder()
listDatasetContentsRequest - A Consumer that will call methods on ListDatasetContentsRequest.Builder to create a
request.default CompletableFuture<ListDatasetsResponse> listDatasets(ListDatasetsRequest listDatasetsRequest)
Retrieves information about data sets.
listDatasetsRequest - default CompletableFuture<ListDatasetsResponse> listDatasets(Consumer<ListDatasetsRequest.Builder> listDatasetsRequest)
Retrieves information about data sets.
This is a convenience which creates an instance of the ListDatasetsRequest.Builder avoiding the need to
create one manually via ListDatasetsRequest.builder()
listDatasetsRequest - A Consumer that will call methods on ListDatasetsRequest.Builder to create a request.default CompletableFuture<ListDatasetsResponse> listDatasets()
Retrieves information about data sets.
default ListDatasetsPublisher listDatasetsPaginator()
Retrieves information about data sets.
This is a variant of
listDatasets(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetsPublisher publisher = client.listDatasetsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetsPublisher publisher = client.listDatasetsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatasetsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatasets(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsRequest) operation.
default ListDatasetsPublisher listDatasetsPaginator(ListDatasetsRequest listDatasetsRequest)
Retrieves information about data sets.
This is a variant of
listDatasets(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetsPublisher publisher = client.listDatasetsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetsPublisher publisher = client.listDatasetsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatasetsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatasets(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsRequest) operation.
listDatasetsRequest - default ListDatasetsPublisher listDatasetsPaginator(Consumer<ListDatasetsRequest.Builder> listDatasetsRequest)
Retrieves information about data sets.
This is a variant of
listDatasets(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetsPublisher publisher = client.listDatasetsPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatasetsPublisher publisher = client.listDatasetsPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatasetsResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatasets(software.amazon.awssdk.services.iotanalytics.model.ListDatasetsRequest) operation.
This is a convenience which creates an instance of the ListDatasetsRequest.Builder avoiding the need to
create one manually via ListDatasetsRequest.builder()
listDatasetsRequest - A Consumer that will call methods on ListDatasetsRequest.Builder to create a request.default CompletableFuture<ListDatastoresResponse> listDatastores(ListDatastoresRequest listDatastoresRequest)
Retrieves a list of data stores.
listDatastoresRequest - default CompletableFuture<ListDatastoresResponse> listDatastores(Consumer<ListDatastoresRequest.Builder> listDatastoresRequest)
Retrieves a list of data stores.
This is a convenience which creates an instance of the ListDatastoresRequest.Builder avoiding the need to
create one manually via ListDatastoresRequest.builder()
listDatastoresRequest - A Consumer that will call methods on ListDatastoresRequest.Builder to create a request.default CompletableFuture<ListDatastoresResponse> listDatastores()
Retrieves a list of data stores.
default ListDatastoresPublisher listDatastoresPaginator()
Retrieves a list of data stores.
This is a variant of
listDatastores(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatastoresPublisher publisher = client.listDatastoresPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatastoresPublisher publisher = client.listDatastoresPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatastoresResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatastores(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresRequest) operation.
default ListDatastoresPublisher listDatastoresPaginator(ListDatastoresRequest listDatastoresRequest)
Retrieves a list of data stores.
This is a variant of
listDatastores(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatastoresPublisher publisher = client.listDatastoresPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatastoresPublisher publisher = client.listDatastoresPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatastoresResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatastores(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresRequest) operation.
listDatastoresRequest - default ListDatastoresPublisher listDatastoresPaginator(Consumer<ListDatastoresRequest.Builder> listDatastoresRequest)
Retrieves a list of data stores.
This is a variant of
listDatastores(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListDatastoresPublisher publisher = client.listDatastoresPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListDatastoresPublisher publisher = client.listDatastoresPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListDatastoresResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listDatastores(software.amazon.awssdk.services.iotanalytics.model.ListDatastoresRequest) operation.
This is a convenience which creates an instance of the ListDatastoresRequest.Builder avoiding the need to
create one manually via ListDatastoresRequest.builder()
listDatastoresRequest - A Consumer that will call methods on ListDatastoresRequest.Builder to create a request.default CompletableFuture<ListPipelinesResponse> listPipelines(ListPipelinesRequest listPipelinesRequest)
Retrieves a list of pipelines.
listPipelinesRequest - default CompletableFuture<ListPipelinesResponse> listPipelines(Consumer<ListPipelinesRequest.Builder> listPipelinesRequest)
Retrieves a list of pipelines.
This is a convenience which creates an instance of the ListPipelinesRequest.Builder avoiding the need to
create one manually via ListPipelinesRequest.builder()
listPipelinesRequest - A Consumer that will call methods on ListPipelinesRequest.Builder to create a request.default CompletableFuture<ListPipelinesResponse> listPipelines()
Retrieves a list of pipelines.
default ListPipelinesPublisher listPipelinesPaginator()
Retrieves a list of pipelines.
This is a variant of
listPipelines(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListPipelinesPublisher publisher = client.listPipelinesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListPipelinesPublisher publisher = client.listPipelinesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListPipelinesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listPipelines(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesRequest) operation.
default ListPipelinesPublisher listPipelinesPaginator(ListPipelinesRequest listPipelinesRequest)
Retrieves a list of pipelines.
This is a variant of
listPipelines(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListPipelinesPublisher publisher = client.listPipelinesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListPipelinesPublisher publisher = client.listPipelinesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListPipelinesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listPipelines(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesRequest) operation.
listPipelinesRequest - default ListPipelinesPublisher listPipelinesPaginator(Consumer<ListPipelinesRequest.Builder> listPipelinesRequest)
Retrieves a list of pipelines.
This is a variant of
listPipelines(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesRequest) operation. The
return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will
internally handle making service calls for you.
When the operation is called, an instance of this class is returned. At this point, no service calls are made yet
and so there is no guarantee that the request is valid. If there are errors in your request, you will see the
failures only after you start streaming the data. The subscribe method should be called as a request to start
streaming data. For more info, see
Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe
method will result in a new Subscription i.e., a new contract to stream data from the
starting request.
The following are few ways to use the response class:
1) Using the subscribe helper method
software.amazon.awssdk.services.iotanalytics.paginators.ListPipelinesPublisher publisher = client.listPipelinesPaginator(request);
CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
future.get();
2) Using a custom subscriber
software.amazon.awssdk.services.iotanalytics.paginators.ListPipelinesPublisher publisher = client.listPipelinesPaginator(request);
publisher.subscribe(new Subscriber<software.amazon.awssdk.services.iotanalytics.model.ListPipelinesResponse>() {
public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
public void onNext(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesResponse response) { //... };
});
As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
Note: If you prefer to have control on service calls, use the
listPipelines(software.amazon.awssdk.services.iotanalytics.model.ListPipelinesRequest) operation.
This is a convenience which creates an instance of the ListPipelinesRequest.Builder avoiding the need to
create one manually via ListPipelinesRequest.builder()
listPipelinesRequest - A Consumer that will call methods on ListPipelinesRequest.Builder to create a request.default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
Lists the tags (metadata) which you have assigned to the resource.
listTagsForResourceRequest - default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)
Lists the tags (metadata) which you have assigned to the resource.
This is a convenience which creates an instance of the ListTagsForResourceRequest.Builder avoiding the
need to create one manually via ListTagsForResourceRequest.builder()
listTagsForResourceRequest - A Consumer that will call methods on ListTagsForResourceRequest.Builder to create a
request.default CompletableFuture<PutLoggingOptionsResponse> putLoggingOptions(PutLoggingOptionsRequest putLoggingOptionsRequest)
Sets or updates the AWS IoT Analytics logging options.
Note that if you update the value of any loggingOptions field, it takes up to one minute for the
change to take effect. Also, if you change the policy attached to the role you specified in the roleArn field
(for example, to correct an invalid policy) it takes up to 5 minutes for that change to take effect.
putLoggingOptionsRequest - default CompletableFuture<PutLoggingOptionsResponse> putLoggingOptions(Consumer<PutLoggingOptionsRequest.Builder> putLoggingOptionsRequest)
Sets or updates the AWS IoT Analytics logging options.
Note that if you update the value of any loggingOptions field, it takes up to one minute for the
change to take effect. Also, if you change the policy attached to the role you specified in the roleArn field
(for example, to correct an invalid policy) it takes up to 5 minutes for that change to take effect.
This is a convenience which creates an instance of the PutLoggingOptionsRequest.Builder avoiding the need
to create one manually via PutLoggingOptionsRequest.builder()
putLoggingOptionsRequest - A Consumer that will call methods on PutLoggingOptionsRequest.Builder to create a request.default CompletableFuture<RunPipelineActivityResponse> runPipelineActivity(RunPipelineActivityRequest runPipelineActivityRequest)
Simulates the results of running a pipeline activity on a message payload.
runPipelineActivityRequest - default CompletableFuture<RunPipelineActivityResponse> runPipelineActivity(Consumer<RunPipelineActivityRequest.Builder> runPipelineActivityRequest)
Simulates the results of running a pipeline activity on a message payload.
This is a convenience which creates an instance of the RunPipelineActivityRequest.Builder avoiding the
need to create one manually via RunPipelineActivityRequest.builder()
runPipelineActivityRequest - A Consumer that will call methods on RunPipelineActivityRequest.Builder to create a
request.default CompletableFuture<SampleChannelDataResponse> sampleChannelData(SampleChannelDataRequest sampleChannelDataRequest)
Retrieves a sample of messages from the specified channel ingested during the specified timeframe. Up to 10 messages can be retrieved.
sampleChannelDataRequest - default CompletableFuture<SampleChannelDataResponse> sampleChannelData(Consumer<SampleChannelDataRequest.Builder> sampleChannelDataRequest)
Retrieves a sample of messages from the specified channel ingested during the specified timeframe. Up to 10 messages can be retrieved.
This is a convenience which creates an instance of the SampleChannelDataRequest.Builder avoiding the need
to create one manually via SampleChannelDataRequest.builder()
sampleChannelDataRequest - A Consumer that will call methods on SampleChannelDataRequest.Builder to create a request.default CompletableFuture<StartPipelineReprocessingResponse> startPipelineReprocessing(StartPipelineReprocessingRequest startPipelineReprocessingRequest)
Starts the reprocessing of raw message data through the pipeline.
startPipelineReprocessingRequest - default CompletableFuture<StartPipelineReprocessingResponse> startPipelineReprocessing(Consumer<StartPipelineReprocessingRequest.Builder> startPipelineReprocessingRequest)
Starts the reprocessing of raw message data through the pipeline.
This is a convenience which creates an instance of the StartPipelineReprocessingRequest.Builder avoiding
the need to create one manually via StartPipelineReprocessingRequest.builder()
startPipelineReprocessingRequest - A Consumer that will call methods on StartPipelineReprocessingRequest.Builder to create a
request.default CompletableFuture<TagResourceResponse> tagResource(TagResourceRequest tagResourceRequest)
Adds to or modifies the tags of the given resource. Tags are metadata which can be used to manage a resource.
tagResourceRequest - default CompletableFuture<TagResourceResponse> tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest)
Adds to or modifies the tags of the given resource. Tags are metadata which can be used to manage a resource.
This is a convenience which creates an instance of the TagResourceRequest.Builder avoiding the need to
create one manually via TagResourceRequest.builder()
tagResourceRequest - A Consumer that will call methods on TagResourceRequest.Builder to create a request.default CompletableFuture<UntagResourceResponse> untagResource(UntagResourceRequest untagResourceRequest)
Removes the given tags (metadata) from the resource.
untagResourceRequest - default CompletableFuture<UntagResourceResponse> untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest)
Removes the given tags (metadata) from the resource.
This is a convenience which creates an instance of the UntagResourceRequest.Builder avoiding the need to
create one manually via UntagResourceRequest.builder()
untagResourceRequest - A Consumer that will call methods on UntagResourceRequest.Builder to create a request.default CompletableFuture<UpdateChannelResponse> updateChannel(UpdateChannelRequest updateChannelRequest)
Updates the settings of a channel.
updateChannelRequest - default CompletableFuture<UpdateChannelResponse> updateChannel(Consumer<UpdateChannelRequest.Builder> updateChannelRequest)
Updates the settings of a channel.
This is a convenience which creates an instance of the UpdateChannelRequest.Builder avoiding the need to
create one manually via UpdateChannelRequest.builder()
updateChannelRequest - A Consumer that will call methods on UpdateChannelRequest.Builder to create a request.default CompletableFuture<UpdateDatasetResponse> updateDataset(UpdateDatasetRequest updateDatasetRequest)
Updates the settings of a data set.
updateDatasetRequest - default CompletableFuture<UpdateDatasetResponse> updateDataset(Consumer<UpdateDatasetRequest.Builder> updateDatasetRequest)
Updates the settings of a data set.
This is a convenience which creates an instance of the UpdateDatasetRequest.Builder avoiding the need to
create one manually via UpdateDatasetRequest.builder()
updateDatasetRequest - A Consumer that will call methods on UpdateDatasetRequest.Builder to create a request.default CompletableFuture<UpdateDatastoreResponse> updateDatastore(UpdateDatastoreRequest updateDatastoreRequest)
Updates the settings of a data store.
updateDatastoreRequest - default CompletableFuture<UpdateDatastoreResponse> updateDatastore(Consumer<UpdateDatastoreRequest.Builder> updateDatastoreRequest)
Updates the settings of a data store.
This is a convenience which creates an instance of the UpdateDatastoreRequest.Builder avoiding the need
to create one manually via UpdateDatastoreRequest.builder()
updateDatastoreRequest - A Consumer that will call methods on UpdateDatastoreRequest.Builder to create a request.default CompletableFuture<UpdatePipelineResponse> updatePipeline(UpdatePipelineRequest updatePipelineRequest)
Updates the settings of a pipeline.
updatePipelineRequest - default CompletableFuture<UpdatePipelineResponse> updatePipeline(Consumer<UpdatePipelineRequest.Builder> updatePipelineRequest)
Updates the settings of a pipeline.
This is a convenience which creates an instance of the UpdatePipelineRequest.Builder avoiding the need to
create one manually via UpdatePipelineRequest.builder()
updatePipelineRequest - A Consumer that will call methods on UpdatePipelineRequest.Builder to create a request.Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.