Package software.amazon.awssdk.services.timestreamquery

Interface TimestreamQueryAsyncClient

  • All Superinterfaces:
    AutoCloseable, AwsClient, SdkAutoCloseable, SdkClient
    @Generated("software.amazon.awssdk:codegen")
@ThreadSafe
public interface TimestreamQueryAsyncClient
extends AwsClient
    Service client for accessing Timestream Query asynchronously. This can be created using the static builder() method.The asynchronous client performs non-blocking I/O when configured with any SdkAsyncHttpClient supported in the SDK. However, full non-blocking is not guaranteed as the async client may perform blocking calls in some cases such as credentials retrieval and endpoint discovery as part of the async API call. Amazon Timestream Query

    • Method Detail

      • cancelQuery

        default CompletableFuture<CancelQueryResponse> cancelQuery​(CancelQueryRequest cancelQueryRequest)

        Cancels a query that has been issued. Cancellation is provided only if the query has not completed running before the cancellation request was issued. Because cancellation is an idempotent operation, subsequent cancellation requests will return a CancellationMessage, indicating that the query has already been canceled. See code sample for details.

        Parameters:
        cancelQueryRequest -
        Returns:
        A Java Future containing the result of the CancelQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • cancelQuery

        default CompletableFuture<CancelQueryResponse> cancelQuery​(Consumer<CancelQueryRequest.Builder> cancelQueryRequest)

        Cancels a query that has been issued. Cancellation is provided only if the query has not completed running before the cancellation request was issued. Because cancellation is an idempotent operation, subsequent cancellation requests will return a CancellationMessage, indicating that the query has already been canceled. See code sample for details.


        This is a convenience which creates an instance of the CancelQueryRequest.Builder avoiding the need to create one manually via CancelQueryRequest.builder()

        Parameters:
        cancelQueryRequest - A Consumer that will call methods on CancelQueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the CancelQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • createScheduledQuery

        default CompletableFuture<CreateScheduledQueryResponse> createScheduledQuery​(CreateScheduledQueryRequest createScheduledQueryRequest)

        Create a scheduled query that will be run on your behalf at the configured schedule. Timestream assumes the execution role provided as part of the ScheduledQueryExecutionRoleArn parameter to run the query. You can use the NotificationConfiguration parameter to configure notification for your scheduled query operations.

        Parameters:
        createScheduledQueryRequest -
        Returns:
        A Java Future containing the result of the CreateScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • ConflictException Unable to poll results for a cancelled query.
        • InternalServerException An internal server error occurred while processing the request.
        • ServiceQuotaExceededException You have exceeded the service quota.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • createScheduledQuery

        default CompletableFuture<CreateScheduledQueryResponse> createScheduledQuery​(Consumer<CreateScheduledQueryRequest.Builder> createScheduledQueryRequest)

        Create a scheduled query that will be run on your behalf at the configured schedule. Timestream assumes the execution role provided as part of the ScheduledQueryExecutionRoleArn parameter to run the query. You can use the NotificationConfiguration parameter to configure notification for your scheduled query operations.


        This is a convenience which creates an instance of the CreateScheduledQueryRequest.Builder avoiding the need to create one manually via CreateScheduledQueryRequest.builder()

        Parameters:
        createScheduledQueryRequest - A Consumer that will call methods on CreateScheduledQueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the CreateScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • ConflictException Unable to poll results for a cancelled query.
        • InternalServerException An internal server error occurred while processing the request.
        • ServiceQuotaExceededException You have exceeded the service quota.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • deleteScheduledQuery

        default CompletableFuture<DeleteScheduledQueryResponse> deleteScheduledQuery​(DeleteScheduledQueryRequest deleteScheduledQueryRequest)

        Deletes a given scheduled query. This is an irreversible operation.

        Parameters:
        deleteScheduledQueryRequest -
        Returns:
        A Java Future containing the result of the DeleteScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • deleteScheduledQuery

        default CompletableFuture<DeleteScheduledQueryResponse> deleteScheduledQuery​(Consumer<DeleteScheduledQueryRequest.Builder> deleteScheduledQueryRequest)

        Deletes a given scheduled query. This is an irreversible operation.


        This is a convenience which creates an instance of the DeleteScheduledQueryRequest.Builder avoiding the need to create one manually via DeleteScheduledQueryRequest.builder()

        Parameters:
        deleteScheduledQueryRequest - A Consumer that will call methods on DeleteScheduledQueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the DeleteScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • describeAccountSettings

        default CompletableFuture<DescribeAccountSettingsResponse> describeAccountSettings​(DescribeAccountSettingsRequest describeAccountSettingsRequest)

        Describes the settings for your account that include the query pricing model and the configured maximum TCUs the service can use for your query workload.

        You're charged only for the duration of compute units used for your workloads.

        Parameters:
        describeAccountSettingsRequest -
        Returns:
        A Java Future containing the result of the DescribeAccountSettings operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • describeAccountSettings

        default CompletableFuture<DescribeAccountSettingsResponse> describeAccountSettings​(Consumer<DescribeAccountSettingsRequest.Builder> describeAccountSettingsRequest)

        Describes the settings for your account that include the query pricing model and the configured maximum TCUs the service can use for your query workload.

        You're charged only for the duration of compute units used for your workloads.


        This is a convenience which creates an instance of the DescribeAccountSettingsRequest.Builder avoiding the need to create one manually via DescribeAccountSettingsRequest.builder()

        Parameters:
        describeAccountSettingsRequest - A Consumer that will call methods on DescribeAccountSettingsRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the DescribeAccountSettings operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • describeEndpoints

        default CompletableFuture<DescribeEndpointsResponse> describeEndpoints​(DescribeEndpointsRequest describeEndpointsRequest)

        DescribeEndpoints returns a list of available endpoints to make Timestream API calls against. This API is available through both Write and Query.

        Because the Timestream SDKs are designed to transparently work with the service’s architecture, including the management and mapping of the service endpoints, it is not recommended that you use this API unless:

        For detailed information on how and when to use and implement DescribeEndpoints, see The Endpoint Discovery Pattern.

        Parameters:
        describeEndpointsRequest -
        Returns:
        A Java Future containing the result of the DescribeEndpoints operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • InternalServerException An internal server error occurred while processing the request.
        • ValidationException Invalid or malformed request.
        • ThrottlingException The request was throttled due to excessive requests.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • describeEndpoints

        default CompletableFuture<DescribeEndpointsResponse> describeEndpoints​(Consumer<DescribeEndpointsRequest.Builder> describeEndpointsRequest)

        DescribeEndpoints returns a list of available endpoints to make Timestream API calls against. This API is available through both Write and Query.

        Because the Timestream SDKs are designed to transparently work with the service’s architecture, including the management and mapping of the service endpoints, it is not recommended that you use this API unless:

        For detailed information on how and when to use and implement DescribeEndpoints, see The Endpoint Discovery Pattern.


        This is a convenience which creates an instance of the DescribeEndpointsRequest.Builder avoiding the need to create one manually via DescribeEndpointsRequest.builder()

        Parameters:
        describeEndpointsRequest - A Consumer that will call methods on DescribeEndpointsRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the DescribeEndpoints operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • InternalServerException An internal server error occurred while processing the request.
        • ValidationException Invalid or malformed request.
        • ThrottlingException The request was throttled due to excessive requests.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • describeScheduledQuery

        default CompletableFuture<DescribeScheduledQueryResponse> describeScheduledQuery​(DescribeScheduledQueryRequest describeScheduledQueryRequest)

        Provides detailed information about a scheduled query.

        Parameters:
        describeScheduledQueryRequest -
        Returns:
        A Java Future containing the result of the DescribeScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • describeScheduledQuery

        default CompletableFuture<DescribeScheduledQueryResponse> describeScheduledQuery​(Consumer<DescribeScheduledQueryRequest.Builder> describeScheduledQueryRequest)

        Provides detailed information about a scheduled query.


        This is a convenience which creates an instance of the DescribeScheduledQueryRequest.Builder avoiding the need to create one manually via DescribeScheduledQueryRequest.builder()

        Parameters:
        describeScheduledQueryRequest - A Consumer that will call methods on DescribeScheduledQueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the DescribeScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • executeScheduledQuery

        default CompletableFuture<ExecuteScheduledQueryResponse> executeScheduledQuery​(ExecuteScheduledQueryRequest executeScheduledQueryRequest)

        You can use this API to run a scheduled query manually.

        If you enabled QueryInsights, this API also returns insights and metrics related to the query that you executed as part of an Amazon SNS notification. QueryInsights helps with performance tuning of your query. For more information about QueryInsights, see Using query insights to optimize queries in Amazon Timestream.

        Parameters:
        executeScheduledQueryRequest -
        Returns:
        A Java Future containing the result of the ExecuteScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • executeScheduledQuery

        default CompletableFuture<ExecuteScheduledQueryResponse> executeScheduledQuery​(Consumer<ExecuteScheduledQueryRequest.Builder> executeScheduledQueryRequest)

        You can use this API to run a scheduled query manually.

        If you enabled QueryInsights, this API also returns insights and metrics related to the query that you executed as part of an Amazon SNS notification. QueryInsights helps with performance tuning of your query. For more information about QueryInsights, see Using query insights to optimize queries in Amazon Timestream.


        This is a convenience which creates an instance of the ExecuteScheduledQueryRequest.Builder avoiding the need to create one manually via ExecuteScheduledQueryRequest.builder()

        Parameters:
        executeScheduledQueryRequest - A Consumer that will call methods on ExecuteScheduledQueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the ExecuteScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listScheduledQueries

        default CompletableFuture<ListScheduledQueriesResponse> listScheduledQueries​(ListScheduledQueriesRequest listScheduledQueriesRequest)

        Gets a list of all scheduled queries in the caller's Amazon account and Region. ListScheduledQueries is eventually consistent.

        Parameters:
        listScheduledQueriesRequest -
        Returns:
        A Java Future containing the result of the ListScheduledQueries operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listScheduledQueries

        default CompletableFuture<ListScheduledQueriesResponse> listScheduledQueries​(Consumer<ListScheduledQueriesRequest.Builder> listScheduledQueriesRequest)

        Gets a list of all scheduled queries in the caller's Amazon account and Region. ListScheduledQueries is eventually consistent.


        This is a convenience which creates an instance of the ListScheduledQueriesRequest.Builder avoiding the need to create one manually via ListScheduledQueriesRequest.builder()

        Parameters:
        listScheduledQueriesRequest - A Consumer that will call methods on ListScheduledQueriesRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the ListScheduledQueries operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listScheduledQueriesPaginator

        default ListScheduledQueriesPublisher listScheduledQueriesPaginator​(ListScheduledQueriesRequest listScheduledQueriesRequest)

        This is a variant of listScheduledQueries(software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesRequest) 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.timestreamquery.paginators.ListScheduledQueriesPublisher publisher = client.listScheduledQueriesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
        2) Using a custom subscriber 
         
 software.amazon.awssdk.services.timestreamquery.paginators.ListScheduledQueriesPublisher publisher = client.listScheduledQueriesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesResponse response) { //... };
 });
        As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

        Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

        Note: If you prefer to have control on service calls, use the listScheduledQueries(software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesRequest) operation.

        Parameters:
        listScheduledQueriesRequest -
        Returns:
        A custom publisher that can be subscribed to request a stream of response pages.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listScheduledQueriesPaginator

        default ListScheduledQueriesPublisher listScheduledQueriesPaginator​(Consumer<ListScheduledQueriesRequest.Builder> listScheduledQueriesRequest)

        This is a variant of listScheduledQueries(software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesRequest) 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.timestreamquery.paginators.ListScheduledQueriesPublisher publisher = client.listScheduledQueriesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
        2) Using a custom subscriber 
         
 software.amazon.awssdk.services.timestreamquery.paginators.ListScheduledQueriesPublisher publisher = client.listScheduledQueriesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesResponse response) { //... };
 });
        As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

        Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

        Note: If you prefer to have control on service calls, use the listScheduledQueries(software.amazon.awssdk.services.timestreamquery.model.ListScheduledQueriesRequest) operation.


        This is a convenience which creates an instance of the ListScheduledQueriesRequest.Builder avoiding the need to create one manually via ListScheduledQueriesRequest.builder()

        Parameters:
        listScheduledQueriesRequest - A Consumer that will call methods on ListScheduledQueriesRequest.Builder to create a request.
        Returns:
        A custom publisher that can be subscribed to request a stream of response pages.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listTagsForResource

        default CompletableFuture<ListTagsForResourceResponse> listTagsForResource​(ListTagsForResourceRequest listTagsForResourceRequest)

        List all tags on a Timestream query resource.

        Parameters:
        listTagsForResourceRequest -
        Returns:
        A Java Future containing the result of the ListTagsForResource operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listTagsForResource

        default CompletableFuture<ListTagsForResourceResponse> listTagsForResource​(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)

        List all tags on a Timestream query resource.


        This is a convenience which creates an instance of the ListTagsForResourceRequest.Builder avoiding the need to create one manually via ListTagsForResourceRequest.builder()

        Parameters:
        listTagsForResourceRequest - A Consumer that will call methods on ListTagsForResourceRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the ListTagsForResource operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listTagsForResourcePaginator

        default ListTagsForResourcePublisher listTagsForResourcePaginator​(ListTagsForResourceRequest listTagsForResourceRequest)

        This is a variant of listTagsForResource(software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceRequest) 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.timestreamquery.paginators.ListTagsForResourcePublisher publisher = client.listTagsForResourcePaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
        2) Using a custom subscriber 
         
 software.amazon.awssdk.services.timestreamquery.paginators.ListTagsForResourcePublisher publisher = client.listTagsForResourcePaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceResponse response) { //... };
 });
        As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

        Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

        Note: If you prefer to have control on service calls, use the listTagsForResource(software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceRequest) operation.

        Parameters:
        listTagsForResourceRequest -
        Returns:
        A custom publisher that can be subscribed to request a stream of response pages.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • listTagsForResourcePaginator

        default ListTagsForResourcePublisher listTagsForResourcePaginator​(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)

        This is a variant of listTagsForResource(software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceRequest) 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.timestreamquery.paginators.ListTagsForResourcePublisher publisher = client.listTagsForResourcePaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
        2) Using a custom subscriber 
         
 software.amazon.awssdk.services.timestreamquery.paginators.ListTagsForResourcePublisher publisher = client.listTagsForResourcePaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceResponse response) { //... };
 });
        As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

        Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

        Note: If you prefer to have control on service calls, use the listTagsForResource(software.amazon.awssdk.services.timestreamquery.model.ListTagsForResourceRequest) operation.


        This is a convenience which creates an instance of the ListTagsForResourceRequest.Builder avoiding the need to create one manually via ListTagsForResourceRequest.builder()

        Parameters:
        listTagsForResourceRequest - A Consumer that will call methods on ListTagsForResourceRequest.Builder to create a request.
        Returns:
        A custom publisher that can be subscribed to request a stream of response pages.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • prepareQuery

        default CompletableFuture<PrepareQueryResponse> prepareQuery​(PrepareQueryRequest prepareQueryRequest)

        A synchronous operation that allows you to submit a query with parameters to be stored by Timestream for later running. Timestream only supports using this operation with ValidateOnly set to true.

        Parameters:
        prepareQueryRequest -
        Returns:
        A Java Future containing the result of the PrepareQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • prepareQuery

        default CompletableFuture<PrepareQueryResponse> prepareQuery​(Consumer<PrepareQueryRequest.Builder> prepareQueryRequest)

        A synchronous operation that allows you to submit a query with parameters to be stored by Timestream for later running. Timestream only supports using this operation with ValidateOnly set to true.


        This is a convenience which creates an instance of the PrepareQueryRequest.Builder avoiding the need to create one manually via PrepareQueryRequest.builder()

        Parameters:
        prepareQueryRequest - A Consumer that will call methods on PrepareQueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the PrepareQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • query

        default CompletableFuture<QueryResponse> query​(QueryRequest queryRequest)

        Query is a synchronous operation that enables you to run a query against your Amazon Timestream data.

        If you enabled QueryInsights, this API also returns insights and metrics related to the query that you executed. QueryInsights helps with performance tuning of your query. For more information about QueryInsights, see Using query insights to optimize queries in Amazon Timestream.

        The maximum number of Query API requests you're allowed to make with QueryInsights enabled is 1 query per second (QPS). If you exceed this query rate, it might result in throttling.

        Query will time out after 60 seconds. You must update the default timeout in the SDK to support a timeout of 60 seconds. See the code sample for details.

        Your query request will fail in the following cases:

        • If you submit a Query request with the same client token outside of the 5-minute idempotency window.

        • If you submit a Query request with the same client token, but change other parameters, within the 5-minute idempotency window.

        • If the size of the row (including the query metadata) exceeds 1 MB, then the query will fail with the following error message:

          Query aborted as max page response size has been exceeded by the output result row

        • If the IAM principal of the query initiator and the result reader are not the same and/or the query initiator and the result reader do not have the same query string in the query requests, the query will fail with an Invalid pagination token error.

        Parameters:
        queryRequest -
        Returns:
        A Java Future containing the result of the Query operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • ConflictException Unable to poll results for a cancelled query.
        • InternalServerException An internal server error occurred while processing the request.
        • QueryExecutionException Timestream was unable to run the query successfully.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • query

        default CompletableFuture<QueryResponse> query​(Consumer<QueryRequest.Builder> queryRequest)

        Query is a synchronous operation that enables you to run a query against your Amazon Timestream data.

        If you enabled QueryInsights, this API also returns insights and metrics related to the query that you executed. QueryInsights helps with performance tuning of your query. For more information about QueryInsights, see Using query insights to optimize queries in Amazon Timestream.

        The maximum number of Query API requests you're allowed to make with QueryInsights enabled is 1 query per second (QPS). If you exceed this query rate, it might result in throttling.

        Query will time out after 60 seconds. You must update the default timeout in the SDK to support a timeout of 60 seconds. See the code sample for details.

        Your query request will fail in the following cases:

        • If you submit a Query request with the same client token outside of the 5-minute idempotency window.

        • If you submit a Query request with the same client token, but change other parameters, within the 5-minute idempotency window.

        • If the size of the row (including the query metadata) exceeds 1 MB, then the query will fail with the following error message:

          Query aborted as max page response size has been exceeded by the output result row

        • If the IAM principal of the query initiator and the result reader are not the same and/or the query initiator and the result reader do not have the same query string in the query requests, the query will fail with an Invalid pagination token error.


        This is a convenience which creates an instance of the QueryRequest.Builder avoiding the need to create one manually via QueryRequest.builder()

        Parameters:
        queryRequest - A Consumer that will call methods on QueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the Query operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • ConflictException Unable to poll results for a cancelled query.
        • InternalServerException An internal server error occurred while processing the request.
        • QueryExecutionException Timestream was unable to run the query successfully.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • queryPaginator

        default QueryPublisher queryPaginator​(QueryRequest queryRequest)

        This is a variant of query(software.amazon.awssdk.services.timestreamquery.model.QueryRequest) 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.timestreamquery.paginators.QueryPublisher publisher = client.queryPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
        2) Using a custom subscriber 
         
 software.amazon.awssdk.services.timestreamquery.paginators.QueryPublisher publisher = client.queryPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.timestreamquery.model.QueryResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.timestreamquery.model.QueryResponse response) { //... };
 });
        As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

        Please notice that the configuration of MaxRows won't limit the number of results you get with the paginator. It only limits the number of results in each page.

        Note: If you prefer to have control on service calls, use the query(software.amazon.awssdk.services.timestreamquery.model.QueryRequest) operation.

        Parameters:
        queryRequest -
        Returns:
        A custom publisher that can be subscribed to request a stream of response pages.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • ConflictException Unable to poll results for a cancelled query.
        • InternalServerException An internal server error occurred while processing the request.
        • QueryExecutionException Timestream was unable to run the query successfully.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • queryPaginator

        default QueryPublisher queryPaginator​(Consumer<QueryRequest.Builder> queryRequest)

        This is a variant of query(software.amazon.awssdk.services.timestreamquery.model.QueryRequest) 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.timestreamquery.paginators.QueryPublisher publisher = client.queryPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
        2) Using a custom subscriber 
         
 software.amazon.awssdk.services.timestreamquery.paginators.QueryPublisher publisher = client.queryPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.timestreamquery.model.QueryResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.timestreamquery.model.QueryResponse response) { //... };
 });
        As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

        Please notice that the configuration of MaxRows won't limit the number of results you get with the paginator. It only limits the number of results in each page.

        Note: If you prefer to have control on service calls, use the query(software.amazon.awssdk.services.timestreamquery.model.QueryRequest) operation.


        This is a convenience which creates an instance of the QueryRequest.Builder avoiding the need to create one manually via QueryRequest.builder()

        Parameters:
        queryRequest - A Consumer that will call methods on QueryRequest.Builder to create a request.
        Returns:
        A custom publisher that can be subscribed to request a stream of response pages.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • ConflictException Unable to poll results for a cancelled query.
        • InternalServerException An internal server error occurred while processing the request.
        • QueryExecutionException Timestream was unable to run the query successfully.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • tagResource

        default CompletableFuture<TagResourceResponse> tagResource​(TagResourceRequest tagResourceRequest)

        Associate a set of tags with a Timestream resource. You can then activate these user-defined tags so that they appear on the Billing and Cost Management console for cost allocation tracking.

        Parameters:
        tagResourceRequest -
        Returns:
        A Java Future containing the result of the TagResource operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ResourceNotFoundException The requested resource could not be found.
        • ServiceQuotaExceededException You have exceeded the service quota.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • tagResource

        default CompletableFuture<TagResourceResponse> tagResource​(Consumer<TagResourceRequest.Builder> tagResourceRequest)

        Associate a set of tags with a Timestream resource. You can then activate these user-defined tags so that they appear on the Billing and Cost Management console for cost allocation tracking.


        This is a convenience which creates an instance of the TagResourceRequest.Builder avoiding the need to create one manually via TagResourceRequest.builder()

        Parameters:
        tagResourceRequest - A Consumer that will call methods on TagResourceRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the TagResource operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ResourceNotFoundException The requested resource could not be found.
        • ServiceQuotaExceededException You have exceeded the service quota.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • untagResource

        default CompletableFuture<UntagResourceResponse> untagResource​(UntagResourceRequest untagResourceRequest)

        Removes the association of tags from a Timestream query resource.

        Parameters:
        untagResourceRequest -
        Returns:
        A Java Future containing the result of the UntagResource operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ValidationException Invalid or malformed request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ResourceNotFoundException The requested resource could not be found.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • untagResource

        default CompletableFuture<UntagResourceResponse> untagResource​(Consumer<UntagResourceRequest.Builder> untagResourceRequest)

        Removes the association of tags from a Timestream query resource.


        This is a convenience which creates an instance of the UntagResourceRequest.Builder avoiding the need to create one manually via UntagResourceRequest.builder()

        Parameters:
        untagResourceRequest - A Consumer that will call methods on UntagResourceRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the UntagResource operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • ValidationException Invalid or malformed request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ResourceNotFoundException The requested resource could not be found.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • updateAccountSettings

        default CompletableFuture<UpdateAccountSettingsResponse> updateAccountSettings​(UpdateAccountSettingsRequest updateAccountSettingsRequest)

        Transitions your account to use TCUs for query pricing and modifies the maximum query compute units that you've configured. If you reduce the value of MaxQueryTCU to a desired configuration, the new value can take up to 24 hours to be effective.

        After you've transitioned your account to use TCUs for query pricing, you can't transition to using bytes scanned for query pricing.

        Parameters:
        updateAccountSettingsRequest -
        Returns:
        A Java Future containing the result of the UpdateAccountSettings operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • updateAccountSettings

        default CompletableFuture<UpdateAccountSettingsResponse> updateAccountSettings​(Consumer<UpdateAccountSettingsRequest.Builder> updateAccountSettingsRequest)

        Transitions your account to use TCUs for query pricing and modifies the maximum query compute units that you've configured. If you reduce the value of MaxQueryTCU to a desired configuration, the new value can take up to 24 hours to be effective.

        After you've transitioned your account to use TCUs for query pricing, you can't transition to using bytes scanned for query pricing.


        This is a convenience which creates an instance of the UpdateAccountSettingsRequest.Builder avoiding the need to create one manually via UpdateAccountSettingsRequest.builder()

        Parameters:
        updateAccountSettingsRequest - A Consumer that will call methods on UpdateAccountSettingsRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the UpdateAccountSettings operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • updateScheduledQuery

        default CompletableFuture<UpdateScheduledQueryResponse> updateScheduledQuery​(UpdateScheduledQueryRequest updateScheduledQueryRequest)

        Update a scheduled query.

        Parameters:
        updateScheduledQueryRequest -
        Returns:
        A Java Future containing the result of the UpdateScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation

      • updateScheduledQuery

        default CompletableFuture<UpdateScheduledQueryResponse> updateScheduledQuery​(Consumer<UpdateScheduledQueryRequest.Builder> updateScheduledQueryRequest)

        Update a scheduled query.


        This is a convenience which creates an instance of the UpdateScheduledQueryRequest.Builder avoiding the need to create one manually via UpdateScheduledQueryRequest.builder()

        Parameters:
        updateScheduledQueryRequest - A Consumer that will call methods on UpdateScheduledQueryRequest.Builder to create a request.
        Returns:
        A Java Future containing the result of the UpdateScheduledQuery operation returned by the service.
        The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
        • AccessDeniedException You do not have the necessary permissions to access the account settings.
        • InternalServerException An internal server error occurred while processing the request.
        • ResourceNotFoundException The requested resource could not be found.
        • ThrottlingException The request was throttled due to excessive requests.
        • ValidationException Invalid or malformed request.
        • InvalidEndpointException The requested endpoint is invalid.
        • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
        • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
        • TimestreamQueryException Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
        See Also:
        AWS API Documentation