1 /**
2 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
3 * SPDX-License-Identifier: Apache-2.0.
4 */
5
6 #include <aws/core/utils/Outcome.h>
7 #include <aws/core/auth/AWSAuthSigner.h>
8 #include <aws/core/client/CoreErrors.h>
9 #include <aws/core/client/RetryStrategy.h>
10 #include <aws/core/http/HttpClient.h>
11 #include <aws/core/http/HttpResponse.h>
12 #include <aws/core/http/HttpClientFactory.h>
13 #include <aws/core/auth/AWSCredentialsProviderChain.h>
14 #include <aws/core/utils/json/JsonSerializer.h>
15 #include <aws/core/utils/memory/stl/AWSStringStream.h>
16 #include <aws/core/utils/threading/Executor.h>
17 #include <aws/core/utils/DNS.h>
18 #include <aws/core/utils/logging/LogMacros.h>
19
20 #include <aws/elasticmapreduce/EMRClient.h>
21 #include <aws/elasticmapreduce/EMREndpoint.h>
22 #include <aws/elasticmapreduce/EMRErrorMarshaller.h>
23 #include <aws/elasticmapreduce/model/AddInstanceFleetRequest.h>
24 #include <aws/elasticmapreduce/model/AddInstanceGroupsRequest.h>
25 #include <aws/elasticmapreduce/model/AddJobFlowStepsRequest.h>
26 #include <aws/elasticmapreduce/model/AddTagsRequest.h>
27 #include <aws/elasticmapreduce/model/CancelStepsRequest.h>
28 #include <aws/elasticmapreduce/model/CreateSecurityConfigurationRequest.h>
29 #include <aws/elasticmapreduce/model/CreateStudioRequest.h>
30 #include <aws/elasticmapreduce/model/CreateStudioSessionMappingRequest.h>
31 #include <aws/elasticmapreduce/model/DeleteSecurityConfigurationRequest.h>
32 #include <aws/elasticmapreduce/model/DeleteStudioRequest.h>
33 #include <aws/elasticmapreduce/model/DeleteStudioSessionMappingRequest.h>
34 #include <aws/elasticmapreduce/model/DescribeClusterRequest.h>
35 #include <aws/elasticmapreduce/model/DescribeNotebookExecutionRequest.h>
36 #include <aws/elasticmapreduce/model/DescribeReleaseLabelRequest.h>
37 #include <aws/elasticmapreduce/model/DescribeSecurityConfigurationRequest.h>
38 #include <aws/elasticmapreduce/model/DescribeStepRequest.h>
39 #include <aws/elasticmapreduce/model/DescribeStudioRequest.h>
40 #include <aws/elasticmapreduce/model/GetAutoTerminationPolicyRequest.h>
41 #include <aws/elasticmapreduce/model/GetBlockPublicAccessConfigurationRequest.h>
42 #include <aws/elasticmapreduce/model/GetManagedScalingPolicyRequest.h>
43 #include <aws/elasticmapreduce/model/GetStudioSessionMappingRequest.h>
44 #include <aws/elasticmapreduce/model/ListBootstrapActionsRequest.h>
45 #include <aws/elasticmapreduce/model/ListClustersRequest.h>
46 #include <aws/elasticmapreduce/model/ListInstanceFleetsRequest.h>
47 #include <aws/elasticmapreduce/model/ListInstanceGroupsRequest.h>
48 #include <aws/elasticmapreduce/model/ListInstancesRequest.h>
49 #include <aws/elasticmapreduce/model/ListNotebookExecutionsRequest.h>
50 #include <aws/elasticmapreduce/model/ListReleaseLabelsRequest.h>
51 #include <aws/elasticmapreduce/model/ListSecurityConfigurationsRequest.h>
52 #include <aws/elasticmapreduce/model/ListStepsRequest.h>
53 #include <aws/elasticmapreduce/model/ListStudioSessionMappingsRequest.h>
54 #include <aws/elasticmapreduce/model/ListStudiosRequest.h>
55 #include <aws/elasticmapreduce/model/ModifyClusterRequest.h>
56 #include <aws/elasticmapreduce/model/ModifyInstanceFleetRequest.h>
57 #include <aws/elasticmapreduce/model/ModifyInstanceGroupsRequest.h>
58 #include <aws/elasticmapreduce/model/PutAutoScalingPolicyRequest.h>
59 #include <aws/elasticmapreduce/model/PutAutoTerminationPolicyRequest.h>
60 #include <aws/elasticmapreduce/model/PutBlockPublicAccessConfigurationRequest.h>
61 #include <aws/elasticmapreduce/model/PutManagedScalingPolicyRequest.h>
62 #include <aws/elasticmapreduce/model/RemoveAutoScalingPolicyRequest.h>
63 #include <aws/elasticmapreduce/model/RemoveAutoTerminationPolicyRequest.h>
64 #include <aws/elasticmapreduce/model/RemoveManagedScalingPolicyRequest.h>
65 #include <aws/elasticmapreduce/model/RemoveTagsRequest.h>
66 #include <aws/elasticmapreduce/model/RunJobFlowRequest.h>
67 #include <aws/elasticmapreduce/model/SetTerminationProtectionRequest.h>
68 #include <aws/elasticmapreduce/model/SetVisibleToAllUsersRequest.h>
69 #include <aws/elasticmapreduce/model/StartNotebookExecutionRequest.h>
70 #include <aws/elasticmapreduce/model/StopNotebookExecutionRequest.h>
71 #include <aws/elasticmapreduce/model/TerminateJobFlowsRequest.h>
72 #include <aws/elasticmapreduce/model/UpdateStudioRequest.h>
73 #include <aws/elasticmapreduce/model/UpdateStudioSessionMappingRequest.h>
74
75 using namespace Aws;
76 using namespace Aws::Auth;
77 using namespace Aws::Client;
78 using namespace Aws::EMR;
79 using namespace Aws::EMR::Model;
80 using namespace Aws::Http;
81 using namespace Aws::Utils::Json;
82
83 static const char* SERVICE_NAME = "elasticmapreduce";
84 static const char* ALLOCATION_TAG = "EMRClient";
85
86
EMRClient(const Client::ClientConfiguration & clientConfiguration)87 EMRClient::EMRClient(const Client::ClientConfiguration& clientConfiguration) :
88 BASECLASS(clientConfiguration,
89 Aws::MakeShared<AWSAuthV4Signer>(ALLOCATION_TAG, Aws::MakeShared<DefaultAWSCredentialsProviderChain>(ALLOCATION_TAG),
90 SERVICE_NAME, Aws::Region::ComputeSignerRegion(clientConfiguration.region)),
91 Aws::MakeShared<EMRErrorMarshaller>(ALLOCATION_TAG)),
92 m_executor(clientConfiguration.executor)
93 {
94 init(clientConfiguration);
95 }
96
EMRClient(const AWSCredentials & credentials,const Client::ClientConfiguration & clientConfiguration)97 EMRClient::EMRClient(const AWSCredentials& credentials, const Client::ClientConfiguration& clientConfiguration) :
98 BASECLASS(clientConfiguration,
99 Aws::MakeShared<AWSAuthV4Signer>(ALLOCATION_TAG, Aws::MakeShared<SimpleAWSCredentialsProvider>(ALLOCATION_TAG, credentials),
100 SERVICE_NAME, Aws::Region::ComputeSignerRegion(clientConfiguration.region)),
101 Aws::MakeShared<EMRErrorMarshaller>(ALLOCATION_TAG)),
102 m_executor(clientConfiguration.executor)
103 {
104 init(clientConfiguration);
105 }
106
EMRClient(const std::shared_ptr<AWSCredentialsProvider> & credentialsProvider,const Client::ClientConfiguration & clientConfiguration)107 EMRClient::EMRClient(const std::shared_ptr<AWSCredentialsProvider>& credentialsProvider,
108 const Client::ClientConfiguration& clientConfiguration) :
109 BASECLASS(clientConfiguration,
110 Aws::MakeShared<AWSAuthV4Signer>(ALLOCATION_TAG, credentialsProvider,
111 SERVICE_NAME, Aws::Region::ComputeSignerRegion(clientConfiguration.region)),
112 Aws::MakeShared<EMRErrorMarshaller>(ALLOCATION_TAG)),
113 m_executor(clientConfiguration.executor)
114 {
115 init(clientConfiguration);
116 }
117
~EMRClient()118 EMRClient::~EMRClient()
119 {
120 }
121
init(const Client::ClientConfiguration & config)122 void EMRClient::init(const Client::ClientConfiguration& config)
123 {
124 SetServiceClientName("EMR");
125 m_configScheme = SchemeMapper::ToString(config.scheme);
126 if (config.endpointOverride.empty())
127 {
128 m_uri = m_configScheme + "://" + EMREndpoint::ForRegion(config.region, config.useDualStack);
129 }
130 else
131 {
132 OverrideEndpoint(config.endpointOverride);
133 }
134 }
135
OverrideEndpoint(const Aws::String & endpoint)136 void EMRClient::OverrideEndpoint(const Aws::String& endpoint)
137 {
138 if (endpoint.compare(0, 7, "http://") == 0 || endpoint.compare(0, 8, "https://") == 0)
139 {
140 m_uri = endpoint;
141 }
142 else
143 {
144 m_uri = m_configScheme + "://" + endpoint;
145 }
146 }
147
AddInstanceFleet(const AddInstanceFleetRequest & request) const148 AddInstanceFleetOutcome EMRClient::AddInstanceFleet(const AddInstanceFleetRequest& request) const
149 {
150 Aws::Http::URI uri = m_uri;
151 return AddInstanceFleetOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
152 }
153
AddInstanceFleetCallable(const AddInstanceFleetRequest & request) const154 AddInstanceFleetOutcomeCallable EMRClient::AddInstanceFleetCallable(const AddInstanceFleetRequest& request) const
155 {
156 auto task = Aws::MakeShared< std::packaged_task< AddInstanceFleetOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->AddInstanceFleet(request); } );
157 auto packagedFunction = [task]() { (*task)(); };
158 m_executor->Submit(packagedFunction);
159 return task->get_future();
160 }
161
AddInstanceFleetAsync(const AddInstanceFleetRequest & request,const AddInstanceFleetResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const162 void EMRClient::AddInstanceFleetAsync(const AddInstanceFleetRequest& request, const AddInstanceFleetResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
163 {
164 m_executor->Submit( [this, request, handler, context](){ this->AddInstanceFleetAsyncHelper( request, handler, context ); } );
165 }
166
AddInstanceFleetAsyncHelper(const AddInstanceFleetRequest & request,const AddInstanceFleetResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const167 void EMRClient::AddInstanceFleetAsyncHelper(const AddInstanceFleetRequest& request, const AddInstanceFleetResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
168 {
169 handler(this, request, AddInstanceFleet(request), context);
170 }
171
AddInstanceGroups(const AddInstanceGroupsRequest & request) const172 AddInstanceGroupsOutcome EMRClient::AddInstanceGroups(const AddInstanceGroupsRequest& request) const
173 {
174 Aws::Http::URI uri = m_uri;
175 return AddInstanceGroupsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
176 }
177
AddInstanceGroupsCallable(const AddInstanceGroupsRequest & request) const178 AddInstanceGroupsOutcomeCallable EMRClient::AddInstanceGroupsCallable(const AddInstanceGroupsRequest& request) const
179 {
180 auto task = Aws::MakeShared< std::packaged_task< AddInstanceGroupsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->AddInstanceGroups(request); } );
181 auto packagedFunction = [task]() { (*task)(); };
182 m_executor->Submit(packagedFunction);
183 return task->get_future();
184 }
185
AddInstanceGroupsAsync(const AddInstanceGroupsRequest & request,const AddInstanceGroupsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const186 void EMRClient::AddInstanceGroupsAsync(const AddInstanceGroupsRequest& request, const AddInstanceGroupsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
187 {
188 m_executor->Submit( [this, request, handler, context](){ this->AddInstanceGroupsAsyncHelper( request, handler, context ); } );
189 }
190
AddInstanceGroupsAsyncHelper(const AddInstanceGroupsRequest & request,const AddInstanceGroupsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const191 void EMRClient::AddInstanceGroupsAsyncHelper(const AddInstanceGroupsRequest& request, const AddInstanceGroupsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
192 {
193 handler(this, request, AddInstanceGroups(request), context);
194 }
195
AddJobFlowSteps(const AddJobFlowStepsRequest & request) const196 AddJobFlowStepsOutcome EMRClient::AddJobFlowSteps(const AddJobFlowStepsRequest& request) const
197 {
198 Aws::Http::URI uri = m_uri;
199 return AddJobFlowStepsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
200 }
201
AddJobFlowStepsCallable(const AddJobFlowStepsRequest & request) const202 AddJobFlowStepsOutcomeCallable EMRClient::AddJobFlowStepsCallable(const AddJobFlowStepsRequest& request) const
203 {
204 auto task = Aws::MakeShared< std::packaged_task< AddJobFlowStepsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->AddJobFlowSteps(request); } );
205 auto packagedFunction = [task]() { (*task)(); };
206 m_executor->Submit(packagedFunction);
207 return task->get_future();
208 }
209
AddJobFlowStepsAsync(const AddJobFlowStepsRequest & request,const AddJobFlowStepsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const210 void EMRClient::AddJobFlowStepsAsync(const AddJobFlowStepsRequest& request, const AddJobFlowStepsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
211 {
212 m_executor->Submit( [this, request, handler, context](){ this->AddJobFlowStepsAsyncHelper( request, handler, context ); } );
213 }
214
AddJobFlowStepsAsyncHelper(const AddJobFlowStepsRequest & request,const AddJobFlowStepsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const215 void EMRClient::AddJobFlowStepsAsyncHelper(const AddJobFlowStepsRequest& request, const AddJobFlowStepsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
216 {
217 handler(this, request, AddJobFlowSteps(request), context);
218 }
219
AddTags(const AddTagsRequest & request) const220 AddTagsOutcome EMRClient::AddTags(const AddTagsRequest& request) const
221 {
222 Aws::Http::URI uri = m_uri;
223 return AddTagsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
224 }
225
AddTagsCallable(const AddTagsRequest & request) const226 AddTagsOutcomeCallable EMRClient::AddTagsCallable(const AddTagsRequest& request) const
227 {
228 auto task = Aws::MakeShared< std::packaged_task< AddTagsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->AddTags(request); } );
229 auto packagedFunction = [task]() { (*task)(); };
230 m_executor->Submit(packagedFunction);
231 return task->get_future();
232 }
233
AddTagsAsync(const AddTagsRequest & request,const AddTagsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const234 void EMRClient::AddTagsAsync(const AddTagsRequest& request, const AddTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
235 {
236 m_executor->Submit( [this, request, handler, context](){ this->AddTagsAsyncHelper( request, handler, context ); } );
237 }
238
AddTagsAsyncHelper(const AddTagsRequest & request,const AddTagsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const239 void EMRClient::AddTagsAsyncHelper(const AddTagsRequest& request, const AddTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
240 {
241 handler(this, request, AddTags(request), context);
242 }
243
CancelSteps(const CancelStepsRequest & request) const244 CancelStepsOutcome EMRClient::CancelSteps(const CancelStepsRequest& request) const
245 {
246 Aws::Http::URI uri = m_uri;
247 return CancelStepsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
248 }
249
CancelStepsCallable(const CancelStepsRequest & request) const250 CancelStepsOutcomeCallable EMRClient::CancelStepsCallable(const CancelStepsRequest& request) const
251 {
252 auto task = Aws::MakeShared< std::packaged_task< CancelStepsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->CancelSteps(request); } );
253 auto packagedFunction = [task]() { (*task)(); };
254 m_executor->Submit(packagedFunction);
255 return task->get_future();
256 }
257
CancelStepsAsync(const CancelStepsRequest & request,const CancelStepsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const258 void EMRClient::CancelStepsAsync(const CancelStepsRequest& request, const CancelStepsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
259 {
260 m_executor->Submit( [this, request, handler, context](){ this->CancelStepsAsyncHelper( request, handler, context ); } );
261 }
262
CancelStepsAsyncHelper(const CancelStepsRequest & request,const CancelStepsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const263 void EMRClient::CancelStepsAsyncHelper(const CancelStepsRequest& request, const CancelStepsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
264 {
265 handler(this, request, CancelSteps(request), context);
266 }
267
CreateSecurityConfiguration(const CreateSecurityConfigurationRequest & request) const268 CreateSecurityConfigurationOutcome EMRClient::CreateSecurityConfiguration(const CreateSecurityConfigurationRequest& request) const
269 {
270 Aws::Http::URI uri = m_uri;
271 return CreateSecurityConfigurationOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
272 }
273
CreateSecurityConfigurationCallable(const CreateSecurityConfigurationRequest & request) const274 CreateSecurityConfigurationOutcomeCallable EMRClient::CreateSecurityConfigurationCallable(const CreateSecurityConfigurationRequest& request) const
275 {
276 auto task = Aws::MakeShared< std::packaged_task< CreateSecurityConfigurationOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->CreateSecurityConfiguration(request); } );
277 auto packagedFunction = [task]() { (*task)(); };
278 m_executor->Submit(packagedFunction);
279 return task->get_future();
280 }
281
CreateSecurityConfigurationAsync(const CreateSecurityConfigurationRequest & request,const CreateSecurityConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const282 void EMRClient::CreateSecurityConfigurationAsync(const CreateSecurityConfigurationRequest& request, const CreateSecurityConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
283 {
284 m_executor->Submit( [this, request, handler, context](){ this->CreateSecurityConfigurationAsyncHelper( request, handler, context ); } );
285 }
286
CreateSecurityConfigurationAsyncHelper(const CreateSecurityConfigurationRequest & request,const CreateSecurityConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const287 void EMRClient::CreateSecurityConfigurationAsyncHelper(const CreateSecurityConfigurationRequest& request, const CreateSecurityConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
288 {
289 handler(this, request, CreateSecurityConfiguration(request), context);
290 }
291
CreateStudio(const CreateStudioRequest & request) const292 CreateStudioOutcome EMRClient::CreateStudio(const CreateStudioRequest& request) const
293 {
294 Aws::Http::URI uri = m_uri;
295 return CreateStudioOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
296 }
297
CreateStudioCallable(const CreateStudioRequest & request) const298 CreateStudioOutcomeCallable EMRClient::CreateStudioCallable(const CreateStudioRequest& request) const
299 {
300 auto task = Aws::MakeShared< std::packaged_task< CreateStudioOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->CreateStudio(request); } );
301 auto packagedFunction = [task]() { (*task)(); };
302 m_executor->Submit(packagedFunction);
303 return task->get_future();
304 }
305
CreateStudioAsync(const CreateStudioRequest & request,const CreateStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const306 void EMRClient::CreateStudioAsync(const CreateStudioRequest& request, const CreateStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
307 {
308 m_executor->Submit( [this, request, handler, context](){ this->CreateStudioAsyncHelper( request, handler, context ); } );
309 }
310
CreateStudioAsyncHelper(const CreateStudioRequest & request,const CreateStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const311 void EMRClient::CreateStudioAsyncHelper(const CreateStudioRequest& request, const CreateStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
312 {
313 handler(this, request, CreateStudio(request), context);
314 }
315
CreateStudioSessionMapping(const CreateStudioSessionMappingRequest & request) const316 CreateStudioSessionMappingOutcome EMRClient::CreateStudioSessionMapping(const CreateStudioSessionMappingRequest& request) const
317 {
318 Aws::Http::URI uri = m_uri;
319 return CreateStudioSessionMappingOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
320 }
321
CreateStudioSessionMappingCallable(const CreateStudioSessionMappingRequest & request) const322 CreateStudioSessionMappingOutcomeCallable EMRClient::CreateStudioSessionMappingCallable(const CreateStudioSessionMappingRequest& request) const
323 {
324 auto task = Aws::MakeShared< std::packaged_task< CreateStudioSessionMappingOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->CreateStudioSessionMapping(request); } );
325 auto packagedFunction = [task]() { (*task)(); };
326 m_executor->Submit(packagedFunction);
327 return task->get_future();
328 }
329
CreateStudioSessionMappingAsync(const CreateStudioSessionMappingRequest & request,const CreateStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const330 void EMRClient::CreateStudioSessionMappingAsync(const CreateStudioSessionMappingRequest& request, const CreateStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
331 {
332 m_executor->Submit( [this, request, handler, context](){ this->CreateStudioSessionMappingAsyncHelper( request, handler, context ); } );
333 }
334
CreateStudioSessionMappingAsyncHelper(const CreateStudioSessionMappingRequest & request,const CreateStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const335 void EMRClient::CreateStudioSessionMappingAsyncHelper(const CreateStudioSessionMappingRequest& request, const CreateStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
336 {
337 handler(this, request, CreateStudioSessionMapping(request), context);
338 }
339
DeleteSecurityConfiguration(const DeleteSecurityConfigurationRequest & request) const340 DeleteSecurityConfigurationOutcome EMRClient::DeleteSecurityConfiguration(const DeleteSecurityConfigurationRequest& request) const
341 {
342 Aws::Http::URI uri = m_uri;
343 return DeleteSecurityConfigurationOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
344 }
345
DeleteSecurityConfigurationCallable(const DeleteSecurityConfigurationRequest & request) const346 DeleteSecurityConfigurationOutcomeCallable EMRClient::DeleteSecurityConfigurationCallable(const DeleteSecurityConfigurationRequest& request) const
347 {
348 auto task = Aws::MakeShared< std::packaged_task< DeleteSecurityConfigurationOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DeleteSecurityConfiguration(request); } );
349 auto packagedFunction = [task]() { (*task)(); };
350 m_executor->Submit(packagedFunction);
351 return task->get_future();
352 }
353
DeleteSecurityConfigurationAsync(const DeleteSecurityConfigurationRequest & request,const DeleteSecurityConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const354 void EMRClient::DeleteSecurityConfigurationAsync(const DeleteSecurityConfigurationRequest& request, const DeleteSecurityConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
355 {
356 m_executor->Submit( [this, request, handler, context](){ this->DeleteSecurityConfigurationAsyncHelper( request, handler, context ); } );
357 }
358
DeleteSecurityConfigurationAsyncHelper(const DeleteSecurityConfigurationRequest & request,const DeleteSecurityConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const359 void EMRClient::DeleteSecurityConfigurationAsyncHelper(const DeleteSecurityConfigurationRequest& request, const DeleteSecurityConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
360 {
361 handler(this, request, DeleteSecurityConfiguration(request), context);
362 }
363
DeleteStudio(const DeleteStudioRequest & request) const364 DeleteStudioOutcome EMRClient::DeleteStudio(const DeleteStudioRequest& request) const
365 {
366 Aws::Http::URI uri = m_uri;
367 return DeleteStudioOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
368 }
369
DeleteStudioCallable(const DeleteStudioRequest & request) const370 DeleteStudioOutcomeCallable EMRClient::DeleteStudioCallable(const DeleteStudioRequest& request) const
371 {
372 auto task = Aws::MakeShared< std::packaged_task< DeleteStudioOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DeleteStudio(request); } );
373 auto packagedFunction = [task]() { (*task)(); };
374 m_executor->Submit(packagedFunction);
375 return task->get_future();
376 }
377
DeleteStudioAsync(const DeleteStudioRequest & request,const DeleteStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const378 void EMRClient::DeleteStudioAsync(const DeleteStudioRequest& request, const DeleteStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
379 {
380 m_executor->Submit( [this, request, handler, context](){ this->DeleteStudioAsyncHelper( request, handler, context ); } );
381 }
382
DeleteStudioAsyncHelper(const DeleteStudioRequest & request,const DeleteStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const383 void EMRClient::DeleteStudioAsyncHelper(const DeleteStudioRequest& request, const DeleteStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
384 {
385 handler(this, request, DeleteStudio(request), context);
386 }
387
DeleteStudioSessionMapping(const DeleteStudioSessionMappingRequest & request) const388 DeleteStudioSessionMappingOutcome EMRClient::DeleteStudioSessionMapping(const DeleteStudioSessionMappingRequest& request) const
389 {
390 Aws::Http::URI uri = m_uri;
391 return DeleteStudioSessionMappingOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
392 }
393
DeleteStudioSessionMappingCallable(const DeleteStudioSessionMappingRequest & request) const394 DeleteStudioSessionMappingOutcomeCallable EMRClient::DeleteStudioSessionMappingCallable(const DeleteStudioSessionMappingRequest& request) const
395 {
396 auto task = Aws::MakeShared< std::packaged_task< DeleteStudioSessionMappingOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DeleteStudioSessionMapping(request); } );
397 auto packagedFunction = [task]() { (*task)(); };
398 m_executor->Submit(packagedFunction);
399 return task->get_future();
400 }
401
DeleteStudioSessionMappingAsync(const DeleteStudioSessionMappingRequest & request,const DeleteStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const402 void EMRClient::DeleteStudioSessionMappingAsync(const DeleteStudioSessionMappingRequest& request, const DeleteStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
403 {
404 m_executor->Submit( [this, request, handler, context](){ this->DeleteStudioSessionMappingAsyncHelper( request, handler, context ); } );
405 }
406
DeleteStudioSessionMappingAsyncHelper(const DeleteStudioSessionMappingRequest & request,const DeleteStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const407 void EMRClient::DeleteStudioSessionMappingAsyncHelper(const DeleteStudioSessionMappingRequest& request, const DeleteStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
408 {
409 handler(this, request, DeleteStudioSessionMapping(request), context);
410 }
411
DescribeCluster(const DescribeClusterRequest & request) const412 DescribeClusterOutcome EMRClient::DescribeCluster(const DescribeClusterRequest& request) const
413 {
414 Aws::Http::URI uri = m_uri;
415 return DescribeClusterOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
416 }
417
DescribeClusterCallable(const DescribeClusterRequest & request) const418 DescribeClusterOutcomeCallable EMRClient::DescribeClusterCallable(const DescribeClusterRequest& request) const
419 {
420 auto task = Aws::MakeShared< std::packaged_task< DescribeClusterOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DescribeCluster(request); } );
421 auto packagedFunction = [task]() { (*task)(); };
422 m_executor->Submit(packagedFunction);
423 return task->get_future();
424 }
425
DescribeClusterAsync(const DescribeClusterRequest & request,const DescribeClusterResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const426 void EMRClient::DescribeClusterAsync(const DescribeClusterRequest& request, const DescribeClusterResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
427 {
428 m_executor->Submit( [this, request, handler, context](){ this->DescribeClusterAsyncHelper( request, handler, context ); } );
429 }
430
DescribeClusterAsyncHelper(const DescribeClusterRequest & request,const DescribeClusterResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const431 void EMRClient::DescribeClusterAsyncHelper(const DescribeClusterRequest& request, const DescribeClusterResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
432 {
433 handler(this, request, DescribeCluster(request), context);
434 }
435
DescribeNotebookExecution(const DescribeNotebookExecutionRequest & request) const436 DescribeNotebookExecutionOutcome EMRClient::DescribeNotebookExecution(const DescribeNotebookExecutionRequest& request) const
437 {
438 Aws::Http::URI uri = m_uri;
439 return DescribeNotebookExecutionOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
440 }
441
DescribeNotebookExecutionCallable(const DescribeNotebookExecutionRequest & request) const442 DescribeNotebookExecutionOutcomeCallable EMRClient::DescribeNotebookExecutionCallable(const DescribeNotebookExecutionRequest& request) const
443 {
444 auto task = Aws::MakeShared< std::packaged_task< DescribeNotebookExecutionOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DescribeNotebookExecution(request); } );
445 auto packagedFunction = [task]() { (*task)(); };
446 m_executor->Submit(packagedFunction);
447 return task->get_future();
448 }
449
DescribeNotebookExecutionAsync(const DescribeNotebookExecutionRequest & request,const DescribeNotebookExecutionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const450 void EMRClient::DescribeNotebookExecutionAsync(const DescribeNotebookExecutionRequest& request, const DescribeNotebookExecutionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
451 {
452 m_executor->Submit( [this, request, handler, context](){ this->DescribeNotebookExecutionAsyncHelper( request, handler, context ); } );
453 }
454
DescribeNotebookExecutionAsyncHelper(const DescribeNotebookExecutionRequest & request,const DescribeNotebookExecutionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const455 void EMRClient::DescribeNotebookExecutionAsyncHelper(const DescribeNotebookExecutionRequest& request, const DescribeNotebookExecutionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
456 {
457 handler(this, request, DescribeNotebookExecution(request), context);
458 }
459
DescribeReleaseLabel(const DescribeReleaseLabelRequest & request) const460 DescribeReleaseLabelOutcome EMRClient::DescribeReleaseLabel(const DescribeReleaseLabelRequest& request) const
461 {
462 Aws::Http::URI uri = m_uri;
463 return DescribeReleaseLabelOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
464 }
465
DescribeReleaseLabelCallable(const DescribeReleaseLabelRequest & request) const466 DescribeReleaseLabelOutcomeCallable EMRClient::DescribeReleaseLabelCallable(const DescribeReleaseLabelRequest& request) const
467 {
468 auto task = Aws::MakeShared< std::packaged_task< DescribeReleaseLabelOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DescribeReleaseLabel(request); } );
469 auto packagedFunction = [task]() { (*task)(); };
470 m_executor->Submit(packagedFunction);
471 return task->get_future();
472 }
473
DescribeReleaseLabelAsync(const DescribeReleaseLabelRequest & request,const DescribeReleaseLabelResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const474 void EMRClient::DescribeReleaseLabelAsync(const DescribeReleaseLabelRequest& request, const DescribeReleaseLabelResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
475 {
476 m_executor->Submit( [this, request, handler, context](){ this->DescribeReleaseLabelAsyncHelper( request, handler, context ); } );
477 }
478
DescribeReleaseLabelAsyncHelper(const DescribeReleaseLabelRequest & request,const DescribeReleaseLabelResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const479 void EMRClient::DescribeReleaseLabelAsyncHelper(const DescribeReleaseLabelRequest& request, const DescribeReleaseLabelResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
480 {
481 handler(this, request, DescribeReleaseLabel(request), context);
482 }
483
DescribeSecurityConfiguration(const DescribeSecurityConfigurationRequest & request) const484 DescribeSecurityConfigurationOutcome EMRClient::DescribeSecurityConfiguration(const DescribeSecurityConfigurationRequest& request) const
485 {
486 Aws::Http::URI uri = m_uri;
487 return DescribeSecurityConfigurationOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
488 }
489
DescribeSecurityConfigurationCallable(const DescribeSecurityConfigurationRequest & request) const490 DescribeSecurityConfigurationOutcomeCallable EMRClient::DescribeSecurityConfigurationCallable(const DescribeSecurityConfigurationRequest& request) const
491 {
492 auto task = Aws::MakeShared< std::packaged_task< DescribeSecurityConfigurationOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DescribeSecurityConfiguration(request); } );
493 auto packagedFunction = [task]() { (*task)(); };
494 m_executor->Submit(packagedFunction);
495 return task->get_future();
496 }
497
DescribeSecurityConfigurationAsync(const DescribeSecurityConfigurationRequest & request,const DescribeSecurityConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const498 void EMRClient::DescribeSecurityConfigurationAsync(const DescribeSecurityConfigurationRequest& request, const DescribeSecurityConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
499 {
500 m_executor->Submit( [this, request, handler, context](){ this->DescribeSecurityConfigurationAsyncHelper( request, handler, context ); } );
501 }
502
DescribeSecurityConfigurationAsyncHelper(const DescribeSecurityConfigurationRequest & request,const DescribeSecurityConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const503 void EMRClient::DescribeSecurityConfigurationAsyncHelper(const DescribeSecurityConfigurationRequest& request, const DescribeSecurityConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
504 {
505 handler(this, request, DescribeSecurityConfiguration(request), context);
506 }
507
DescribeStep(const DescribeStepRequest & request) const508 DescribeStepOutcome EMRClient::DescribeStep(const DescribeStepRequest& request) const
509 {
510 Aws::Http::URI uri = m_uri;
511 return DescribeStepOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
512 }
513
DescribeStepCallable(const DescribeStepRequest & request) const514 DescribeStepOutcomeCallable EMRClient::DescribeStepCallable(const DescribeStepRequest& request) const
515 {
516 auto task = Aws::MakeShared< std::packaged_task< DescribeStepOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DescribeStep(request); } );
517 auto packagedFunction = [task]() { (*task)(); };
518 m_executor->Submit(packagedFunction);
519 return task->get_future();
520 }
521
DescribeStepAsync(const DescribeStepRequest & request,const DescribeStepResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const522 void EMRClient::DescribeStepAsync(const DescribeStepRequest& request, const DescribeStepResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
523 {
524 m_executor->Submit( [this, request, handler, context](){ this->DescribeStepAsyncHelper( request, handler, context ); } );
525 }
526
DescribeStepAsyncHelper(const DescribeStepRequest & request,const DescribeStepResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const527 void EMRClient::DescribeStepAsyncHelper(const DescribeStepRequest& request, const DescribeStepResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
528 {
529 handler(this, request, DescribeStep(request), context);
530 }
531
DescribeStudio(const DescribeStudioRequest & request) const532 DescribeStudioOutcome EMRClient::DescribeStudio(const DescribeStudioRequest& request) const
533 {
534 Aws::Http::URI uri = m_uri;
535 return DescribeStudioOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
536 }
537
DescribeStudioCallable(const DescribeStudioRequest & request) const538 DescribeStudioOutcomeCallable EMRClient::DescribeStudioCallable(const DescribeStudioRequest& request) const
539 {
540 auto task = Aws::MakeShared< std::packaged_task< DescribeStudioOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->DescribeStudio(request); } );
541 auto packagedFunction = [task]() { (*task)(); };
542 m_executor->Submit(packagedFunction);
543 return task->get_future();
544 }
545
DescribeStudioAsync(const DescribeStudioRequest & request,const DescribeStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const546 void EMRClient::DescribeStudioAsync(const DescribeStudioRequest& request, const DescribeStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
547 {
548 m_executor->Submit( [this, request, handler, context](){ this->DescribeStudioAsyncHelper( request, handler, context ); } );
549 }
550
DescribeStudioAsyncHelper(const DescribeStudioRequest & request,const DescribeStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const551 void EMRClient::DescribeStudioAsyncHelper(const DescribeStudioRequest& request, const DescribeStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
552 {
553 handler(this, request, DescribeStudio(request), context);
554 }
555
GetAutoTerminationPolicy(const GetAutoTerminationPolicyRequest & request) const556 GetAutoTerminationPolicyOutcome EMRClient::GetAutoTerminationPolicy(const GetAutoTerminationPolicyRequest& request) const
557 {
558 Aws::Http::URI uri = m_uri;
559 return GetAutoTerminationPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
560 }
561
GetAutoTerminationPolicyCallable(const GetAutoTerminationPolicyRequest & request) const562 GetAutoTerminationPolicyOutcomeCallable EMRClient::GetAutoTerminationPolicyCallable(const GetAutoTerminationPolicyRequest& request) const
563 {
564 auto task = Aws::MakeShared< std::packaged_task< GetAutoTerminationPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->GetAutoTerminationPolicy(request); } );
565 auto packagedFunction = [task]() { (*task)(); };
566 m_executor->Submit(packagedFunction);
567 return task->get_future();
568 }
569
GetAutoTerminationPolicyAsync(const GetAutoTerminationPolicyRequest & request,const GetAutoTerminationPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const570 void EMRClient::GetAutoTerminationPolicyAsync(const GetAutoTerminationPolicyRequest& request, const GetAutoTerminationPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
571 {
572 m_executor->Submit( [this, request, handler, context](){ this->GetAutoTerminationPolicyAsyncHelper( request, handler, context ); } );
573 }
574
GetAutoTerminationPolicyAsyncHelper(const GetAutoTerminationPolicyRequest & request,const GetAutoTerminationPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const575 void EMRClient::GetAutoTerminationPolicyAsyncHelper(const GetAutoTerminationPolicyRequest& request, const GetAutoTerminationPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
576 {
577 handler(this, request, GetAutoTerminationPolicy(request), context);
578 }
579
GetBlockPublicAccessConfiguration(const GetBlockPublicAccessConfigurationRequest & request) const580 GetBlockPublicAccessConfigurationOutcome EMRClient::GetBlockPublicAccessConfiguration(const GetBlockPublicAccessConfigurationRequest& request) const
581 {
582 Aws::Http::URI uri = m_uri;
583 return GetBlockPublicAccessConfigurationOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
584 }
585
GetBlockPublicAccessConfigurationCallable(const GetBlockPublicAccessConfigurationRequest & request) const586 GetBlockPublicAccessConfigurationOutcomeCallable EMRClient::GetBlockPublicAccessConfigurationCallable(const GetBlockPublicAccessConfigurationRequest& request) const
587 {
588 auto task = Aws::MakeShared< std::packaged_task< GetBlockPublicAccessConfigurationOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->GetBlockPublicAccessConfiguration(request); } );
589 auto packagedFunction = [task]() { (*task)(); };
590 m_executor->Submit(packagedFunction);
591 return task->get_future();
592 }
593
GetBlockPublicAccessConfigurationAsync(const GetBlockPublicAccessConfigurationRequest & request,const GetBlockPublicAccessConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const594 void EMRClient::GetBlockPublicAccessConfigurationAsync(const GetBlockPublicAccessConfigurationRequest& request, const GetBlockPublicAccessConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
595 {
596 m_executor->Submit( [this, request, handler, context](){ this->GetBlockPublicAccessConfigurationAsyncHelper( request, handler, context ); } );
597 }
598
GetBlockPublicAccessConfigurationAsyncHelper(const GetBlockPublicAccessConfigurationRequest & request,const GetBlockPublicAccessConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const599 void EMRClient::GetBlockPublicAccessConfigurationAsyncHelper(const GetBlockPublicAccessConfigurationRequest& request, const GetBlockPublicAccessConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
600 {
601 handler(this, request, GetBlockPublicAccessConfiguration(request), context);
602 }
603
GetManagedScalingPolicy(const GetManagedScalingPolicyRequest & request) const604 GetManagedScalingPolicyOutcome EMRClient::GetManagedScalingPolicy(const GetManagedScalingPolicyRequest& request) const
605 {
606 Aws::Http::URI uri = m_uri;
607 return GetManagedScalingPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
608 }
609
GetManagedScalingPolicyCallable(const GetManagedScalingPolicyRequest & request) const610 GetManagedScalingPolicyOutcomeCallable EMRClient::GetManagedScalingPolicyCallable(const GetManagedScalingPolicyRequest& request) const
611 {
612 auto task = Aws::MakeShared< std::packaged_task< GetManagedScalingPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->GetManagedScalingPolicy(request); } );
613 auto packagedFunction = [task]() { (*task)(); };
614 m_executor->Submit(packagedFunction);
615 return task->get_future();
616 }
617
GetManagedScalingPolicyAsync(const GetManagedScalingPolicyRequest & request,const GetManagedScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const618 void EMRClient::GetManagedScalingPolicyAsync(const GetManagedScalingPolicyRequest& request, const GetManagedScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
619 {
620 m_executor->Submit( [this, request, handler, context](){ this->GetManagedScalingPolicyAsyncHelper( request, handler, context ); } );
621 }
622
GetManagedScalingPolicyAsyncHelper(const GetManagedScalingPolicyRequest & request,const GetManagedScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const623 void EMRClient::GetManagedScalingPolicyAsyncHelper(const GetManagedScalingPolicyRequest& request, const GetManagedScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
624 {
625 handler(this, request, GetManagedScalingPolicy(request), context);
626 }
627
GetStudioSessionMapping(const GetStudioSessionMappingRequest & request) const628 GetStudioSessionMappingOutcome EMRClient::GetStudioSessionMapping(const GetStudioSessionMappingRequest& request) const
629 {
630 Aws::Http::URI uri = m_uri;
631 return GetStudioSessionMappingOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
632 }
633
GetStudioSessionMappingCallable(const GetStudioSessionMappingRequest & request) const634 GetStudioSessionMappingOutcomeCallable EMRClient::GetStudioSessionMappingCallable(const GetStudioSessionMappingRequest& request) const
635 {
636 auto task = Aws::MakeShared< std::packaged_task< GetStudioSessionMappingOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->GetStudioSessionMapping(request); } );
637 auto packagedFunction = [task]() { (*task)(); };
638 m_executor->Submit(packagedFunction);
639 return task->get_future();
640 }
641
GetStudioSessionMappingAsync(const GetStudioSessionMappingRequest & request,const GetStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const642 void EMRClient::GetStudioSessionMappingAsync(const GetStudioSessionMappingRequest& request, const GetStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
643 {
644 m_executor->Submit( [this, request, handler, context](){ this->GetStudioSessionMappingAsyncHelper( request, handler, context ); } );
645 }
646
GetStudioSessionMappingAsyncHelper(const GetStudioSessionMappingRequest & request,const GetStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const647 void EMRClient::GetStudioSessionMappingAsyncHelper(const GetStudioSessionMappingRequest& request, const GetStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
648 {
649 handler(this, request, GetStudioSessionMapping(request), context);
650 }
651
ListBootstrapActions(const ListBootstrapActionsRequest & request) const652 ListBootstrapActionsOutcome EMRClient::ListBootstrapActions(const ListBootstrapActionsRequest& request) const
653 {
654 Aws::Http::URI uri = m_uri;
655 return ListBootstrapActionsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
656 }
657
ListBootstrapActionsCallable(const ListBootstrapActionsRequest & request) const658 ListBootstrapActionsOutcomeCallable EMRClient::ListBootstrapActionsCallable(const ListBootstrapActionsRequest& request) const
659 {
660 auto task = Aws::MakeShared< std::packaged_task< ListBootstrapActionsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListBootstrapActions(request); } );
661 auto packagedFunction = [task]() { (*task)(); };
662 m_executor->Submit(packagedFunction);
663 return task->get_future();
664 }
665
ListBootstrapActionsAsync(const ListBootstrapActionsRequest & request,const ListBootstrapActionsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const666 void EMRClient::ListBootstrapActionsAsync(const ListBootstrapActionsRequest& request, const ListBootstrapActionsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
667 {
668 m_executor->Submit( [this, request, handler, context](){ this->ListBootstrapActionsAsyncHelper( request, handler, context ); } );
669 }
670
ListBootstrapActionsAsyncHelper(const ListBootstrapActionsRequest & request,const ListBootstrapActionsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const671 void EMRClient::ListBootstrapActionsAsyncHelper(const ListBootstrapActionsRequest& request, const ListBootstrapActionsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
672 {
673 handler(this, request, ListBootstrapActions(request), context);
674 }
675
ListClusters(const ListClustersRequest & request) const676 ListClustersOutcome EMRClient::ListClusters(const ListClustersRequest& request) const
677 {
678 Aws::Http::URI uri = m_uri;
679 return ListClustersOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
680 }
681
ListClustersCallable(const ListClustersRequest & request) const682 ListClustersOutcomeCallable EMRClient::ListClustersCallable(const ListClustersRequest& request) const
683 {
684 auto task = Aws::MakeShared< std::packaged_task< ListClustersOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListClusters(request); } );
685 auto packagedFunction = [task]() { (*task)(); };
686 m_executor->Submit(packagedFunction);
687 return task->get_future();
688 }
689
ListClustersAsync(const ListClustersRequest & request,const ListClustersResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const690 void EMRClient::ListClustersAsync(const ListClustersRequest& request, const ListClustersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
691 {
692 m_executor->Submit( [this, request, handler, context](){ this->ListClustersAsyncHelper( request, handler, context ); } );
693 }
694
ListClustersAsyncHelper(const ListClustersRequest & request,const ListClustersResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const695 void EMRClient::ListClustersAsyncHelper(const ListClustersRequest& request, const ListClustersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
696 {
697 handler(this, request, ListClusters(request), context);
698 }
699
ListInstanceFleets(const ListInstanceFleetsRequest & request) const700 ListInstanceFleetsOutcome EMRClient::ListInstanceFleets(const ListInstanceFleetsRequest& request) const
701 {
702 Aws::Http::URI uri = m_uri;
703 return ListInstanceFleetsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
704 }
705
ListInstanceFleetsCallable(const ListInstanceFleetsRequest & request) const706 ListInstanceFleetsOutcomeCallable EMRClient::ListInstanceFleetsCallable(const ListInstanceFleetsRequest& request) const
707 {
708 auto task = Aws::MakeShared< std::packaged_task< ListInstanceFleetsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListInstanceFleets(request); } );
709 auto packagedFunction = [task]() { (*task)(); };
710 m_executor->Submit(packagedFunction);
711 return task->get_future();
712 }
713
ListInstanceFleetsAsync(const ListInstanceFleetsRequest & request,const ListInstanceFleetsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const714 void EMRClient::ListInstanceFleetsAsync(const ListInstanceFleetsRequest& request, const ListInstanceFleetsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
715 {
716 m_executor->Submit( [this, request, handler, context](){ this->ListInstanceFleetsAsyncHelper( request, handler, context ); } );
717 }
718
ListInstanceFleetsAsyncHelper(const ListInstanceFleetsRequest & request,const ListInstanceFleetsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const719 void EMRClient::ListInstanceFleetsAsyncHelper(const ListInstanceFleetsRequest& request, const ListInstanceFleetsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
720 {
721 handler(this, request, ListInstanceFleets(request), context);
722 }
723
ListInstanceGroups(const ListInstanceGroupsRequest & request) const724 ListInstanceGroupsOutcome EMRClient::ListInstanceGroups(const ListInstanceGroupsRequest& request) const
725 {
726 Aws::Http::URI uri = m_uri;
727 return ListInstanceGroupsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
728 }
729
ListInstanceGroupsCallable(const ListInstanceGroupsRequest & request) const730 ListInstanceGroupsOutcomeCallable EMRClient::ListInstanceGroupsCallable(const ListInstanceGroupsRequest& request) const
731 {
732 auto task = Aws::MakeShared< std::packaged_task< ListInstanceGroupsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListInstanceGroups(request); } );
733 auto packagedFunction = [task]() { (*task)(); };
734 m_executor->Submit(packagedFunction);
735 return task->get_future();
736 }
737
ListInstanceGroupsAsync(const ListInstanceGroupsRequest & request,const ListInstanceGroupsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const738 void EMRClient::ListInstanceGroupsAsync(const ListInstanceGroupsRequest& request, const ListInstanceGroupsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
739 {
740 m_executor->Submit( [this, request, handler, context](){ this->ListInstanceGroupsAsyncHelper( request, handler, context ); } );
741 }
742
ListInstanceGroupsAsyncHelper(const ListInstanceGroupsRequest & request,const ListInstanceGroupsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const743 void EMRClient::ListInstanceGroupsAsyncHelper(const ListInstanceGroupsRequest& request, const ListInstanceGroupsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
744 {
745 handler(this, request, ListInstanceGroups(request), context);
746 }
747
ListInstances(const ListInstancesRequest & request) const748 ListInstancesOutcome EMRClient::ListInstances(const ListInstancesRequest& request) const
749 {
750 Aws::Http::URI uri = m_uri;
751 return ListInstancesOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
752 }
753
ListInstancesCallable(const ListInstancesRequest & request) const754 ListInstancesOutcomeCallable EMRClient::ListInstancesCallable(const ListInstancesRequest& request) const
755 {
756 auto task = Aws::MakeShared< std::packaged_task< ListInstancesOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListInstances(request); } );
757 auto packagedFunction = [task]() { (*task)(); };
758 m_executor->Submit(packagedFunction);
759 return task->get_future();
760 }
761
ListInstancesAsync(const ListInstancesRequest & request,const ListInstancesResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const762 void EMRClient::ListInstancesAsync(const ListInstancesRequest& request, const ListInstancesResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
763 {
764 m_executor->Submit( [this, request, handler, context](){ this->ListInstancesAsyncHelper( request, handler, context ); } );
765 }
766
ListInstancesAsyncHelper(const ListInstancesRequest & request,const ListInstancesResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const767 void EMRClient::ListInstancesAsyncHelper(const ListInstancesRequest& request, const ListInstancesResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
768 {
769 handler(this, request, ListInstances(request), context);
770 }
771
ListNotebookExecutions(const ListNotebookExecutionsRequest & request) const772 ListNotebookExecutionsOutcome EMRClient::ListNotebookExecutions(const ListNotebookExecutionsRequest& request) const
773 {
774 Aws::Http::URI uri = m_uri;
775 return ListNotebookExecutionsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
776 }
777
ListNotebookExecutionsCallable(const ListNotebookExecutionsRequest & request) const778 ListNotebookExecutionsOutcomeCallable EMRClient::ListNotebookExecutionsCallable(const ListNotebookExecutionsRequest& request) const
779 {
780 auto task = Aws::MakeShared< std::packaged_task< ListNotebookExecutionsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListNotebookExecutions(request); } );
781 auto packagedFunction = [task]() { (*task)(); };
782 m_executor->Submit(packagedFunction);
783 return task->get_future();
784 }
785
ListNotebookExecutionsAsync(const ListNotebookExecutionsRequest & request,const ListNotebookExecutionsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const786 void EMRClient::ListNotebookExecutionsAsync(const ListNotebookExecutionsRequest& request, const ListNotebookExecutionsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
787 {
788 m_executor->Submit( [this, request, handler, context](){ this->ListNotebookExecutionsAsyncHelper( request, handler, context ); } );
789 }
790
ListNotebookExecutionsAsyncHelper(const ListNotebookExecutionsRequest & request,const ListNotebookExecutionsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const791 void EMRClient::ListNotebookExecutionsAsyncHelper(const ListNotebookExecutionsRequest& request, const ListNotebookExecutionsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
792 {
793 handler(this, request, ListNotebookExecutions(request), context);
794 }
795
ListReleaseLabels(const ListReleaseLabelsRequest & request) const796 ListReleaseLabelsOutcome EMRClient::ListReleaseLabels(const ListReleaseLabelsRequest& request) const
797 {
798 Aws::Http::URI uri = m_uri;
799 return ListReleaseLabelsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
800 }
801
ListReleaseLabelsCallable(const ListReleaseLabelsRequest & request) const802 ListReleaseLabelsOutcomeCallable EMRClient::ListReleaseLabelsCallable(const ListReleaseLabelsRequest& request) const
803 {
804 auto task = Aws::MakeShared< std::packaged_task< ListReleaseLabelsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListReleaseLabels(request); } );
805 auto packagedFunction = [task]() { (*task)(); };
806 m_executor->Submit(packagedFunction);
807 return task->get_future();
808 }
809
ListReleaseLabelsAsync(const ListReleaseLabelsRequest & request,const ListReleaseLabelsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const810 void EMRClient::ListReleaseLabelsAsync(const ListReleaseLabelsRequest& request, const ListReleaseLabelsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
811 {
812 m_executor->Submit( [this, request, handler, context](){ this->ListReleaseLabelsAsyncHelper( request, handler, context ); } );
813 }
814
ListReleaseLabelsAsyncHelper(const ListReleaseLabelsRequest & request,const ListReleaseLabelsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const815 void EMRClient::ListReleaseLabelsAsyncHelper(const ListReleaseLabelsRequest& request, const ListReleaseLabelsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
816 {
817 handler(this, request, ListReleaseLabels(request), context);
818 }
819
ListSecurityConfigurations(const ListSecurityConfigurationsRequest & request) const820 ListSecurityConfigurationsOutcome EMRClient::ListSecurityConfigurations(const ListSecurityConfigurationsRequest& request) const
821 {
822 Aws::Http::URI uri = m_uri;
823 return ListSecurityConfigurationsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
824 }
825
ListSecurityConfigurationsCallable(const ListSecurityConfigurationsRequest & request) const826 ListSecurityConfigurationsOutcomeCallable EMRClient::ListSecurityConfigurationsCallable(const ListSecurityConfigurationsRequest& request) const
827 {
828 auto task = Aws::MakeShared< std::packaged_task< ListSecurityConfigurationsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListSecurityConfigurations(request); } );
829 auto packagedFunction = [task]() { (*task)(); };
830 m_executor->Submit(packagedFunction);
831 return task->get_future();
832 }
833
ListSecurityConfigurationsAsync(const ListSecurityConfigurationsRequest & request,const ListSecurityConfigurationsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const834 void EMRClient::ListSecurityConfigurationsAsync(const ListSecurityConfigurationsRequest& request, const ListSecurityConfigurationsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
835 {
836 m_executor->Submit( [this, request, handler, context](){ this->ListSecurityConfigurationsAsyncHelper( request, handler, context ); } );
837 }
838
ListSecurityConfigurationsAsyncHelper(const ListSecurityConfigurationsRequest & request,const ListSecurityConfigurationsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const839 void EMRClient::ListSecurityConfigurationsAsyncHelper(const ListSecurityConfigurationsRequest& request, const ListSecurityConfigurationsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
840 {
841 handler(this, request, ListSecurityConfigurations(request), context);
842 }
843
ListSteps(const ListStepsRequest & request) const844 ListStepsOutcome EMRClient::ListSteps(const ListStepsRequest& request) const
845 {
846 Aws::Http::URI uri = m_uri;
847 return ListStepsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
848 }
849
ListStepsCallable(const ListStepsRequest & request) const850 ListStepsOutcomeCallable EMRClient::ListStepsCallable(const ListStepsRequest& request) const
851 {
852 auto task = Aws::MakeShared< std::packaged_task< ListStepsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListSteps(request); } );
853 auto packagedFunction = [task]() { (*task)(); };
854 m_executor->Submit(packagedFunction);
855 return task->get_future();
856 }
857
ListStepsAsync(const ListStepsRequest & request,const ListStepsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const858 void EMRClient::ListStepsAsync(const ListStepsRequest& request, const ListStepsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
859 {
860 m_executor->Submit( [this, request, handler, context](){ this->ListStepsAsyncHelper( request, handler, context ); } );
861 }
862
ListStepsAsyncHelper(const ListStepsRequest & request,const ListStepsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const863 void EMRClient::ListStepsAsyncHelper(const ListStepsRequest& request, const ListStepsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
864 {
865 handler(this, request, ListSteps(request), context);
866 }
867
ListStudioSessionMappings(const ListStudioSessionMappingsRequest & request) const868 ListStudioSessionMappingsOutcome EMRClient::ListStudioSessionMappings(const ListStudioSessionMappingsRequest& request) const
869 {
870 Aws::Http::URI uri = m_uri;
871 return ListStudioSessionMappingsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
872 }
873
ListStudioSessionMappingsCallable(const ListStudioSessionMappingsRequest & request) const874 ListStudioSessionMappingsOutcomeCallable EMRClient::ListStudioSessionMappingsCallable(const ListStudioSessionMappingsRequest& request) const
875 {
876 auto task = Aws::MakeShared< std::packaged_task< ListStudioSessionMappingsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListStudioSessionMappings(request); } );
877 auto packagedFunction = [task]() { (*task)(); };
878 m_executor->Submit(packagedFunction);
879 return task->get_future();
880 }
881
ListStudioSessionMappingsAsync(const ListStudioSessionMappingsRequest & request,const ListStudioSessionMappingsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const882 void EMRClient::ListStudioSessionMappingsAsync(const ListStudioSessionMappingsRequest& request, const ListStudioSessionMappingsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
883 {
884 m_executor->Submit( [this, request, handler, context](){ this->ListStudioSessionMappingsAsyncHelper( request, handler, context ); } );
885 }
886
ListStudioSessionMappingsAsyncHelper(const ListStudioSessionMappingsRequest & request,const ListStudioSessionMappingsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const887 void EMRClient::ListStudioSessionMappingsAsyncHelper(const ListStudioSessionMappingsRequest& request, const ListStudioSessionMappingsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
888 {
889 handler(this, request, ListStudioSessionMappings(request), context);
890 }
891
ListStudios(const ListStudiosRequest & request) const892 ListStudiosOutcome EMRClient::ListStudios(const ListStudiosRequest& request) const
893 {
894 Aws::Http::URI uri = m_uri;
895 return ListStudiosOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
896 }
897
ListStudiosCallable(const ListStudiosRequest & request) const898 ListStudiosOutcomeCallable EMRClient::ListStudiosCallable(const ListStudiosRequest& request) const
899 {
900 auto task = Aws::MakeShared< std::packaged_task< ListStudiosOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ListStudios(request); } );
901 auto packagedFunction = [task]() { (*task)(); };
902 m_executor->Submit(packagedFunction);
903 return task->get_future();
904 }
905
ListStudiosAsync(const ListStudiosRequest & request,const ListStudiosResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const906 void EMRClient::ListStudiosAsync(const ListStudiosRequest& request, const ListStudiosResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
907 {
908 m_executor->Submit( [this, request, handler, context](){ this->ListStudiosAsyncHelper( request, handler, context ); } );
909 }
910
ListStudiosAsyncHelper(const ListStudiosRequest & request,const ListStudiosResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const911 void EMRClient::ListStudiosAsyncHelper(const ListStudiosRequest& request, const ListStudiosResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
912 {
913 handler(this, request, ListStudios(request), context);
914 }
915
ModifyCluster(const ModifyClusterRequest & request) const916 ModifyClusterOutcome EMRClient::ModifyCluster(const ModifyClusterRequest& request) const
917 {
918 Aws::Http::URI uri = m_uri;
919 return ModifyClusterOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
920 }
921
ModifyClusterCallable(const ModifyClusterRequest & request) const922 ModifyClusterOutcomeCallable EMRClient::ModifyClusterCallable(const ModifyClusterRequest& request) const
923 {
924 auto task = Aws::MakeShared< std::packaged_task< ModifyClusterOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ModifyCluster(request); } );
925 auto packagedFunction = [task]() { (*task)(); };
926 m_executor->Submit(packagedFunction);
927 return task->get_future();
928 }
929
ModifyClusterAsync(const ModifyClusterRequest & request,const ModifyClusterResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const930 void EMRClient::ModifyClusterAsync(const ModifyClusterRequest& request, const ModifyClusterResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
931 {
932 m_executor->Submit( [this, request, handler, context](){ this->ModifyClusterAsyncHelper( request, handler, context ); } );
933 }
934
ModifyClusterAsyncHelper(const ModifyClusterRequest & request,const ModifyClusterResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const935 void EMRClient::ModifyClusterAsyncHelper(const ModifyClusterRequest& request, const ModifyClusterResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
936 {
937 handler(this, request, ModifyCluster(request), context);
938 }
939
ModifyInstanceFleet(const ModifyInstanceFleetRequest & request) const940 ModifyInstanceFleetOutcome EMRClient::ModifyInstanceFleet(const ModifyInstanceFleetRequest& request) const
941 {
942 Aws::Http::URI uri = m_uri;
943 return ModifyInstanceFleetOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
944 }
945
ModifyInstanceFleetCallable(const ModifyInstanceFleetRequest & request) const946 ModifyInstanceFleetOutcomeCallable EMRClient::ModifyInstanceFleetCallable(const ModifyInstanceFleetRequest& request) const
947 {
948 auto task = Aws::MakeShared< std::packaged_task< ModifyInstanceFleetOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ModifyInstanceFleet(request); } );
949 auto packagedFunction = [task]() { (*task)(); };
950 m_executor->Submit(packagedFunction);
951 return task->get_future();
952 }
953
ModifyInstanceFleetAsync(const ModifyInstanceFleetRequest & request,const ModifyInstanceFleetResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const954 void EMRClient::ModifyInstanceFleetAsync(const ModifyInstanceFleetRequest& request, const ModifyInstanceFleetResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
955 {
956 m_executor->Submit( [this, request, handler, context](){ this->ModifyInstanceFleetAsyncHelper( request, handler, context ); } );
957 }
958
ModifyInstanceFleetAsyncHelper(const ModifyInstanceFleetRequest & request,const ModifyInstanceFleetResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const959 void EMRClient::ModifyInstanceFleetAsyncHelper(const ModifyInstanceFleetRequest& request, const ModifyInstanceFleetResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
960 {
961 handler(this, request, ModifyInstanceFleet(request), context);
962 }
963
ModifyInstanceGroups(const ModifyInstanceGroupsRequest & request) const964 ModifyInstanceGroupsOutcome EMRClient::ModifyInstanceGroups(const ModifyInstanceGroupsRequest& request) const
965 {
966 Aws::Http::URI uri = m_uri;
967 return ModifyInstanceGroupsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
968 }
969
ModifyInstanceGroupsCallable(const ModifyInstanceGroupsRequest & request) const970 ModifyInstanceGroupsOutcomeCallable EMRClient::ModifyInstanceGroupsCallable(const ModifyInstanceGroupsRequest& request) const
971 {
972 auto task = Aws::MakeShared< std::packaged_task< ModifyInstanceGroupsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->ModifyInstanceGroups(request); } );
973 auto packagedFunction = [task]() { (*task)(); };
974 m_executor->Submit(packagedFunction);
975 return task->get_future();
976 }
977
ModifyInstanceGroupsAsync(const ModifyInstanceGroupsRequest & request,const ModifyInstanceGroupsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const978 void EMRClient::ModifyInstanceGroupsAsync(const ModifyInstanceGroupsRequest& request, const ModifyInstanceGroupsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
979 {
980 m_executor->Submit( [this, request, handler, context](){ this->ModifyInstanceGroupsAsyncHelper( request, handler, context ); } );
981 }
982
ModifyInstanceGroupsAsyncHelper(const ModifyInstanceGroupsRequest & request,const ModifyInstanceGroupsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const983 void EMRClient::ModifyInstanceGroupsAsyncHelper(const ModifyInstanceGroupsRequest& request, const ModifyInstanceGroupsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
984 {
985 handler(this, request, ModifyInstanceGroups(request), context);
986 }
987
PutAutoScalingPolicy(const PutAutoScalingPolicyRequest & request) const988 PutAutoScalingPolicyOutcome EMRClient::PutAutoScalingPolicy(const PutAutoScalingPolicyRequest& request) const
989 {
990 Aws::Http::URI uri = m_uri;
991 return PutAutoScalingPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
992 }
993
PutAutoScalingPolicyCallable(const PutAutoScalingPolicyRequest & request) const994 PutAutoScalingPolicyOutcomeCallable EMRClient::PutAutoScalingPolicyCallable(const PutAutoScalingPolicyRequest& request) const
995 {
996 auto task = Aws::MakeShared< std::packaged_task< PutAutoScalingPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->PutAutoScalingPolicy(request); } );
997 auto packagedFunction = [task]() { (*task)(); };
998 m_executor->Submit(packagedFunction);
999 return task->get_future();
1000 }
1001
PutAutoScalingPolicyAsync(const PutAutoScalingPolicyRequest & request,const PutAutoScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1002 void EMRClient::PutAutoScalingPolicyAsync(const PutAutoScalingPolicyRequest& request, const PutAutoScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1003 {
1004 m_executor->Submit( [this, request, handler, context](){ this->PutAutoScalingPolicyAsyncHelper( request, handler, context ); } );
1005 }
1006
PutAutoScalingPolicyAsyncHelper(const PutAutoScalingPolicyRequest & request,const PutAutoScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1007 void EMRClient::PutAutoScalingPolicyAsyncHelper(const PutAutoScalingPolicyRequest& request, const PutAutoScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1008 {
1009 handler(this, request, PutAutoScalingPolicy(request), context);
1010 }
1011
PutAutoTerminationPolicy(const PutAutoTerminationPolicyRequest & request) const1012 PutAutoTerminationPolicyOutcome EMRClient::PutAutoTerminationPolicy(const PutAutoTerminationPolicyRequest& request) const
1013 {
1014 Aws::Http::URI uri = m_uri;
1015 return PutAutoTerminationPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1016 }
1017
PutAutoTerminationPolicyCallable(const PutAutoTerminationPolicyRequest & request) const1018 PutAutoTerminationPolicyOutcomeCallable EMRClient::PutAutoTerminationPolicyCallable(const PutAutoTerminationPolicyRequest& request) const
1019 {
1020 auto task = Aws::MakeShared< std::packaged_task< PutAutoTerminationPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->PutAutoTerminationPolicy(request); } );
1021 auto packagedFunction = [task]() { (*task)(); };
1022 m_executor->Submit(packagedFunction);
1023 return task->get_future();
1024 }
1025
PutAutoTerminationPolicyAsync(const PutAutoTerminationPolicyRequest & request,const PutAutoTerminationPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1026 void EMRClient::PutAutoTerminationPolicyAsync(const PutAutoTerminationPolicyRequest& request, const PutAutoTerminationPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1027 {
1028 m_executor->Submit( [this, request, handler, context](){ this->PutAutoTerminationPolicyAsyncHelper( request, handler, context ); } );
1029 }
1030
PutAutoTerminationPolicyAsyncHelper(const PutAutoTerminationPolicyRequest & request,const PutAutoTerminationPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1031 void EMRClient::PutAutoTerminationPolicyAsyncHelper(const PutAutoTerminationPolicyRequest& request, const PutAutoTerminationPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1032 {
1033 handler(this, request, PutAutoTerminationPolicy(request), context);
1034 }
1035
PutBlockPublicAccessConfiguration(const PutBlockPublicAccessConfigurationRequest & request) const1036 PutBlockPublicAccessConfigurationOutcome EMRClient::PutBlockPublicAccessConfiguration(const PutBlockPublicAccessConfigurationRequest& request) const
1037 {
1038 Aws::Http::URI uri = m_uri;
1039 return PutBlockPublicAccessConfigurationOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1040 }
1041
PutBlockPublicAccessConfigurationCallable(const PutBlockPublicAccessConfigurationRequest & request) const1042 PutBlockPublicAccessConfigurationOutcomeCallable EMRClient::PutBlockPublicAccessConfigurationCallable(const PutBlockPublicAccessConfigurationRequest& request) const
1043 {
1044 auto task = Aws::MakeShared< std::packaged_task< PutBlockPublicAccessConfigurationOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->PutBlockPublicAccessConfiguration(request); } );
1045 auto packagedFunction = [task]() { (*task)(); };
1046 m_executor->Submit(packagedFunction);
1047 return task->get_future();
1048 }
1049
PutBlockPublicAccessConfigurationAsync(const PutBlockPublicAccessConfigurationRequest & request,const PutBlockPublicAccessConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1050 void EMRClient::PutBlockPublicAccessConfigurationAsync(const PutBlockPublicAccessConfigurationRequest& request, const PutBlockPublicAccessConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1051 {
1052 m_executor->Submit( [this, request, handler, context](){ this->PutBlockPublicAccessConfigurationAsyncHelper( request, handler, context ); } );
1053 }
1054
PutBlockPublicAccessConfigurationAsyncHelper(const PutBlockPublicAccessConfigurationRequest & request,const PutBlockPublicAccessConfigurationResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1055 void EMRClient::PutBlockPublicAccessConfigurationAsyncHelper(const PutBlockPublicAccessConfigurationRequest& request, const PutBlockPublicAccessConfigurationResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1056 {
1057 handler(this, request, PutBlockPublicAccessConfiguration(request), context);
1058 }
1059
PutManagedScalingPolicy(const PutManagedScalingPolicyRequest & request) const1060 PutManagedScalingPolicyOutcome EMRClient::PutManagedScalingPolicy(const PutManagedScalingPolicyRequest& request) const
1061 {
1062 Aws::Http::URI uri = m_uri;
1063 return PutManagedScalingPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1064 }
1065
PutManagedScalingPolicyCallable(const PutManagedScalingPolicyRequest & request) const1066 PutManagedScalingPolicyOutcomeCallable EMRClient::PutManagedScalingPolicyCallable(const PutManagedScalingPolicyRequest& request) const
1067 {
1068 auto task = Aws::MakeShared< std::packaged_task< PutManagedScalingPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->PutManagedScalingPolicy(request); } );
1069 auto packagedFunction = [task]() { (*task)(); };
1070 m_executor->Submit(packagedFunction);
1071 return task->get_future();
1072 }
1073
PutManagedScalingPolicyAsync(const PutManagedScalingPolicyRequest & request,const PutManagedScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1074 void EMRClient::PutManagedScalingPolicyAsync(const PutManagedScalingPolicyRequest& request, const PutManagedScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1075 {
1076 m_executor->Submit( [this, request, handler, context](){ this->PutManagedScalingPolicyAsyncHelper( request, handler, context ); } );
1077 }
1078
PutManagedScalingPolicyAsyncHelper(const PutManagedScalingPolicyRequest & request,const PutManagedScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1079 void EMRClient::PutManagedScalingPolicyAsyncHelper(const PutManagedScalingPolicyRequest& request, const PutManagedScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1080 {
1081 handler(this, request, PutManagedScalingPolicy(request), context);
1082 }
1083
RemoveAutoScalingPolicy(const RemoveAutoScalingPolicyRequest & request) const1084 RemoveAutoScalingPolicyOutcome EMRClient::RemoveAutoScalingPolicy(const RemoveAutoScalingPolicyRequest& request) const
1085 {
1086 Aws::Http::URI uri = m_uri;
1087 return RemoveAutoScalingPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1088 }
1089
RemoveAutoScalingPolicyCallable(const RemoveAutoScalingPolicyRequest & request) const1090 RemoveAutoScalingPolicyOutcomeCallable EMRClient::RemoveAutoScalingPolicyCallable(const RemoveAutoScalingPolicyRequest& request) const
1091 {
1092 auto task = Aws::MakeShared< std::packaged_task< RemoveAutoScalingPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->RemoveAutoScalingPolicy(request); } );
1093 auto packagedFunction = [task]() { (*task)(); };
1094 m_executor->Submit(packagedFunction);
1095 return task->get_future();
1096 }
1097
RemoveAutoScalingPolicyAsync(const RemoveAutoScalingPolicyRequest & request,const RemoveAutoScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1098 void EMRClient::RemoveAutoScalingPolicyAsync(const RemoveAutoScalingPolicyRequest& request, const RemoveAutoScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1099 {
1100 m_executor->Submit( [this, request, handler, context](){ this->RemoveAutoScalingPolicyAsyncHelper( request, handler, context ); } );
1101 }
1102
RemoveAutoScalingPolicyAsyncHelper(const RemoveAutoScalingPolicyRequest & request,const RemoveAutoScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1103 void EMRClient::RemoveAutoScalingPolicyAsyncHelper(const RemoveAutoScalingPolicyRequest& request, const RemoveAutoScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1104 {
1105 handler(this, request, RemoveAutoScalingPolicy(request), context);
1106 }
1107
RemoveAutoTerminationPolicy(const RemoveAutoTerminationPolicyRequest & request) const1108 RemoveAutoTerminationPolicyOutcome EMRClient::RemoveAutoTerminationPolicy(const RemoveAutoTerminationPolicyRequest& request) const
1109 {
1110 Aws::Http::URI uri = m_uri;
1111 return RemoveAutoTerminationPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1112 }
1113
RemoveAutoTerminationPolicyCallable(const RemoveAutoTerminationPolicyRequest & request) const1114 RemoveAutoTerminationPolicyOutcomeCallable EMRClient::RemoveAutoTerminationPolicyCallable(const RemoveAutoTerminationPolicyRequest& request) const
1115 {
1116 auto task = Aws::MakeShared< std::packaged_task< RemoveAutoTerminationPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->RemoveAutoTerminationPolicy(request); } );
1117 auto packagedFunction = [task]() { (*task)(); };
1118 m_executor->Submit(packagedFunction);
1119 return task->get_future();
1120 }
1121
RemoveAutoTerminationPolicyAsync(const RemoveAutoTerminationPolicyRequest & request,const RemoveAutoTerminationPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1122 void EMRClient::RemoveAutoTerminationPolicyAsync(const RemoveAutoTerminationPolicyRequest& request, const RemoveAutoTerminationPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1123 {
1124 m_executor->Submit( [this, request, handler, context](){ this->RemoveAutoTerminationPolicyAsyncHelper( request, handler, context ); } );
1125 }
1126
RemoveAutoTerminationPolicyAsyncHelper(const RemoveAutoTerminationPolicyRequest & request,const RemoveAutoTerminationPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1127 void EMRClient::RemoveAutoTerminationPolicyAsyncHelper(const RemoveAutoTerminationPolicyRequest& request, const RemoveAutoTerminationPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1128 {
1129 handler(this, request, RemoveAutoTerminationPolicy(request), context);
1130 }
1131
RemoveManagedScalingPolicy(const RemoveManagedScalingPolicyRequest & request) const1132 RemoveManagedScalingPolicyOutcome EMRClient::RemoveManagedScalingPolicy(const RemoveManagedScalingPolicyRequest& request) const
1133 {
1134 Aws::Http::URI uri = m_uri;
1135 return RemoveManagedScalingPolicyOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1136 }
1137
RemoveManagedScalingPolicyCallable(const RemoveManagedScalingPolicyRequest & request) const1138 RemoveManagedScalingPolicyOutcomeCallable EMRClient::RemoveManagedScalingPolicyCallable(const RemoveManagedScalingPolicyRequest& request) const
1139 {
1140 auto task = Aws::MakeShared< std::packaged_task< RemoveManagedScalingPolicyOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->RemoveManagedScalingPolicy(request); } );
1141 auto packagedFunction = [task]() { (*task)(); };
1142 m_executor->Submit(packagedFunction);
1143 return task->get_future();
1144 }
1145
RemoveManagedScalingPolicyAsync(const RemoveManagedScalingPolicyRequest & request,const RemoveManagedScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1146 void EMRClient::RemoveManagedScalingPolicyAsync(const RemoveManagedScalingPolicyRequest& request, const RemoveManagedScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1147 {
1148 m_executor->Submit( [this, request, handler, context](){ this->RemoveManagedScalingPolicyAsyncHelper( request, handler, context ); } );
1149 }
1150
RemoveManagedScalingPolicyAsyncHelper(const RemoveManagedScalingPolicyRequest & request,const RemoveManagedScalingPolicyResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1151 void EMRClient::RemoveManagedScalingPolicyAsyncHelper(const RemoveManagedScalingPolicyRequest& request, const RemoveManagedScalingPolicyResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1152 {
1153 handler(this, request, RemoveManagedScalingPolicy(request), context);
1154 }
1155
RemoveTags(const RemoveTagsRequest & request) const1156 RemoveTagsOutcome EMRClient::RemoveTags(const RemoveTagsRequest& request) const
1157 {
1158 Aws::Http::URI uri = m_uri;
1159 return RemoveTagsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1160 }
1161
RemoveTagsCallable(const RemoveTagsRequest & request) const1162 RemoveTagsOutcomeCallable EMRClient::RemoveTagsCallable(const RemoveTagsRequest& request) const
1163 {
1164 auto task = Aws::MakeShared< std::packaged_task< RemoveTagsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->RemoveTags(request); } );
1165 auto packagedFunction = [task]() { (*task)(); };
1166 m_executor->Submit(packagedFunction);
1167 return task->get_future();
1168 }
1169
RemoveTagsAsync(const RemoveTagsRequest & request,const RemoveTagsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1170 void EMRClient::RemoveTagsAsync(const RemoveTagsRequest& request, const RemoveTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1171 {
1172 m_executor->Submit( [this, request, handler, context](){ this->RemoveTagsAsyncHelper( request, handler, context ); } );
1173 }
1174
RemoveTagsAsyncHelper(const RemoveTagsRequest & request,const RemoveTagsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1175 void EMRClient::RemoveTagsAsyncHelper(const RemoveTagsRequest& request, const RemoveTagsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1176 {
1177 handler(this, request, RemoveTags(request), context);
1178 }
1179
RunJobFlow(const RunJobFlowRequest & request) const1180 RunJobFlowOutcome EMRClient::RunJobFlow(const RunJobFlowRequest& request) const
1181 {
1182 Aws::Http::URI uri = m_uri;
1183 return RunJobFlowOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1184 }
1185
RunJobFlowCallable(const RunJobFlowRequest & request) const1186 RunJobFlowOutcomeCallable EMRClient::RunJobFlowCallable(const RunJobFlowRequest& request) const
1187 {
1188 auto task = Aws::MakeShared< std::packaged_task< RunJobFlowOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->RunJobFlow(request); } );
1189 auto packagedFunction = [task]() { (*task)(); };
1190 m_executor->Submit(packagedFunction);
1191 return task->get_future();
1192 }
1193
RunJobFlowAsync(const RunJobFlowRequest & request,const RunJobFlowResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1194 void EMRClient::RunJobFlowAsync(const RunJobFlowRequest& request, const RunJobFlowResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1195 {
1196 m_executor->Submit( [this, request, handler, context](){ this->RunJobFlowAsyncHelper( request, handler, context ); } );
1197 }
1198
RunJobFlowAsyncHelper(const RunJobFlowRequest & request,const RunJobFlowResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1199 void EMRClient::RunJobFlowAsyncHelper(const RunJobFlowRequest& request, const RunJobFlowResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1200 {
1201 handler(this, request, RunJobFlow(request), context);
1202 }
1203
SetTerminationProtection(const SetTerminationProtectionRequest & request) const1204 SetTerminationProtectionOutcome EMRClient::SetTerminationProtection(const SetTerminationProtectionRequest& request) const
1205 {
1206 Aws::Http::URI uri = m_uri;
1207 return SetTerminationProtectionOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1208 }
1209
SetTerminationProtectionCallable(const SetTerminationProtectionRequest & request) const1210 SetTerminationProtectionOutcomeCallable EMRClient::SetTerminationProtectionCallable(const SetTerminationProtectionRequest& request) const
1211 {
1212 auto task = Aws::MakeShared< std::packaged_task< SetTerminationProtectionOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->SetTerminationProtection(request); } );
1213 auto packagedFunction = [task]() { (*task)(); };
1214 m_executor->Submit(packagedFunction);
1215 return task->get_future();
1216 }
1217
SetTerminationProtectionAsync(const SetTerminationProtectionRequest & request,const SetTerminationProtectionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1218 void EMRClient::SetTerminationProtectionAsync(const SetTerminationProtectionRequest& request, const SetTerminationProtectionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1219 {
1220 m_executor->Submit( [this, request, handler, context](){ this->SetTerminationProtectionAsyncHelper( request, handler, context ); } );
1221 }
1222
SetTerminationProtectionAsyncHelper(const SetTerminationProtectionRequest & request,const SetTerminationProtectionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1223 void EMRClient::SetTerminationProtectionAsyncHelper(const SetTerminationProtectionRequest& request, const SetTerminationProtectionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1224 {
1225 handler(this, request, SetTerminationProtection(request), context);
1226 }
1227
SetVisibleToAllUsers(const SetVisibleToAllUsersRequest & request) const1228 SetVisibleToAllUsersOutcome EMRClient::SetVisibleToAllUsers(const SetVisibleToAllUsersRequest& request) const
1229 {
1230 Aws::Http::URI uri = m_uri;
1231 return SetVisibleToAllUsersOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1232 }
1233
SetVisibleToAllUsersCallable(const SetVisibleToAllUsersRequest & request) const1234 SetVisibleToAllUsersOutcomeCallable EMRClient::SetVisibleToAllUsersCallable(const SetVisibleToAllUsersRequest& request) const
1235 {
1236 auto task = Aws::MakeShared< std::packaged_task< SetVisibleToAllUsersOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->SetVisibleToAllUsers(request); } );
1237 auto packagedFunction = [task]() { (*task)(); };
1238 m_executor->Submit(packagedFunction);
1239 return task->get_future();
1240 }
1241
SetVisibleToAllUsersAsync(const SetVisibleToAllUsersRequest & request,const SetVisibleToAllUsersResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1242 void EMRClient::SetVisibleToAllUsersAsync(const SetVisibleToAllUsersRequest& request, const SetVisibleToAllUsersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1243 {
1244 m_executor->Submit( [this, request, handler, context](){ this->SetVisibleToAllUsersAsyncHelper( request, handler, context ); } );
1245 }
1246
SetVisibleToAllUsersAsyncHelper(const SetVisibleToAllUsersRequest & request,const SetVisibleToAllUsersResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1247 void EMRClient::SetVisibleToAllUsersAsyncHelper(const SetVisibleToAllUsersRequest& request, const SetVisibleToAllUsersResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1248 {
1249 handler(this, request, SetVisibleToAllUsers(request), context);
1250 }
1251
StartNotebookExecution(const StartNotebookExecutionRequest & request) const1252 StartNotebookExecutionOutcome EMRClient::StartNotebookExecution(const StartNotebookExecutionRequest& request) const
1253 {
1254 Aws::Http::URI uri = m_uri;
1255 return StartNotebookExecutionOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1256 }
1257
StartNotebookExecutionCallable(const StartNotebookExecutionRequest & request) const1258 StartNotebookExecutionOutcomeCallable EMRClient::StartNotebookExecutionCallable(const StartNotebookExecutionRequest& request) const
1259 {
1260 auto task = Aws::MakeShared< std::packaged_task< StartNotebookExecutionOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->StartNotebookExecution(request); } );
1261 auto packagedFunction = [task]() { (*task)(); };
1262 m_executor->Submit(packagedFunction);
1263 return task->get_future();
1264 }
1265
StartNotebookExecutionAsync(const StartNotebookExecutionRequest & request,const StartNotebookExecutionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1266 void EMRClient::StartNotebookExecutionAsync(const StartNotebookExecutionRequest& request, const StartNotebookExecutionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1267 {
1268 m_executor->Submit( [this, request, handler, context](){ this->StartNotebookExecutionAsyncHelper( request, handler, context ); } );
1269 }
1270
StartNotebookExecutionAsyncHelper(const StartNotebookExecutionRequest & request,const StartNotebookExecutionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1271 void EMRClient::StartNotebookExecutionAsyncHelper(const StartNotebookExecutionRequest& request, const StartNotebookExecutionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1272 {
1273 handler(this, request, StartNotebookExecution(request), context);
1274 }
1275
StopNotebookExecution(const StopNotebookExecutionRequest & request) const1276 StopNotebookExecutionOutcome EMRClient::StopNotebookExecution(const StopNotebookExecutionRequest& request) const
1277 {
1278 Aws::Http::URI uri = m_uri;
1279 return StopNotebookExecutionOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1280 }
1281
StopNotebookExecutionCallable(const StopNotebookExecutionRequest & request) const1282 StopNotebookExecutionOutcomeCallable EMRClient::StopNotebookExecutionCallable(const StopNotebookExecutionRequest& request) const
1283 {
1284 auto task = Aws::MakeShared< std::packaged_task< StopNotebookExecutionOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->StopNotebookExecution(request); } );
1285 auto packagedFunction = [task]() { (*task)(); };
1286 m_executor->Submit(packagedFunction);
1287 return task->get_future();
1288 }
1289
StopNotebookExecutionAsync(const StopNotebookExecutionRequest & request,const StopNotebookExecutionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1290 void EMRClient::StopNotebookExecutionAsync(const StopNotebookExecutionRequest& request, const StopNotebookExecutionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1291 {
1292 m_executor->Submit( [this, request, handler, context](){ this->StopNotebookExecutionAsyncHelper( request, handler, context ); } );
1293 }
1294
StopNotebookExecutionAsyncHelper(const StopNotebookExecutionRequest & request,const StopNotebookExecutionResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1295 void EMRClient::StopNotebookExecutionAsyncHelper(const StopNotebookExecutionRequest& request, const StopNotebookExecutionResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1296 {
1297 handler(this, request, StopNotebookExecution(request), context);
1298 }
1299
TerminateJobFlows(const TerminateJobFlowsRequest & request) const1300 TerminateJobFlowsOutcome EMRClient::TerminateJobFlows(const TerminateJobFlowsRequest& request) const
1301 {
1302 Aws::Http::URI uri = m_uri;
1303 return TerminateJobFlowsOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1304 }
1305
TerminateJobFlowsCallable(const TerminateJobFlowsRequest & request) const1306 TerminateJobFlowsOutcomeCallable EMRClient::TerminateJobFlowsCallable(const TerminateJobFlowsRequest& request) const
1307 {
1308 auto task = Aws::MakeShared< std::packaged_task< TerminateJobFlowsOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->TerminateJobFlows(request); } );
1309 auto packagedFunction = [task]() { (*task)(); };
1310 m_executor->Submit(packagedFunction);
1311 return task->get_future();
1312 }
1313
TerminateJobFlowsAsync(const TerminateJobFlowsRequest & request,const TerminateJobFlowsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1314 void EMRClient::TerminateJobFlowsAsync(const TerminateJobFlowsRequest& request, const TerminateJobFlowsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1315 {
1316 m_executor->Submit( [this, request, handler, context](){ this->TerminateJobFlowsAsyncHelper( request, handler, context ); } );
1317 }
1318
TerminateJobFlowsAsyncHelper(const TerminateJobFlowsRequest & request,const TerminateJobFlowsResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1319 void EMRClient::TerminateJobFlowsAsyncHelper(const TerminateJobFlowsRequest& request, const TerminateJobFlowsResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1320 {
1321 handler(this, request, TerminateJobFlows(request), context);
1322 }
1323
UpdateStudio(const UpdateStudioRequest & request) const1324 UpdateStudioOutcome EMRClient::UpdateStudio(const UpdateStudioRequest& request) const
1325 {
1326 Aws::Http::URI uri = m_uri;
1327 return UpdateStudioOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1328 }
1329
UpdateStudioCallable(const UpdateStudioRequest & request) const1330 UpdateStudioOutcomeCallable EMRClient::UpdateStudioCallable(const UpdateStudioRequest& request) const
1331 {
1332 auto task = Aws::MakeShared< std::packaged_task< UpdateStudioOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->UpdateStudio(request); } );
1333 auto packagedFunction = [task]() { (*task)(); };
1334 m_executor->Submit(packagedFunction);
1335 return task->get_future();
1336 }
1337
UpdateStudioAsync(const UpdateStudioRequest & request,const UpdateStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1338 void EMRClient::UpdateStudioAsync(const UpdateStudioRequest& request, const UpdateStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1339 {
1340 m_executor->Submit( [this, request, handler, context](){ this->UpdateStudioAsyncHelper( request, handler, context ); } );
1341 }
1342
UpdateStudioAsyncHelper(const UpdateStudioRequest & request,const UpdateStudioResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1343 void EMRClient::UpdateStudioAsyncHelper(const UpdateStudioRequest& request, const UpdateStudioResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1344 {
1345 handler(this, request, UpdateStudio(request), context);
1346 }
1347
UpdateStudioSessionMapping(const UpdateStudioSessionMappingRequest & request) const1348 UpdateStudioSessionMappingOutcome EMRClient::UpdateStudioSessionMapping(const UpdateStudioSessionMappingRequest& request) const
1349 {
1350 Aws::Http::URI uri = m_uri;
1351 return UpdateStudioSessionMappingOutcome(MakeRequest(uri, request, Aws::Http::HttpMethod::HTTP_POST, Aws::Auth::SIGV4_SIGNER));
1352 }
1353
UpdateStudioSessionMappingCallable(const UpdateStudioSessionMappingRequest & request) const1354 UpdateStudioSessionMappingOutcomeCallable EMRClient::UpdateStudioSessionMappingCallable(const UpdateStudioSessionMappingRequest& request) const
1355 {
1356 auto task = Aws::MakeShared< std::packaged_task< UpdateStudioSessionMappingOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->UpdateStudioSessionMapping(request); } );
1357 auto packagedFunction = [task]() { (*task)(); };
1358 m_executor->Submit(packagedFunction);
1359 return task->get_future();
1360 }
1361
UpdateStudioSessionMappingAsync(const UpdateStudioSessionMappingRequest & request,const UpdateStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1362 void EMRClient::UpdateStudioSessionMappingAsync(const UpdateStudioSessionMappingRequest& request, const UpdateStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1363 {
1364 m_executor->Submit( [this, request, handler, context](){ this->UpdateStudioSessionMappingAsyncHelper( request, handler, context ); } );
1365 }
1366
UpdateStudioSessionMappingAsyncHelper(const UpdateStudioSessionMappingRequest & request,const UpdateStudioSessionMappingResponseReceivedHandler & handler,const std::shared_ptr<const Aws::Client::AsyncCallerContext> & context) const1367 void EMRClient::UpdateStudioSessionMappingAsyncHelper(const UpdateStudioSessionMappingRequest& request, const UpdateStudioSessionMappingResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
1368 {
1369 handler(this, request, UpdateStudioSessionMapping(request), context);
1370 }
1371
1372