/* * Copyright 2018-2023 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with * the License. A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions * and limitations under the License. */ package com.amazonaws.services.finspace; import org.w3c.dom.*; import java.net.*; import java.util.*; import javax.annotation.Generated; import org.apache.commons.logging.*; import com.amazonaws.*; import com.amazonaws.annotation.SdkInternalApi; import com.amazonaws.auth.*; import com.amazonaws.handlers.*; import com.amazonaws.http.*; import com.amazonaws.internal.*; import com.amazonaws.internal.auth.*; import com.amazonaws.metrics.*; import com.amazonaws.regions.*; import com.amazonaws.transform.*; import com.amazonaws.util.*; import com.amazonaws.protocol.json.*; import com.amazonaws.util.AWSRequestMetrics.Field; import com.amazonaws.annotation.ThreadSafe; import com.amazonaws.client.AwsSyncClientParams; import com.amazonaws.client.builder.AdvancedConfig; import com.amazonaws.services.finspace.AWSfinspaceClientBuilder; import com.amazonaws.AmazonServiceException; import com.amazonaws.services.finspace.model.*; import com.amazonaws.services.finspace.model.transform.*; /** * Client for accessing finspace. All service calls made using this client are blocking, and will not return until the * service call completes. *
*
* The FinSpace management service provides the APIs for managing FinSpace environments. *
*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AWSfinspaceClient extends AmazonWebServiceClient implements AWSfinspace { /** Provider for AWS credentials. */ private final AWSCredentialsProvider awsCredentialsProvider; private static final Log log = LogFactory.getLog(AWSfinspace.class); /** Default signing name for the service. */ private static final String DEFAULT_SIGNING_NAME = "finspace"; /** Client configuration factory providing ClientConfigurations tailored to this client */ protected static final ClientConfigurationFactory configFactory = new ClientConfigurationFactory(); private final AdvancedConfig advancedConfig; private static final com.amazonaws.protocol.json.SdkJsonProtocolFactory protocolFactory = new com.amazonaws.protocol.json.SdkJsonProtocolFactory( new JsonClientMetadata() .withProtocolVersion("1.1") .withSupportsCbor(false) .withSupportsIon(false) .withContentTypeOverride("application/json") .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("InvalidRequestException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.InvalidRequestExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ThrottlingException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.ThrottlingExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ServiceQuotaExceededException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.ServiceQuotaExceededExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("InternalServerException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.InternalServerExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("LimitExceededException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.LimitExceededExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("AccessDeniedException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.AccessDeniedExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ConflictException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.ConflictExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ResourceNotFoundException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.ResourceNotFoundExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ValidationException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.ValidationExceptionUnmarshaller.getInstance())) .addErrorMetadata( new JsonErrorShapeMetadata().withErrorCode("ResourceAlreadyExistsException").withExceptionUnmarshaller( com.amazonaws.services.finspace.model.transform.ResourceAlreadyExistsExceptionUnmarshaller.getInstance())) .withBaseServiceExceptionClass(com.amazonaws.services.finspace.model.AWSfinspaceException.class)); public static AWSfinspaceClientBuilder builder() { return AWSfinspaceClientBuilder.standard(); } /** * Constructs a new client to invoke service methods on finspace using the specified parameters. * ** All service calls made using this new client object are blocking, and will not return until the service call * completes. * * @param clientParams * Object providing client parameters. */ AWSfinspaceClient(AwsSyncClientParams clientParams) { this(clientParams, false); } /** * Constructs a new client to invoke service methods on finspace using the specified parameters. * *
* All service calls made using this new client object are blocking, and will not return until the service call * completes. * * @param clientParams * Object providing client parameters. */ AWSfinspaceClient(AwsSyncClientParams clientParams, boolean endpointDiscoveryEnabled) { super(clientParams); this.awsCredentialsProvider = clientParams.getCredentialsProvider(); this.advancedConfig = clientParams.getAdvancedConfig(); init(); } private void init() { setServiceNameIntern(DEFAULT_SIGNING_NAME); setEndpointPrefix(ENDPOINT_PREFIX); // calling this.setEndPoint(...) will also modify the signer accordingly setEndpoint("finspace.us-east-1.amazonaws.com"); HandlerChainFactory chainFactory = new HandlerChainFactory(); requestHandler2s.addAll(chainFactory.newRequestHandlerChain("/com/amazonaws/services/finspace/request.handlers")); requestHandler2s.addAll(chainFactory.newRequestHandler2Chain("/com/amazonaws/services/finspace/request.handler2s")); requestHandler2s.addAll(chainFactory.getGlobalHandlers()); } /** *
* Create a new FinSpace environment. *
* * @param createEnvironmentRequest * @return Result of the CreateEnvironment operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ThrottlingException * The request was denied due to request throttling. * @throws ServiceQuotaExceededException * You have exceeded your service quota. To perform the requested action, remove some of the relevant * resources, or use Service Quotas to request a service quota increase. * @throws LimitExceededException * A service limit or quota is exceeded. * @sample AWSfinspace.CreateEnvironment * @see AWS API * Documentation */ @Override public CreateEnvironmentResult createEnvironment(CreateEnvironmentRequest request) { request = beforeClientExecution(request); return executeCreateEnvironment(request); } @SdkInternalApi final CreateEnvironmentResult executeCreateEnvironment(CreateEnvironmentRequest createEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(createEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Creates a changeset for a kdb database. A changeset allows you to add and delete existing files by using an * ordered list of change requests. *
* * @param createKxChangesetRequest * @return Result of the CreateKxChangeset operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @throws LimitExceededException * A service limit or quota is exceeded. * @sample AWSfinspace.CreateKxChangeset * @see AWS API * Documentation */ @Override public CreateKxChangesetResult createKxChangeset(CreateKxChangesetRequest request) { request = beforeClientExecution(request); return executeCreateKxChangeset(request); } @SdkInternalApi final CreateKxChangesetResult executeCreateKxChangeset(CreateKxChangesetRequest createKxChangesetRequest) { ExecutionContext executionContext = createExecutionContext(createKxChangesetRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Creates a new kdb cluster. *
* * @param createKxClusterRequest * @return Result of the CreateKxCluster operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AWSfinspace.CreateKxCluster * @see AWS API * Documentation */ @Override public CreateKxClusterResult createKxCluster(CreateKxClusterRequest request) { request = beforeClientExecution(request); return executeCreateKxCluster(request); } @SdkInternalApi final CreateKxClusterResult executeCreateKxCluster(CreateKxClusterRequest createKxClusterRequest) { ExecutionContext executionContext = createExecutionContext(createKxClusterRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Creates a new kdb database in the environment. *
* * @param createKxDatabaseRequest * @return Result of the CreateKxDatabase operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @throws ResourceAlreadyExistsException * The specified resource group already exists. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws LimitExceededException * A service limit or quota is exceeded. * @sample AWSfinspace.CreateKxDatabase * @see AWS API * Documentation */ @Override public CreateKxDatabaseResult createKxDatabase(CreateKxDatabaseRequest request) { request = beforeClientExecution(request); return executeCreateKxDatabase(request); } @SdkInternalApi final CreateKxDatabaseResult executeCreateKxDatabase(CreateKxDatabaseRequest createKxDatabaseRequest) { ExecutionContext executionContext = createExecutionContext(createKxDatabaseRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Creates a managed kdb environment for the account. *
* * @param createKxEnvironmentRequest * @return Result of the CreateKxEnvironment operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ThrottlingException * The request was denied due to request throttling. * @throws ServiceQuotaExceededException * You have exceeded your service quota. To perform the requested action, remove some of the relevant * resources, or use Service Quotas to request a service quota increase. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @sample AWSfinspace.CreateKxEnvironment * @see AWS * API Documentation */ @Override public CreateKxEnvironmentResult createKxEnvironment(CreateKxEnvironmentRequest request) { request = beforeClientExecution(request); return executeCreateKxEnvironment(request); } @SdkInternalApi final CreateKxEnvironmentResult executeCreateKxEnvironment(CreateKxEnvironmentRequest createKxEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(createKxEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Creates a user in FinSpace kdb environment with an associated IAM role. *
* * @param createKxUserRequest * @return Result of the CreateKxUser operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ResourceAlreadyExistsException * The specified resource group already exists. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @sample AWSfinspace.CreateKxUser * @see AWS API * Documentation */ @Override public CreateKxUserResult createKxUser(CreateKxUserRequest request) { request = beforeClientExecution(request); return executeCreateKxUser(request); } @SdkInternalApi final CreateKxUserResult executeCreateKxUser(CreateKxUserRequest createKxUserRequest) { ExecutionContext executionContext = createExecutionContext(createKxUserRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Delete an FinSpace environment. *
* * @param deleteEnvironmentRequest * @return Result of the DeleteEnvironment operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ThrottlingException * The request was denied due to request throttling. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.DeleteEnvironment * @see AWS API * Documentation */ @Override public DeleteEnvironmentResult deleteEnvironment(DeleteEnvironmentRequest request) { request = beforeClientExecution(request); return executeDeleteEnvironment(request); } @SdkInternalApi final DeleteEnvironmentResult executeDeleteEnvironment(DeleteEnvironmentRequest deleteEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(deleteEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Deletes a kdb cluster. *
* * @param deleteKxClusterRequest * @return Result of the DeleteKxCluster operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.DeleteKxCluster * @see AWS API * Documentation */ @Override public DeleteKxClusterResult deleteKxCluster(DeleteKxClusterRequest request) { request = beforeClientExecution(request); return executeDeleteKxCluster(request); } @SdkInternalApi final DeleteKxClusterResult executeDeleteKxCluster(DeleteKxClusterRequest deleteKxClusterRequest) { ExecutionContext executionContext = createExecutionContext(deleteKxClusterRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Deletes the specified database and all of its associated data. This action is irreversible. You must copy any * data out of the database before deleting it if the data is to be retained. *
* * @param deleteKxDatabaseRequest * @return Result of the DeleteKxDatabase operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @sample AWSfinspace.DeleteKxDatabase * @see AWS API * Documentation */ @Override public DeleteKxDatabaseResult deleteKxDatabase(DeleteKxDatabaseRequest request) { request = beforeClientExecution(request); return executeDeleteKxDatabase(request); } @SdkInternalApi final DeleteKxDatabaseResult executeDeleteKxDatabase(DeleteKxDatabaseRequest deleteKxDatabaseRequest) { ExecutionContext executionContext = createExecutionContext(deleteKxDatabaseRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Deletes the kdb environment. This action is irreversible. Deleting a kdb environment will remove all the * associated data and any services running in it. *
* * @param deleteKxEnvironmentRequest * @return Result of the DeleteKxEnvironment operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ThrottlingException * The request was denied due to request throttling. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.DeleteKxEnvironment * @see AWS * API Documentation */ @Override public DeleteKxEnvironmentResult deleteKxEnvironment(DeleteKxEnvironmentRequest request) { request = beforeClientExecution(request); return executeDeleteKxEnvironment(request); } @SdkInternalApi final DeleteKxEnvironmentResult executeDeleteKxEnvironment(DeleteKxEnvironmentRequest deleteKxEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(deleteKxEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Deletes a user in the specified kdb environment. *
* * @param deleteKxUserRequest * @return Result of the DeleteKxUser operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.DeleteKxUser * @see AWS API * Documentation */ @Override public DeleteKxUserResult deleteKxUser(DeleteKxUserRequest request) { request = beforeClientExecution(request); return executeDeleteKxUser(request); } @SdkInternalApi final DeleteKxUserResult executeDeleteKxUser(DeleteKxUserRequest deleteKxUserRequest) { ExecutionContext executionContext = createExecutionContext(deleteKxUserRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Returns the FinSpace environment object. *
* * @param getEnvironmentRequest * @return Result of the GetEnvironment operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AWSfinspace.GetEnvironment * @see AWS API * Documentation */ @Override public GetEnvironmentResult getEnvironment(GetEnvironmentRequest request) { request = beforeClientExecution(request); return executeGetEnvironment(request); } @SdkInternalApi final GetEnvironmentResult executeGetEnvironment(GetEnvironmentRequest getEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(getEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Returns information about a kdb changeset. *
* * @param getKxChangesetRequest * @return Result of the GetKxChangeset operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.GetKxChangeset * @see AWS API * Documentation */ @Override public GetKxChangesetResult getKxChangeset(GetKxChangesetRequest request) { request = beforeClientExecution(request); return executeGetKxChangeset(request); } @SdkInternalApi final GetKxChangesetResult executeGetKxChangeset(GetKxChangesetRequest getKxChangesetRequest) { ExecutionContext executionContext = createExecutionContext(getKxChangesetRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Retrieves information about a kdb cluster. *
* * @param getKxClusterRequest * @return Result of the GetKxCluster operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.GetKxCluster * @see AWS API * Documentation */ @Override public GetKxClusterResult getKxCluster(GetKxClusterRequest request) { request = beforeClientExecution(request); return executeGetKxCluster(request); } @SdkInternalApi final GetKxClusterResult executeGetKxCluster(GetKxClusterRequest getKxClusterRequest) { ExecutionContext executionContext = createExecutionContext(getKxClusterRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Retrieves a connection string for a user to connect to a kdb cluster. You must call this API using the same role * that you have defined while creating a user. *
* * @param getKxConnectionStringRequest * @return Result of the GetKxConnectionString operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.GetKxConnectionString * @see AWS * API Documentation */ @Override public GetKxConnectionStringResult getKxConnectionString(GetKxConnectionStringRequest request) { request = beforeClientExecution(request); return executeGetKxConnectionString(request); } @SdkInternalApi final GetKxConnectionStringResult executeGetKxConnectionString(GetKxConnectionStringRequest getKxConnectionStringRequest) { ExecutionContext executionContext = createExecutionContext(getKxConnectionStringRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Returns database information for the specified environment ID. *
* * @param getKxDatabaseRequest * @return Result of the GetKxDatabase operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.GetKxDatabase * @see AWS API * Documentation */ @Override public GetKxDatabaseResult getKxDatabase(GetKxDatabaseRequest request) { request = beforeClientExecution(request); return executeGetKxDatabase(request); } @SdkInternalApi final GetKxDatabaseResult executeGetKxDatabase(GetKxDatabaseRequest getKxDatabaseRequest) { ExecutionContext executionContext = createExecutionContext(getKxDatabaseRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Retrieves all the information for the specified kdb environment. *
* * @param getKxEnvironmentRequest * @return Result of the GetKxEnvironment operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @sample AWSfinspace.GetKxEnvironment * @see AWS API * Documentation */ @Override public GetKxEnvironmentResult getKxEnvironment(GetKxEnvironmentRequest request) { request = beforeClientExecution(request); return executeGetKxEnvironment(request); } @SdkInternalApi final GetKxEnvironmentResult executeGetKxEnvironment(GetKxEnvironmentRequest getKxEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(getKxEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Retrieves information about the specified kdb user. *
* * @param getKxUserRequest * @return Result of the GetKxUser operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.GetKxUser * @see AWS API * Documentation */ @Override public GetKxUserResult getKxUser(GetKxUserRequest request) { request = beforeClientExecution(request); return executeGetKxUser(request); } @SdkInternalApi final GetKxUserResult executeGetKxUser(GetKxUserRequest getKxUserRequest) { ExecutionContext executionContext = createExecutionContext(getKxUserRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* A list of all of your FinSpace environments. *
* * @param listEnvironmentsRequest * @return Result of the ListEnvironments operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.ListEnvironments * @see AWS API * Documentation */ @Override public ListEnvironmentsResult listEnvironments(ListEnvironmentsRequest request) { request = beforeClientExecution(request); return executeListEnvironments(request); } @SdkInternalApi final ListEnvironmentsResult executeListEnvironments(ListEnvironmentsRequest listEnvironmentsRequest) { ExecutionContext executionContext = createExecutionContext(listEnvironmentsRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Returns a list of all the changesets for a database. *
* * @param listKxChangesetsRequest * @return Result of the ListKxChangesets operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.ListKxChangesets * @see AWS API * Documentation */ @Override public ListKxChangesetsResult listKxChangesets(ListKxChangesetsRequest request) { request = beforeClientExecution(request); return executeListKxChangesets(request); } @SdkInternalApi final ListKxChangesetsResult executeListKxChangesets(ListKxChangesetsRequest listKxChangesetsRequest) { ExecutionContext executionContext = createExecutionContext(listKxChangesetsRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Lists all the nodes in a kdb cluster. *
* * @param listKxClusterNodesRequest * @return Result of the ListKxClusterNodes operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.ListKxClusterNodes * @see AWS * API Documentation */ @Override public ListKxClusterNodesResult listKxClusterNodes(ListKxClusterNodesRequest request) { request = beforeClientExecution(request); return executeListKxClusterNodes(request); } @SdkInternalApi final ListKxClusterNodesResult executeListKxClusterNodes(ListKxClusterNodesRequest listKxClusterNodesRequest) { ExecutionContext executionContext = createExecutionContext(listKxClusterNodesRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Returns a list of clusters. *
* * @param listKxClustersRequest * @return Result of the ListKxClusters operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.ListKxClusters * @see AWS API * Documentation */ @Override public ListKxClustersResult listKxClusters(ListKxClustersRequest request) { request = beforeClientExecution(request); return executeListKxClusters(request); } @SdkInternalApi final ListKxClustersResult executeListKxClusters(ListKxClustersRequest listKxClustersRequest) { ExecutionContext executionContext = createExecutionContext(listKxClustersRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Returns a list of all the databases in the kdb environment. *
* * @param listKxDatabasesRequest * @return Result of the ListKxDatabases operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.ListKxDatabases * @see AWS API * Documentation */ @Override public ListKxDatabasesResult listKxDatabases(ListKxDatabasesRequest request) { request = beforeClientExecution(request); return executeListKxDatabases(request); } @SdkInternalApi final ListKxDatabasesResult executeListKxDatabases(ListKxDatabasesRequest listKxDatabasesRequest) { ExecutionContext executionContext = createExecutionContext(listKxDatabasesRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Returns a list of kdb environments created in an account. *
* * @param listKxEnvironmentsRequest * @return Result of the ListKxEnvironments operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.ListKxEnvironments * @see AWS * API Documentation */ @Override public ListKxEnvironmentsResult listKxEnvironments(ListKxEnvironmentsRequest request) { request = beforeClientExecution(request); return executeListKxEnvironments(request); } @SdkInternalApi final ListKxEnvironmentsResult executeListKxEnvironments(ListKxEnvironmentsRequest listKxEnvironmentsRequest) { ExecutionContext executionContext = createExecutionContext(listKxEnvironmentsRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Lists all the users in a kdb environment. *
* * @param listKxUsersRequest * @return Result of the ListKxUsers operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.ListKxUsers * @see AWS API * Documentation */ @Override public ListKxUsersResult listKxUsers(ListKxUsersRequest request) { request = beforeClientExecution(request); return executeListKxUsers(request); } @SdkInternalApi final ListKxUsersResult executeListKxUsers(ListKxUsersRequest listKxUsersRequest) { ExecutionContext executionContext = createExecutionContext(listKxUsersRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* A list of all tags for a resource. *
* * @param listTagsForResourceRequest * @return Result of the ListTagsForResource operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws InvalidRequestException * The request is invalid. Something is wrong with the input to the request. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.ListTagsForResource * @see AWS * API Documentation */ @Override public ListTagsForResourceResult listTagsForResource(ListTagsForResourceRequest request) { request = beforeClientExecution(request); return executeListTagsForResource(request); } @SdkInternalApi final ListTagsForResourceResult executeListTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest) { ExecutionContext executionContext = createExecutionContext(listTagsForResourceRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Adds metadata tags to a FinSpace resource. *
* * @param tagResourceRequest * @return Result of the TagResource operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws InvalidRequestException * The request is invalid. Something is wrong with the input to the request. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.TagResource * @see AWS API * Documentation */ @Override public TagResourceResult tagResource(TagResourceRequest request) { request = beforeClientExecution(request); return executeTagResource(request); } @SdkInternalApi final TagResourceResult executeTagResource(TagResourceRequest tagResourceRequest) { ExecutionContext executionContext = createExecutionContext(tagResourceRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Removes metadata tags from a FinSpace resource. *
* * @param untagResourceRequest * @return Result of the UntagResource operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws InvalidRequestException * The request is invalid. Something is wrong with the input to the request. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.UntagResource * @see AWS API * Documentation */ @Override public UntagResourceResult untagResource(UntagResourceRequest request) { request = beforeClientExecution(request); return executeUntagResource(request); } @SdkInternalApi final UntagResourceResult executeUntagResource(UntagResourceRequest untagResourceRequest) { ExecutionContext executionContext = createExecutionContext(untagResourceRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Update your FinSpace environment. *
* * @param updateEnvironmentRequest * @return Result of the UpdateEnvironment operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ThrottlingException * The request was denied due to request throttling. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @sample AWSfinspace.UpdateEnvironment * @see AWS API * Documentation */ @Override public UpdateEnvironmentResult updateEnvironment(UpdateEnvironmentRequest request) { request = beforeClientExecution(request); return executeUpdateEnvironment(request); } @SdkInternalApi final UpdateEnvironmentResult executeUpdateEnvironment(UpdateEnvironmentRequest updateEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(updateEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request
* Updates the databases mounted on a kdb cluster, which includes the changesetId
and all the dbPaths
* to be cached. This API does not allow you to change a database name or add a database if you created a cluster
* without one.
*
* Using this API you can point a cluster to a different changeset and modify a list of partitions being cached. *
* * @param updateKxClusterDatabasesRequest * @return Result of the UpdateKxClusterDatabases operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ResourceNotFoundException * One or more resources can't be found. * @sample AWSfinspace.UpdateKxClusterDatabases * @see AWS API Documentation */ @Override public UpdateKxClusterDatabasesResult updateKxClusterDatabases(UpdateKxClusterDatabasesRequest request) { request = beforeClientExecution(request); return executeUpdateKxClusterDatabases(request); } @SdkInternalApi final UpdateKxClusterDatabasesResult executeUpdateKxClusterDatabases(UpdateKxClusterDatabasesRequest updateKxClusterDatabasesRequest) { ExecutionContext executionContext = createExecutionContext(updateKxClusterDatabasesRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Updates information for the given kdb database. *
* * @param updateKxDatabaseRequest * @return Result of the UpdateKxDatabase operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @sample AWSfinspace.UpdateKxDatabase * @see AWS API * Documentation */ @Override public UpdateKxDatabaseResult updateKxDatabase(UpdateKxDatabaseRequest request) { request = beforeClientExecution(request); return executeUpdateKxDatabase(request); } @SdkInternalApi final UpdateKxDatabaseResult executeUpdateKxDatabase(UpdateKxDatabaseRequest updateKxDatabaseRequest) { ExecutionContext executionContext = createExecutionContext(updateKxDatabaseRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Updates information for the given kdb environment. *
* * @param updateKxEnvironmentRequest * @return Result of the UpdateKxEnvironment operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ThrottlingException * The request was denied due to request throttling. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @sample AWSfinspace.UpdateKxEnvironment * @see AWS * API Documentation */ @Override public UpdateKxEnvironmentResult updateKxEnvironment(UpdateKxEnvironmentRequest request) { request = beforeClientExecution(request); return executeUpdateKxEnvironment(request); } @SdkInternalApi final UpdateKxEnvironmentResult executeUpdateKxEnvironment(UpdateKxEnvironmentRequest updateKxEnvironmentRequest) { ExecutionContext executionContext = createExecutionContext(updateKxEnvironmentRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Updates environment network to connect to your internal network by using a transit gateway. This API supports * request to create a transit gateway attachment from FinSpace VPC to your transit gateway ID and create a custom * Route-53 outbound resolvers. *
** Once you send a request to update a network, you cannot change it again. Network update might require termination * of any clusters that are running in the existing network. *
* * @param updateKxEnvironmentNetworkRequest * @return Result of the UpdateKxEnvironmentNetwork operation returned by the service. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ThrottlingException * The request was denied due to request throttling. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @sample AWSfinspace.UpdateKxEnvironmentNetwork * @see AWS API Documentation */ @Override public UpdateKxEnvironmentNetworkResult updateKxEnvironmentNetwork(UpdateKxEnvironmentNetworkRequest request) { request = beforeClientExecution(request); return executeUpdateKxEnvironmentNetwork(request); } @SdkInternalApi final UpdateKxEnvironmentNetworkResult executeUpdateKxEnvironmentNetwork(UpdateKxEnvironmentNetworkRequest updateKxEnvironmentNetworkRequest) { ExecutionContext executionContext = createExecutionContext(updateKxEnvironmentNetworkRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request* Updates the user details. You can only update the IAM role associated with a user. *
* * @param updateKxUserRequest * @return Result of the UpdateKxUser operation returned by the service. * @throws InternalServerException * The request processing has failed because of an unknown error, exception or failure. * @throws ThrottlingException * The request was denied due to request throttling. * @throws AccessDeniedException * You do not have sufficient access to perform this action. * @throws ResourceNotFoundException * One or more resources can't be found. * @throws ValidationException * The input fails to satisfy the constraints specified by an AWS service. * @throws LimitExceededException * A service limit or quota is exceeded. * @throws ConflictException * There was a conflict with this action, and it could not be completed. * @sample AWSfinspace.UpdateKxUser * @see AWS API * Documentation */ @Override public UpdateKxUserResult updateKxUser(UpdateKxUserRequest request) { request = beforeClientExecution(request); return executeUpdateKxUser(request); } @SdkInternalApi final UpdateKxUserResult executeUpdateKxUser(UpdateKxUserRequest updateKxUserRequest) { ExecutionContext executionContext = createExecutionContext(updateKxUserRequest); AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics(); awsRequestMetrics.startEvent(Field.ClientExecuteTime); Request
* Response metadata is only cached for a limited period of time, so if you need to access this extra diagnostic
* information for an executed request, you should use this method to retrieve it as soon as possible after
* executing the request.
*
* @param request
* The originally executed request
*
* @return The response metadata for the specified request, or null if none is available.
*/
public ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest request) {
return client.getResponseMetadataForRequest(request);
}
/**
* Normal invoke with authentication. Credentials are required and may be overriden at the request level.
**/
private