@ThreadSafe @Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class AWSIoTAnalyticsAsyncClient extends AWSIoTAnalyticsClient implements AWSIoTAnalyticsAsync
AsyncHandler can be used to receive
notification when an asynchronous operation completes.
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. 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.
IoT Analytics automates the steps required to analyze data from IoT devices. 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. 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.
LOGGING_AWS_REQUEST_METRICENDPOINT_PREFIXbatchPutMessage, builder, cancelPipelineReprocessing, createChannel, createDataset, createDatasetContent, createDatastore, createPipeline, deleteChannel, deleteDataset, deleteDatasetContent, deleteDatastore, deletePipeline, describeChannel, describeDataset, describeDatastore, describeLoggingOptions, describePipeline, getCachedResponseMetadata, getDatasetContent, listChannels, listDatasetContents, listDatasets, listDatastores, listPipelines, listTagsForResource, putLoggingOptions, runPipelineActivity, sampleChannelData, startPipelineReprocessing, tagResource, untagResource, updateChannel, updateDataset, updateDatastore, updatePipelineaddRequestHandler, addRequestHandler, configureRegion, getClientConfiguration, getEndpointPrefix, getMonitoringListeners, getRequestMetricsCollector, getServiceName, getSignerByURI, getSignerOverride, getSignerRegionOverride, getTimeOffset, makeImmutable, removeRequestHandler, removeRequestHandler, setEndpoint, setEndpoint, setRegion, setServiceNameIntern, setSignerRegionOverride, setTimeOffset, withEndpoint, withRegion, withRegion, withTimeOffsetequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitbatchPutMessage, cancelPipelineReprocessing, createChannel, createDataset, createDatasetContent, createDatastore, createPipeline, deleteChannel, deleteDataset, deleteDatasetContent, deleteDatastore, deletePipeline, describeChannel, describeDataset, describeDatastore, describeLoggingOptions, describePipeline, getCachedResponseMetadata, getDatasetContent, listChannels, listDatasetContents, listDatasets, listDatastores, listPipelines, listTagsForResource, putLoggingOptions, runPipelineActivity, sampleChannelData, startPipelineReprocessing, tagResource, untagResource, updateChannel, updateDataset, updateDatastore, updatePipelinepublic static AWSIoTAnalyticsAsyncClientBuilder asyncBuilder()
public ExecutorService getExecutorService()
public Future<BatchPutMessageResult> batchPutMessageAsync(BatchPutMessageRequest request)
AWSIoTAnalyticsAsyncSends messages to a channel.
batchPutMessageAsync in interface AWSIoTAnalyticsAsyncpublic Future<BatchPutMessageResult> batchPutMessageAsync(BatchPutMessageRequest request, AsyncHandler<BatchPutMessageRequest,BatchPutMessageResult> asyncHandler)
AWSIoTAnalyticsAsyncSends messages to a channel.
batchPutMessageAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<CancelPipelineReprocessingResult> cancelPipelineReprocessingAsync(CancelPipelineReprocessingRequest request)
AWSIoTAnalyticsAsyncCancels the reprocessing of data through the pipeline.
cancelPipelineReprocessingAsync in interface AWSIoTAnalyticsAsyncpublic Future<CancelPipelineReprocessingResult> cancelPipelineReprocessingAsync(CancelPipelineReprocessingRequest request, AsyncHandler<CancelPipelineReprocessingRequest,CancelPipelineReprocessingResult> asyncHandler)
AWSIoTAnalyticsAsyncCancels the reprocessing of data through the pipeline.
cancelPipelineReprocessingAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<CreateChannelResult> createChannelAsync(CreateChannelRequest request)
AWSIoTAnalyticsAsyncUsed to create a channel. A channel collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline.
createChannelAsync in interface AWSIoTAnalyticsAsyncpublic Future<CreateChannelResult> createChannelAsync(CreateChannelRequest request, AsyncHandler<CreateChannelRequest,CreateChannelResult> asyncHandler)
AWSIoTAnalyticsAsyncUsed to create a channel. A channel collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline.
createChannelAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<CreateDatasetResult> createDatasetAsync(CreateDatasetRequest request)
AWSIoTAnalyticsAsync
Used to create a dataset. A dataset 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 dataset. The dataset can be populated manually by calling
CreateDatasetContent or automatically according to a trigger you specify.
createDatasetAsync in interface AWSIoTAnalyticsAsyncpublic Future<CreateDatasetResult> createDatasetAsync(CreateDatasetRequest request, AsyncHandler<CreateDatasetRequest,CreateDatasetResult> asyncHandler)
AWSIoTAnalyticsAsync
Used to create a dataset. A dataset 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 dataset. The dataset can be populated manually by calling
CreateDatasetContent or automatically according to a trigger you specify.
createDatasetAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<CreateDatasetContentResult> createDatasetContentAsync(CreateDatasetContentRequest request)
AWSIoTAnalyticsAsync
Creates the content of a dataset by applying a queryAction (a SQL query) or a
containerAction (executing a containerized application).
createDatasetContentAsync in interface AWSIoTAnalyticsAsyncpublic Future<CreateDatasetContentResult> createDatasetContentAsync(CreateDatasetContentRequest request, AsyncHandler<CreateDatasetContentRequest,CreateDatasetContentResult> asyncHandler)
AWSIoTAnalyticsAsync
Creates the content of a dataset by applying a queryAction (a SQL query) or a
containerAction (executing a containerized application).
createDatasetContentAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<CreateDatastoreResult> createDatastoreAsync(CreateDatastoreRequest request)
AWSIoTAnalyticsAsyncCreates a data store, which is a repository for messages.
createDatastoreAsync in interface AWSIoTAnalyticsAsyncpublic Future<CreateDatastoreResult> createDatastoreAsync(CreateDatastoreRequest request, AsyncHandler<CreateDatastoreRequest,CreateDatastoreResult> asyncHandler)
AWSIoTAnalyticsAsyncCreates a data store, which is a repository for messages.
createDatastoreAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<CreatePipelineResult> createPipelineAsync(CreatePipelineRequest request)
AWSIoTAnalyticsAsync
Creates a pipeline. A pipeline consumes messages from a channel and allows you to process the messages before
storing them in a data store. You must specify both a channel and a datastore activity
and, optionally, as many as 23 additional activities in the pipelineActivities array.
createPipelineAsync in interface AWSIoTAnalyticsAsyncpublic Future<CreatePipelineResult> createPipelineAsync(CreatePipelineRequest request, AsyncHandler<CreatePipelineRequest,CreatePipelineResult> asyncHandler)
AWSIoTAnalyticsAsync
Creates a pipeline. A pipeline consumes messages from a channel and allows you to process the messages before
storing them in a data store. You must specify both a channel and a datastore activity
and, optionally, as many as 23 additional activities in the pipelineActivities array.
createPipelineAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DeleteChannelResult> deleteChannelAsync(DeleteChannelRequest request)
AWSIoTAnalyticsAsyncDeletes the specified channel.
deleteChannelAsync in interface AWSIoTAnalyticsAsyncpublic Future<DeleteChannelResult> deleteChannelAsync(DeleteChannelRequest request, AsyncHandler<DeleteChannelRequest,DeleteChannelResult> asyncHandler)
AWSIoTAnalyticsAsyncDeletes the specified channel.
deleteChannelAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DeleteDatasetResult> deleteDatasetAsync(DeleteDatasetRequest request)
AWSIoTAnalyticsAsyncDeletes the specified dataset.
You do not have to delete the content of the dataset before you perform this operation.
deleteDatasetAsync in interface AWSIoTAnalyticsAsyncpublic Future<DeleteDatasetResult> deleteDatasetAsync(DeleteDatasetRequest request, AsyncHandler<DeleteDatasetRequest,DeleteDatasetResult> asyncHandler)
AWSIoTAnalyticsAsyncDeletes the specified dataset.
You do not have to delete the content of the dataset before you perform this operation.
deleteDatasetAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DeleteDatasetContentResult> deleteDatasetContentAsync(DeleteDatasetContentRequest request)
AWSIoTAnalyticsAsyncDeletes the content of the specified dataset.
deleteDatasetContentAsync in interface AWSIoTAnalyticsAsyncpublic Future<DeleteDatasetContentResult> deleteDatasetContentAsync(DeleteDatasetContentRequest request, AsyncHandler<DeleteDatasetContentRequest,DeleteDatasetContentResult> asyncHandler)
AWSIoTAnalyticsAsyncDeletes the content of the specified dataset.
deleteDatasetContentAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DeleteDatastoreResult> deleteDatastoreAsync(DeleteDatastoreRequest request)
AWSIoTAnalyticsAsyncDeletes the specified data store.
deleteDatastoreAsync in interface AWSIoTAnalyticsAsyncpublic Future<DeleteDatastoreResult> deleteDatastoreAsync(DeleteDatastoreRequest request, AsyncHandler<DeleteDatastoreRequest,DeleteDatastoreResult> asyncHandler)
AWSIoTAnalyticsAsyncDeletes the specified data store.
deleteDatastoreAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DeletePipelineResult> deletePipelineAsync(DeletePipelineRequest request)
AWSIoTAnalyticsAsyncDeletes the specified pipeline.
deletePipelineAsync in interface AWSIoTAnalyticsAsyncpublic Future<DeletePipelineResult> deletePipelineAsync(DeletePipelineRequest request, AsyncHandler<DeletePipelineRequest,DeletePipelineResult> asyncHandler)
AWSIoTAnalyticsAsyncDeletes the specified pipeline.
deletePipelineAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DescribeChannelResult> describeChannelAsync(DescribeChannelRequest request)
AWSIoTAnalyticsAsyncRetrieves information about a channel.
describeChannelAsync in interface AWSIoTAnalyticsAsyncpublic Future<DescribeChannelResult> describeChannelAsync(DescribeChannelRequest request, AsyncHandler<DescribeChannelRequest,DescribeChannelResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves information about a channel.
describeChannelAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DescribeDatasetResult> describeDatasetAsync(DescribeDatasetRequest request)
AWSIoTAnalyticsAsyncRetrieves information about a dataset.
describeDatasetAsync in interface AWSIoTAnalyticsAsyncpublic Future<DescribeDatasetResult> describeDatasetAsync(DescribeDatasetRequest request, AsyncHandler<DescribeDatasetRequest,DescribeDatasetResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves information about a dataset.
describeDatasetAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DescribeDatastoreResult> describeDatastoreAsync(DescribeDatastoreRequest request)
AWSIoTAnalyticsAsyncRetrieves information about a data store.
describeDatastoreAsync in interface AWSIoTAnalyticsAsyncpublic Future<DescribeDatastoreResult> describeDatastoreAsync(DescribeDatastoreRequest request, AsyncHandler<DescribeDatastoreRequest,DescribeDatastoreResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves information about a data store.
describeDatastoreAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DescribeLoggingOptionsResult> describeLoggingOptionsAsync(DescribeLoggingOptionsRequest request)
AWSIoTAnalyticsAsyncRetrieves the current settings of the IoT Analytics logging options.
describeLoggingOptionsAsync in interface AWSIoTAnalyticsAsyncpublic Future<DescribeLoggingOptionsResult> describeLoggingOptionsAsync(DescribeLoggingOptionsRequest request, AsyncHandler<DescribeLoggingOptionsRequest,DescribeLoggingOptionsResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves the current settings of the IoT Analytics logging options.
describeLoggingOptionsAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<DescribePipelineResult> describePipelineAsync(DescribePipelineRequest request)
AWSIoTAnalyticsAsyncRetrieves information about a pipeline.
describePipelineAsync in interface AWSIoTAnalyticsAsyncpublic Future<DescribePipelineResult> describePipelineAsync(DescribePipelineRequest request, AsyncHandler<DescribePipelineRequest,DescribePipelineResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves information about a pipeline.
describePipelineAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<GetDatasetContentResult> getDatasetContentAsync(GetDatasetContentRequest request)
AWSIoTAnalyticsAsyncRetrieves the contents of a dataset as presigned URIs.
getDatasetContentAsync in interface AWSIoTAnalyticsAsyncpublic Future<GetDatasetContentResult> getDatasetContentAsync(GetDatasetContentRequest request, AsyncHandler<GetDatasetContentRequest,GetDatasetContentResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves the contents of a dataset as presigned URIs.
getDatasetContentAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<ListChannelsResult> listChannelsAsync(ListChannelsRequest request)
AWSIoTAnalyticsAsyncRetrieves a list of channels.
listChannelsAsync in interface AWSIoTAnalyticsAsyncpublic Future<ListChannelsResult> listChannelsAsync(ListChannelsRequest request, AsyncHandler<ListChannelsRequest,ListChannelsResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves a list of channels.
listChannelsAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<ListDatasetContentsResult> listDatasetContentsAsync(ListDatasetContentsRequest request)
AWSIoTAnalyticsAsyncLists information about dataset contents that have been created.
listDatasetContentsAsync in interface AWSIoTAnalyticsAsyncpublic Future<ListDatasetContentsResult> listDatasetContentsAsync(ListDatasetContentsRequest request, AsyncHandler<ListDatasetContentsRequest,ListDatasetContentsResult> asyncHandler)
AWSIoTAnalyticsAsyncLists information about dataset contents that have been created.
listDatasetContentsAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<ListDatasetsResult> listDatasetsAsync(ListDatasetsRequest request)
AWSIoTAnalyticsAsyncRetrieves information about datasets.
listDatasetsAsync in interface AWSIoTAnalyticsAsyncpublic Future<ListDatasetsResult> listDatasetsAsync(ListDatasetsRequest request, AsyncHandler<ListDatasetsRequest,ListDatasetsResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves information about datasets.
listDatasetsAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<ListDatastoresResult> listDatastoresAsync(ListDatastoresRequest request)
AWSIoTAnalyticsAsyncRetrieves a list of data stores.
listDatastoresAsync in interface AWSIoTAnalyticsAsyncpublic Future<ListDatastoresResult> listDatastoresAsync(ListDatastoresRequest request, AsyncHandler<ListDatastoresRequest,ListDatastoresResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves a list of data stores.
listDatastoresAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<ListPipelinesResult> listPipelinesAsync(ListPipelinesRequest request)
AWSIoTAnalyticsAsyncRetrieves a list of pipelines.
listPipelinesAsync in interface AWSIoTAnalyticsAsyncpublic Future<ListPipelinesResult> listPipelinesAsync(ListPipelinesRequest request, AsyncHandler<ListPipelinesRequest,ListPipelinesResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves a list of pipelines.
listPipelinesAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest request)
AWSIoTAnalyticsAsyncLists the tags (metadata) that you have assigned to the resource.
listTagsForResourceAsync in interface AWSIoTAnalyticsAsyncpublic Future<ListTagsForResourceResult> listTagsForResourceAsync(ListTagsForResourceRequest request, AsyncHandler<ListTagsForResourceRequest,ListTagsForResourceResult> asyncHandler)
AWSIoTAnalyticsAsyncLists the tags (metadata) that you have assigned to the resource.
listTagsForResourceAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<PutLoggingOptionsResult> putLoggingOptionsAsync(PutLoggingOptionsRequest request)
AWSIoTAnalyticsAsyncSets or updates the IoT Analytics logging options.
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 five minutes for that change to take effect.
putLoggingOptionsAsync in interface AWSIoTAnalyticsAsyncpublic Future<PutLoggingOptionsResult> putLoggingOptionsAsync(PutLoggingOptionsRequest request, AsyncHandler<PutLoggingOptionsRequest,PutLoggingOptionsResult> asyncHandler)
AWSIoTAnalyticsAsyncSets or updates the IoT Analytics logging options.
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 five minutes for that change to take effect.
putLoggingOptionsAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<RunPipelineActivityResult> runPipelineActivityAsync(RunPipelineActivityRequest request)
AWSIoTAnalyticsAsyncSimulates the results of running a pipeline activity on a message payload.
runPipelineActivityAsync in interface AWSIoTAnalyticsAsyncpublic Future<RunPipelineActivityResult> runPipelineActivityAsync(RunPipelineActivityRequest request, AsyncHandler<RunPipelineActivityRequest,RunPipelineActivityResult> asyncHandler)
AWSIoTAnalyticsAsyncSimulates the results of running a pipeline activity on a message payload.
runPipelineActivityAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<SampleChannelDataResult> sampleChannelDataAsync(SampleChannelDataRequest request)
AWSIoTAnalyticsAsyncRetrieves a sample of messages from the specified channel ingested during the specified timeframe. Up to 10 messages can be retrieved.
sampleChannelDataAsync in interface AWSIoTAnalyticsAsyncpublic Future<SampleChannelDataResult> sampleChannelDataAsync(SampleChannelDataRequest request, AsyncHandler<SampleChannelDataRequest,SampleChannelDataResult> asyncHandler)
AWSIoTAnalyticsAsyncRetrieves a sample of messages from the specified channel ingested during the specified timeframe. Up to 10 messages can be retrieved.
sampleChannelDataAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<StartPipelineReprocessingResult> startPipelineReprocessingAsync(StartPipelineReprocessingRequest request)
AWSIoTAnalyticsAsyncStarts the reprocessing of raw message data through the pipeline.
startPipelineReprocessingAsync in interface AWSIoTAnalyticsAsyncpublic Future<StartPipelineReprocessingResult> startPipelineReprocessingAsync(StartPipelineReprocessingRequest request, AsyncHandler<StartPipelineReprocessingRequest,StartPipelineReprocessingResult> asyncHandler)
AWSIoTAnalyticsAsyncStarts the reprocessing of raw message data through the pipeline.
startPipelineReprocessingAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<TagResourceResult> tagResourceAsync(TagResourceRequest request)
AWSIoTAnalyticsAsyncAdds to or modifies the tags of the given resource. Tags are metadata that can be used to manage a resource.
tagResourceAsync in interface AWSIoTAnalyticsAsyncpublic Future<TagResourceResult> tagResourceAsync(TagResourceRequest request, AsyncHandler<TagResourceRequest,TagResourceResult> asyncHandler)
AWSIoTAnalyticsAsyncAdds to or modifies the tags of the given resource. Tags are metadata that can be used to manage a resource.
tagResourceAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest request)
AWSIoTAnalyticsAsyncRemoves the given tags (metadata) from the resource.
untagResourceAsync in interface AWSIoTAnalyticsAsyncpublic Future<UntagResourceResult> untagResourceAsync(UntagResourceRequest request, AsyncHandler<UntagResourceRequest,UntagResourceResult> asyncHandler)
AWSIoTAnalyticsAsyncRemoves the given tags (metadata) from the resource.
untagResourceAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<UpdateChannelResult> updateChannelAsync(UpdateChannelRequest request)
AWSIoTAnalyticsAsyncUsed to update the settings of a channel.
updateChannelAsync in interface AWSIoTAnalyticsAsyncpublic Future<UpdateChannelResult> updateChannelAsync(UpdateChannelRequest request, AsyncHandler<UpdateChannelRequest,UpdateChannelResult> asyncHandler)
AWSIoTAnalyticsAsyncUsed to update the settings of a channel.
updateChannelAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<UpdateDatasetResult> updateDatasetAsync(UpdateDatasetRequest request)
AWSIoTAnalyticsAsyncUpdates the settings of a dataset.
updateDatasetAsync in interface AWSIoTAnalyticsAsyncpublic Future<UpdateDatasetResult> updateDatasetAsync(UpdateDatasetRequest request, AsyncHandler<UpdateDatasetRequest,UpdateDatasetResult> asyncHandler)
AWSIoTAnalyticsAsyncUpdates the settings of a dataset.
updateDatasetAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<UpdateDatastoreResult> updateDatastoreAsync(UpdateDatastoreRequest request)
AWSIoTAnalyticsAsyncUsed to update the settings of a data store.
updateDatastoreAsync in interface AWSIoTAnalyticsAsyncpublic Future<UpdateDatastoreResult> updateDatastoreAsync(UpdateDatastoreRequest request, AsyncHandler<UpdateDatastoreRequest,UpdateDatastoreResult> asyncHandler)
AWSIoTAnalyticsAsyncUsed to update the settings of a data store.
updateDatastoreAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public Future<UpdatePipelineResult> updatePipelineAsync(UpdatePipelineRequest request)
AWSIoTAnalyticsAsync
Updates the settings of a pipeline. You must specify both a channel and a datastore
activity and, optionally, as many as 23 additional activities in the pipelineActivities array.
updatePipelineAsync in interface AWSIoTAnalyticsAsyncpublic Future<UpdatePipelineResult> updatePipelineAsync(UpdatePipelineRequest request, AsyncHandler<UpdatePipelineRequest,UpdatePipelineResult> asyncHandler)
AWSIoTAnalyticsAsync
Updates the settings of a pipeline. You must specify both a channel and a datastore
activity and, optionally, as many as 23 additional activities in the pipelineActivities array.
updatePipelineAsync in interface AWSIoTAnalyticsAsyncasyncHandler - Asynchronous callback handler for events in the lifecycle of the request. Users can provide an
implementation of the callback methods in this interface to receive notification of successful or
unsuccessful completion of the operation.public void shutdown()
getExecutorService().shutdown() followed by getExecutorService().awaitTermination() prior to
calling this method.shutdown in interface AWSIoTAnalyticsshutdown in class AWSIoTAnalyticsClient