/*
* 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.sagemaker;
import javax.annotation.Generated;
import com.amazonaws.services.sagemaker.model.*;
import com.amazonaws.client.AwsAsyncClientParams;
import com.amazonaws.annotation.ThreadSafe;
import java.util.concurrent.ExecutorService;
/**
* Client for accessing SageMaker asynchronously. Each asynchronous method will return a Java Future object representing
* the asynchronous operation; overloads which accept an {@code AsyncHandler} can be used to receive notification when
* an asynchronous operation completes.
*
*
* Provides APIs for creating and managing SageMaker resources.
*
*
* Other Resources:
*
*
*/
@ThreadSafe
@Generated("com.amazonaws:aws-java-sdk-code-generator")
public class AmazonSageMakerAsyncClient extends AmazonSageMakerClient implements AmazonSageMakerAsync {
private static final int DEFAULT_THREAD_POOL_SIZE = 50;
private final java.util.concurrent.ExecutorService executorService;
public static AmazonSageMakerAsyncClientBuilder asyncBuilder() {
return AmazonSageMakerAsyncClientBuilder.standard();
}
/**
* Constructs a new asynchronous client to invoke service methods on SageMaker using the specified parameters.
*
* @param asyncClientParams
* Object providing client parameters.
*/
AmazonSageMakerAsyncClient(AwsAsyncClientParams asyncClientParams) {
this(asyncClientParams, false);
}
/**
* Constructs a new asynchronous client to invoke service methods on SageMaker using the specified parameters.
*
* @param asyncClientParams
* Object providing client parameters.
* @param endpointDiscoveryEnabled
* true will enable endpoint discovery if the service supports it.
*/
AmazonSageMakerAsyncClient(AwsAsyncClientParams asyncClientParams, boolean endpointDiscoveryEnabled) {
super(asyncClientParams, endpointDiscoveryEnabled);
this.executorService = asyncClientParams.getExecutor();
}
/**
* Returns the executor service used by this client to execute async requests.
*
* @return The executor service used by this client to execute async requests.
*/
public ExecutorService getExecutorService() {
return executorService;
}
@Override
public java.util.concurrent.Future addAssociationAsync(AddAssociationRequest request) {
return addAssociationAsync(request, null);
}
@Override
public java.util.concurrent.Future addAssociationAsync(final AddAssociationRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final AddAssociationRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public AddAssociationResult call() throws Exception {
AddAssociationResult result = null;
try {
result = executeAddAssociation(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future addTagsAsync(AddTagsRequest request) {
return addTagsAsync(request, null);
}
@Override
public java.util.concurrent.Future addTagsAsync(final AddTagsRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final AddTagsRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public AddTagsResult call() throws Exception {
AddTagsResult result = null;
try {
result = executeAddTags(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future associateTrialComponentAsync(AssociateTrialComponentRequest request) {
return associateTrialComponentAsync(request, null);
}
@Override
public java.util.concurrent.Future associateTrialComponentAsync(final AssociateTrialComponentRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final AssociateTrialComponentRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public AssociateTrialComponentResult call() throws Exception {
AssociateTrialComponentResult result = null;
try {
result = executeAssociateTrialComponent(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future batchDescribeModelPackageAsync(BatchDescribeModelPackageRequest request) {
return batchDescribeModelPackageAsync(request, null);
}
@Override
public java.util.concurrent.Future batchDescribeModelPackageAsync(final BatchDescribeModelPackageRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final BatchDescribeModelPackageRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public BatchDescribeModelPackageResult call() throws Exception {
BatchDescribeModelPackageResult result = null;
try {
result = executeBatchDescribeModelPackage(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createActionAsync(CreateActionRequest request) {
return createActionAsync(request, null);
}
@Override
public java.util.concurrent.Future createActionAsync(final CreateActionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateActionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateActionResult call() throws Exception {
CreateActionResult result = null;
try {
result = executeCreateAction(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createAlgorithmAsync(CreateAlgorithmRequest request) {
return createAlgorithmAsync(request, null);
}
@Override
public java.util.concurrent.Future createAlgorithmAsync(final CreateAlgorithmRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateAlgorithmRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateAlgorithmResult call() throws Exception {
CreateAlgorithmResult result = null;
try {
result = executeCreateAlgorithm(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createAppAsync(CreateAppRequest request) {
return createAppAsync(request, null);
}
@Override
public java.util.concurrent.Future createAppAsync(final CreateAppRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateAppRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateAppResult call() throws Exception {
CreateAppResult result = null;
try {
result = executeCreateApp(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createAppImageConfigAsync(CreateAppImageConfigRequest request) {
return createAppImageConfigAsync(request, null);
}
@Override
public java.util.concurrent.Future createAppImageConfigAsync(final CreateAppImageConfigRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateAppImageConfigRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateAppImageConfigResult call() throws Exception {
CreateAppImageConfigResult result = null;
try {
result = executeCreateAppImageConfig(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createArtifactAsync(CreateArtifactRequest request) {
return createArtifactAsync(request, null);
}
@Override
public java.util.concurrent.Future createArtifactAsync(final CreateArtifactRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateArtifactRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateArtifactResult call() throws Exception {
CreateArtifactResult result = null;
try {
result = executeCreateArtifact(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createAutoMLJobAsync(CreateAutoMLJobRequest request) {
return createAutoMLJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createAutoMLJobAsync(final CreateAutoMLJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateAutoMLJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateAutoMLJobResult call() throws Exception {
CreateAutoMLJobResult result = null;
try {
result = executeCreateAutoMLJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createAutoMLJobV2Async(CreateAutoMLJobV2Request request) {
return createAutoMLJobV2Async(request, null);
}
@Override
public java.util.concurrent.Future createAutoMLJobV2Async(final CreateAutoMLJobV2Request request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateAutoMLJobV2Request finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateAutoMLJobV2Result call() throws Exception {
CreateAutoMLJobV2Result result = null;
try {
result = executeCreateAutoMLJobV2(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createCodeRepositoryAsync(CreateCodeRepositoryRequest request) {
return createCodeRepositoryAsync(request, null);
}
@Override
public java.util.concurrent.Future createCodeRepositoryAsync(final CreateCodeRepositoryRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateCodeRepositoryRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateCodeRepositoryResult call() throws Exception {
CreateCodeRepositoryResult result = null;
try {
result = executeCreateCodeRepository(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createCompilationJobAsync(CreateCompilationJobRequest request) {
return createCompilationJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createCompilationJobAsync(final CreateCompilationJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateCompilationJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateCompilationJobResult call() throws Exception {
CreateCompilationJobResult result = null;
try {
result = executeCreateCompilationJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createContextAsync(CreateContextRequest request) {
return createContextAsync(request, null);
}
@Override
public java.util.concurrent.Future createContextAsync(final CreateContextRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateContextRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateContextResult call() throws Exception {
CreateContextResult result = null;
try {
result = executeCreateContext(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createDataQualityJobDefinitionAsync(CreateDataQualityJobDefinitionRequest request) {
return createDataQualityJobDefinitionAsync(request, null);
}
@Override
public java.util.concurrent.Future createDataQualityJobDefinitionAsync(
final CreateDataQualityJobDefinitionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateDataQualityJobDefinitionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateDataQualityJobDefinitionResult call() throws Exception {
CreateDataQualityJobDefinitionResult result = null;
try {
result = executeCreateDataQualityJobDefinition(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createDeviceFleetAsync(CreateDeviceFleetRequest request) {
return createDeviceFleetAsync(request, null);
}
@Override
public java.util.concurrent.Future createDeviceFleetAsync(final CreateDeviceFleetRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateDeviceFleetRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateDeviceFleetResult call() throws Exception {
CreateDeviceFleetResult result = null;
try {
result = executeCreateDeviceFleet(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createDomainAsync(CreateDomainRequest request) {
return createDomainAsync(request, null);
}
@Override
public java.util.concurrent.Future createDomainAsync(final CreateDomainRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateDomainRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateDomainResult call() throws Exception {
CreateDomainResult result = null;
try {
result = executeCreateDomain(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createEdgeDeploymentPlanAsync(CreateEdgeDeploymentPlanRequest request) {
return createEdgeDeploymentPlanAsync(request, null);
}
@Override
public java.util.concurrent.Future createEdgeDeploymentPlanAsync(final CreateEdgeDeploymentPlanRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateEdgeDeploymentPlanRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateEdgeDeploymentPlanResult call() throws Exception {
CreateEdgeDeploymentPlanResult result = null;
try {
result = executeCreateEdgeDeploymentPlan(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createEdgeDeploymentStageAsync(CreateEdgeDeploymentStageRequest request) {
return createEdgeDeploymentStageAsync(request, null);
}
@Override
public java.util.concurrent.Future createEdgeDeploymentStageAsync(final CreateEdgeDeploymentStageRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateEdgeDeploymentStageRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateEdgeDeploymentStageResult call() throws Exception {
CreateEdgeDeploymentStageResult result = null;
try {
result = executeCreateEdgeDeploymentStage(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createEdgePackagingJobAsync(CreateEdgePackagingJobRequest request) {
return createEdgePackagingJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createEdgePackagingJobAsync(final CreateEdgePackagingJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateEdgePackagingJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateEdgePackagingJobResult call() throws Exception {
CreateEdgePackagingJobResult result = null;
try {
result = executeCreateEdgePackagingJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createEndpointAsync(CreateEndpointRequest request) {
return createEndpointAsync(request, null);
}
@Override
public java.util.concurrent.Future createEndpointAsync(final CreateEndpointRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateEndpointRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateEndpointResult call() throws Exception {
CreateEndpointResult result = null;
try {
result = executeCreateEndpoint(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createEndpointConfigAsync(CreateEndpointConfigRequest request) {
return createEndpointConfigAsync(request, null);
}
@Override
public java.util.concurrent.Future createEndpointConfigAsync(final CreateEndpointConfigRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateEndpointConfigRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateEndpointConfigResult call() throws Exception {
CreateEndpointConfigResult result = null;
try {
result = executeCreateEndpointConfig(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createExperimentAsync(CreateExperimentRequest request) {
return createExperimentAsync(request, null);
}
@Override
public java.util.concurrent.Future createExperimentAsync(final CreateExperimentRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateExperimentRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateExperimentResult call() throws Exception {
CreateExperimentResult result = null;
try {
result = executeCreateExperiment(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createFeatureGroupAsync(CreateFeatureGroupRequest request) {
return createFeatureGroupAsync(request, null);
}
@Override
public java.util.concurrent.Future createFeatureGroupAsync(final CreateFeatureGroupRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateFeatureGroupRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateFeatureGroupResult call() throws Exception {
CreateFeatureGroupResult result = null;
try {
result = executeCreateFeatureGroup(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createFlowDefinitionAsync(CreateFlowDefinitionRequest request) {
return createFlowDefinitionAsync(request, null);
}
@Override
public java.util.concurrent.Future createFlowDefinitionAsync(final CreateFlowDefinitionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateFlowDefinitionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateFlowDefinitionResult call() throws Exception {
CreateFlowDefinitionResult result = null;
try {
result = executeCreateFlowDefinition(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createHubAsync(CreateHubRequest request) {
return createHubAsync(request, null);
}
@Override
public java.util.concurrent.Future createHubAsync(final CreateHubRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateHubRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateHubResult call() throws Exception {
CreateHubResult result = null;
try {
result = executeCreateHub(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createHumanTaskUiAsync(CreateHumanTaskUiRequest request) {
return createHumanTaskUiAsync(request, null);
}
@Override
public java.util.concurrent.Future createHumanTaskUiAsync(final CreateHumanTaskUiRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateHumanTaskUiRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateHumanTaskUiResult call() throws Exception {
CreateHumanTaskUiResult result = null;
try {
result = executeCreateHumanTaskUi(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createHyperParameterTuningJobAsync(CreateHyperParameterTuningJobRequest request) {
return createHyperParameterTuningJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createHyperParameterTuningJobAsync(
final CreateHyperParameterTuningJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateHyperParameterTuningJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateHyperParameterTuningJobResult call() throws Exception {
CreateHyperParameterTuningJobResult result = null;
try {
result = executeCreateHyperParameterTuningJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createImageAsync(CreateImageRequest request) {
return createImageAsync(request, null);
}
@Override
public java.util.concurrent.Future createImageAsync(final CreateImageRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateImageRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateImageResult call() throws Exception {
CreateImageResult result = null;
try {
result = executeCreateImage(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createImageVersionAsync(CreateImageVersionRequest request) {
return createImageVersionAsync(request, null);
}
@Override
public java.util.concurrent.Future createImageVersionAsync(final CreateImageVersionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateImageVersionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateImageVersionResult call() throws Exception {
CreateImageVersionResult result = null;
try {
result = executeCreateImageVersion(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createInferenceExperimentAsync(CreateInferenceExperimentRequest request) {
return createInferenceExperimentAsync(request, null);
}
@Override
public java.util.concurrent.Future createInferenceExperimentAsync(final CreateInferenceExperimentRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateInferenceExperimentRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateInferenceExperimentResult call() throws Exception {
CreateInferenceExperimentResult result = null;
try {
result = executeCreateInferenceExperiment(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createInferenceRecommendationsJobAsync(
CreateInferenceRecommendationsJobRequest request) {
return createInferenceRecommendationsJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createInferenceRecommendationsJobAsync(
final CreateInferenceRecommendationsJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateInferenceRecommendationsJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateInferenceRecommendationsJobResult call() throws Exception {
CreateInferenceRecommendationsJobResult result = null;
try {
result = executeCreateInferenceRecommendationsJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createLabelingJobAsync(CreateLabelingJobRequest request) {
return createLabelingJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createLabelingJobAsync(final CreateLabelingJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateLabelingJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateLabelingJobResult call() throws Exception {
CreateLabelingJobResult result = null;
try {
result = executeCreateLabelingJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelAsync(CreateModelRequest request) {
return createModelAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelAsync(final CreateModelRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelResult call() throws Exception {
CreateModelResult result = null;
try {
result = executeCreateModel(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelBiasJobDefinitionAsync(CreateModelBiasJobDefinitionRequest request) {
return createModelBiasJobDefinitionAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelBiasJobDefinitionAsync(final CreateModelBiasJobDefinitionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelBiasJobDefinitionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelBiasJobDefinitionResult call() throws Exception {
CreateModelBiasJobDefinitionResult result = null;
try {
result = executeCreateModelBiasJobDefinition(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelCardAsync(CreateModelCardRequest request) {
return createModelCardAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelCardAsync(final CreateModelCardRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelCardRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelCardResult call() throws Exception {
CreateModelCardResult result = null;
try {
result = executeCreateModelCard(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelCardExportJobAsync(CreateModelCardExportJobRequest request) {
return createModelCardExportJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelCardExportJobAsync(final CreateModelCardExportJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelCardExportJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelCardExportJobResult call() throws Exception {
CreateModelCardExportJobResult result = null;
try {
result = executeCreateModelCardExportJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelExplainabilityJobDefinitionAsync(
CreateModelExplainabilityJobDefinitionRequest request) {
return createModelExplainabilityJobDefinitionAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelExplainabilityJobDefinitionAsync(
final CreateModelExplainabilityJobDefinitionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelExplainabilityJobDefinitionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelExplainabilityJobDefinitionResult call() throws Exception {
CreateModelExplainabilityJobDefinitionResult result = null;
try {
result = executeCreateModelExplainabilityJobDefinition(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelPackageAsync(CreateModelPackageRequest request) {
return createModelPackageAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelPackageAsync(final CreateModelPackageRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelPackageRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelPackageResult call() throws Exception {
CreateModelPackageResult result = null;
try {
result = executeCreateModelPackage(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelPackageGroupAsync(CreateModelPackageGroupRequest request) {
return createModelPackageGroupAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelPackageGroupAsync(final CreateModelPackageGroupRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelPackageGroupRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelPackageGroupResult call() throws Exception {
CreateModelPackageGroupResult result = null;
try {
result = executeCreateModelPackageGroup(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createModelQualityJobDefinitionAsync(
CreateModelQualityJobDefinitionRequest request) {
return createModelQualityJobDefinitionAsync(request, null);
}
@Override
public java.util.concurrent.Future createModelQualityJobDefinitionAsync(
final CreateModelQualityJobDefinitionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateModelQualityJobDefinitionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateModelQualityJobDefinitionResult call() throws Exception {
CreateModelQualityJobDefinitionResult result = null;
try {
result = executeCreateModelQualityJobDefinition(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createMonitoringScheduleAsync(CreateMonitoringScheduleRequest request) {
return createMonitoringScheduleAsync(request, null);
}
@Override
public java.util.concurrent.Future createMonitoringScheduleAsync(final CreateMonitoringScheduleRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateMonitoringScheduleRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateMonitoringScheduleResult call() throws Exception {
CreateMonitoringScheduleResult result = null;
try {
result = executeCreateMonitoringSchedule(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createNotebookInstanceAsync(CreateNotebookInstanceRequest request) {
return createNotebookInstanceAsync(request, null);
}
@Override
public java.util.concurrent.Future createNotebookInstanceAsync(final CreateNotebookInstanceRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateNotebookInstanceRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateNotebookInstanceResult call() throws Exception {
CreateNotebookInstanceResult result = null;
try {
result = executeCreateNotebookInstance(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createNotebookInstanceLifecycleConfigAsync(
CreateNotebookInstanceLifecycleConfigRequest request) {
return createNotebookInstanceLifecycleConfigAsync(request, null);
}
@Override
public java.util.concurrent.Future createNotebookInstanceLifecycleConfigAsync(
final CreateNotebookInstanceLifecycleConfigRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateNotebookInstanceLifecycleConfigRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateNotebookInstanceLifecycleConfigResult call() throws Exception {
CreateNotebookInstanceLifecycleConfigResult result = null;
try {
result = executeCreateNotebookInstanceLifecycleConfig(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createPipelineAsync(CreatePipelineRequest request) {
return createPipelineAsync(request, null);
}
@Override
public java.util.concurrent.Future createPipelineAsync(final CreatePipelineRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreatePipelineRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreatePipelineResult call() throws Exception {
CreatePipelineResult result = null;
try {
result = executeCreatePipeline(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createPresignedDomainUrlAsync(CreatePresignedDomainUrlRequest request) {
return createPresignedDomainUrlAsync(request, null);
}
@Override
public java.util.concurrent.Future createPresignedDomainUrlAsync(final CreatePresignedDomainUrlRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreatePresignedDomainUrlRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreatePresignedDomainUrlResult call() throws Exception {
CreatePresignedDomainUrlResult result = null;
try {
result = executeCreatePresignedDomainUrl(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createPresignedNotebookInstanceUrlAsync(
CreatePresignedNotebookInstanceUrlRequest request) {
return createPresignedNotebookInstanceUrlAsync(request, null);
}
@Override
public java.util.concurrent.Future createPresignedNotebookInstanceUrlAsync(
final CreatePresignedNotebookInstanceUrlRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreatePresignedNotebookInstanceUrlRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreatePresignedNotebookInstanceUrlResult call() throws Exception {
CreatePresignedNotebookInstanceUrlResult result = null;
try {
result = executeCreatePresignedNotebookInstanceUrl(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createProcessingJobAsync(CreateProcessingJobRequest request) {
return createProcessingJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createProcessingJobAsync(final CreateProcessingJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateProcessingJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateProcessingJobResult call() throws Exception {
CreateProcessingJobResult result = null;
try {
result = executeCreateProcessingJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createProjectAsync(CreateProjectRequest request) {
return createProjectAsync(request, null);
}
@Override
public java.util.concurrent.Future createProjectAsync(final CreateProjectRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateProjectRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateProjectResult call() throws Exception {
CreateProjectResult result = null;
try {
result = executeCreateProject(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createSpaceAsync(CreateSpaceRequest request) {
return createSpaceAsync(request, null);
}
@Override
public java.util.concurrent.Future createSpaceAsync(final CreateSpaceRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateSpaceRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateSpaceResult call() throws Exception {
CreateSpaceResult result = null;
try {
result = executeCreateSpace(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createStudioLifecycleConfigAsync(CreateStudioLifecycleConfigRequest request) {
return createStudioLifecycleConfigAsync(request, null);
}
@Override
public java.util.concurrent.Future createStudioLifecycleConfigAsync(final CreateStudioLifecycleConfigRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateStudioLifecycleConfigRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateStudioLifecycleConfigResult call() throws Exception {
CreateStudioLifecycleConfigResult result = null;
try {
result = executeCreateStudioLifecycleConfig(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createTrainingJobAsync(CreateTrainingJobRequest request) {
return createTrainingJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createTrainingJobAsync(final CreateTrainingJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateTrainingJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateTrainingJobResult call() throws Exception {
CreateTrainingJobResult result = null;
try {
result = executeCreateTrainingJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createTransformJobAsync(CreateTransformJobRequest request) {
return createTransformJobAsync(request, null);
}
@Override
public java.util.concurrent.Future createTransformJobAsync(final CreateTransformJobRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateTransformJobRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateTransformJobResult call() throws Exception {
CreateTransformJobResult result = null;
try {
result = executeCreateTransformJob(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createTrialAsync(CreateTrialRequest request) {
return createTrialAsync(request, null);
}
@Override
public java.util.concurrent.Future createTrialAsync(final CreateTrialRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateTrialRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateTrialResult call() throws Exception {
CreateTrialResult result = null;
try {
result = executeCreateTrial(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createTrialComponentAsync(CreateTrialComponentRequest request) {
return createTrialComponentAsync(request, null);
}
@Override
public java.util.concurrent.Future createTrialComponentAsync(final CreateTrialComponentRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateTrialComponentRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateTrialComponentResult call() throws Exception {
CreateTrialComponentResult result = null;
try {
result = executeCreateTrialComponent(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createUserProfileAsync(CreateUserProfileRequest request) {
return createUserProfileAsync(request, null);
}
@Override
public java.util.concurrent.Future createUserProfileAsync(final CreateUserProfileRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateUserProfileRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateUserProfileResult call() throws Exception {
CreateUserProfileResult result = null;
try {
result = executeCreateUserProfile(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createWorkforceAsync(CreateWorkforceRequest request) {
return createWorkforceAsync(request, null);
}
@Override
public java.util.concurrent.Future createWorkforceAsync(final CreateWorkforceRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateWorkforceRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateWorkforceResult call() throws Exception {
CreateWorkforceResult result = null;
try {
result = executeCreateWorkforce(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future createWorkteamAsync(CreateWorkteamRequest request) {
return createWorkteamAsync(request, null);
}
@Override
public java.util.concurrent.Future createWorkteamAsync(final CreateWorkteamRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final CreateWorkteamRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public CreateWorkteamResult call() throws Exception {
CreateWorkteamResult result = null;
try {
result = executeCreateWorkteam(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteActionAsync(DeleteActionRequest request) {
return deleteActionAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteActionAsync(final DeleteActionRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteActionRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteActionResult call() throws Exception {
DeleteActionResult result = null;
try {
result = executeDeleteAction(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteAlgorithmAsync(DeleteAlgorithmRequest request) {
return deleteAlgorithmAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteAlgorithmAsync(final DeleteAlgorithmRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteAlgorithmRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteAlgorithmResult call() throws Exception {
DeleteAlgorithmResult result = null;
try {
result = executeDeleteAlgorithm(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteAppAsync(DeleteAppRequest request) {
return deleteAppAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteAppAsync(final DeleteAppRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteAppRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteAppResult call() throws Exception {
DeleteAppResult result = null;
try {
result = executeDeleteApp(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteAppImageConfigAsync(DeleteAppImageConfigRequest request) {
return deleteAppImageConfigAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteAppImageConfigAsync(final DeleteAppImageConfigRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteAppImageConfigRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteAppImageConfigResult call() throws Exception {
DeleteAppImageConfigResult result = null;
try {
result = executeDeleteAppImageConfig(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteArtifactAsync(DeleteArtifactRequest request) {
return deleteArtifactAsync(request, null);
}
@Override
public java.util.concurrent.Future deleteArtifactAsync(final DeleteArtifactRequest request,
final com.amazonaws.handlers.AsyncHandler asyncHandler) {
final DeleteArtifactRequest finalRequest = beforeClientExecution(request);
return executorService.submit(new java.util.concurrent.Callable() {
@Override
public DeleteArtifactResult call() throws Exception {
DeleteArtifactResult result = null;
try {
result = executeDeleteArtifact(finalRequest);
} catch (Exception ex) {
if (asyncHandler != null) {
asyncHandler.onError(ex);
}
throw ex;
}
if (asyncHandler != null) {
asyncHandler.onSuccess(finalRequest, result);
}
return result;
}
});
}
@Override
public java.util.concurrent.Future deleteAssociationAsync(DeleteAssociationRequest request) {
return deleteAssociationAsync(request, null);
}
@Override
public java.util.concurrent.Future