diff --git a/CHANGELOG b/CHANGELOG index 58cfd32f5..bc74d2d75 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,3 +1,6 @@ +2022-03-10 Version: 1.36.1077 +- Disabled Spark Job API. + 2022-03-09 Version: 1.36.1076 - Support modify params. diff --git a/VERSION b/VERSION index 04871c1ff..f99fbe23d 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.36.1076 \ No newline at end of file +1.36.1077 \ No newline at end of file diff --git a/dms-enterprise/CMakeLists.txt b/dms-enterprise/CMakeLists.txt index ae8ea7069..054e152e3 100644 --- a/dms-enterprise/CMakeLists.txt +++ b/dms-enterprise/CMakeLists.txt @@ -33,6 +33,8 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/CreateDataCorrectOrderResult.h include/alibabacloud/dms-enterprise/model/CreateDataCronClearOrderRequest.h include/alibabacloud/dms-enterprise/model/CreateDataCronClearOrderResult.h + include/alibabacloud/dms-enterprise/model/CreateDataExportOrderRequest.h + include/alibabacloud/dms-enterprise/model/CreateDataExportOrderResult.h include/alibabacloud/dms-enterprise/model/CreateDataImportOrderRequest.h include/alibabacloud/dms-enterprise/model/CreateDataImportOrderResult.h include/alibabacloud/dms-enterprise/model/CreateFreeLockCorrectOrderRequest.h @@ -127,14 +129,6 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/GetSQLReviewCheckResultStatusResult.h include/alibabacloud/dms-enterprise/model/GetSQLReviewOptimizeDetailRequest.h include/alibabacloud/dms-enterprise/model/GetSQLReviewOptimizeDetailResult.h - include/alibabacloud/dms-enterprise/model/GetSparkJobDetailRequest.h - include/alibabacloud/dms-enterprise/model/GetSparkJobDetailResult.h - include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogRequest.h - include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogResult.h - include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsRequest.h - include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsResult.h - include/alibabacloud/dms-enterprise/model/GetSparkJobLogRequest.h - include/alibabacloud/dms-enterprise/model/GetSparkJobLogResult.h include/alibabacloud/dms-enterprise/model/GetStructSyncExecSqlDetailRequest.h include/alibabacloud/dms-enterprise/model/GetStructSyncExecSqlDetailResult.h include/alibabacloud/dms-enterprise/model/GetStructSyncJobAnalyzeResultRequest.h @@ -157,8 +151,6 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/GrantUserPermissionResult.h include/alibabacloud/dms-enterprise/model/InspectProxyAccessSecretRequest.h include/alibabacloud/dms-enterprise/model/InspectProxyAccessSecretResult.h - include/alibabacloud/dms-enterprise/model/KillSparkJobRequest.h - include/alibabacloud/dms-enterprise/model/KillSparkJobResult.h include/alibabacloud/dms-enterprise/model/ListColumnsRequest.h include/alibabacloud/dms-enterprise/model/ListColumnsResult.h include/alibabacloud/dms-enterprise/model/ListDBTaskSQLJobRequest.h @@ -205,6 +197,8 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/ListSensitiveColumnsResult.h include/alibabacloud/dms-enterprise/model/ListSensitiveColumnsDetailRequest.h include/alibabacloud/dms-enterprise/model/ListSensitiveColumnsDetailResult.h + include/alibabacloud/dms-enterprise/model/ListStandardGroupsRequest.h + include/alibabacloud/dms-enterprise/model/ListStandardGroupsResult.h include/alibabacloud/dms-enterprise/model/ListTablesRequest.h include/alibabacloud/dms-enterprise/model/ListTablesResult.h include/alibabacloud/dms-enterprise/model/ListUserPermissionsRequest.h @@ -239,8 +233,6 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/SetOwnersResult.h include/alibabacloud/dms-enterprise/model/SubmitOrderApprovalRequest.h include/alibabacloud/dms-enterprise/model/SubmitOrderApprovalResult.h - include/alibabacloud/dms-enterprise/model/SubmitSparkJobRequest.h - include/alibabacloud/dms-enterprise/model/SubmitSparkJobResult.h include/alibabacloud/dms-enterprise/model/SubmitStructSyncOrderApprovalRequest.h include/alibabacloud/dms-enterprise/model/SubmitStructSyncOrderApprovalResult.h include/alibabacloud/dms-enterprise/model/SyncDatabaseMetaRequest.h @@ -266,6 +258,8 @@ set(dms-enterprise_src src/model/CreateDataCorrectOrderResult.cc src/model/CreateDataCronClearOrderRequest.cc src/model/CreateDataCronClearOrderResult.cc + src/model/CreateDataExportOrderRequest.cc + src/model/CreateDataExportOrderResult.cc src/model/CreateDataImportOrderRequest.cc src/model/CreateDataImportOrderResult.cc src/model/CreateFreeLockCorrectOrderRequest.cc @@ -360,14 +354,6 @@ set(dms-enterprise_src src/model/GetSQLReviewCheckResultStatusResult.cc src/model/GetSQLReviewOptimizeDetailRequest.cc src/model/GetSQLReviewOptimizeDetailResult.cc - src/model/GetSparkJobDetailRequest.cc - src/model/GetSparkJobDetailResult.cc - src/model/GetSparkJobDriverLogRequest.cc - src/model/GetSparkJobDriverLogResult.cc - src/model/GetSparkJobExecutorLogsRequest.cc - src/model/GetSparkJobExecutorLogsResult.cc - src/model/GetSparkJobLogRequest.cc - src/model/GetSparkJobLogResult.cc src/model/GetStructSyncExecSqlDetailRequest.cc src/model/GetStructSyncExecSqlDetailResult.cc src/model/GetStructSyncJobAnalyzeResultRequest.cc @@ -390,8 +376,6 @@ set(dms-enterprise_src src/model/GrantUserPermissionResult.cc src/model/InspectProxyAccessSecretRequest.cc src/model/InspectProxyAccessSecretResult.cc - src/model/KillSparkJobRequest.cc - src/model/KillSparkJobResult.cc src/model/ListColumnsRequest.cc src/model/ListColumnsResult.cc src/model/ListDBTaskSQLJobRequest.cc @@ -438,6 +422,8 @@ set(dms-enterprise_src src/model/ListSensitiveColumnsResult.cc src/model/ListSensitiveColumnsDetailRequest.cc src/model/ListSensitiveColumnsDetailResult.cc + src/model/ListStandardGroupsRequest.cc + src/model/ListStandardGroupsResult.cc src/model/ListTablesRequest.cc src/model/ListTablesResult.cc src/model/ListUserPermissionsRequest.cc @@ -472,8 +458,6 @@ set(dms-enterprise_src src/model/SetOwnersResult.cc src/model/SubmitOrderApprovalRequest.cc src/model/SubmitOrderApprovalResult.cc - src/model/SubmitSparkJobRequest.cc - src/model/SubmitSparkJobResult.cc src/model/SubmitStructSyncOrderApprovalRequest.cc src/model/SubmitStructSyncOrderApprovalResult.cc src/model/SyncDatabaseMetaRequest.cc diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h b/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h index c199293d9..a25e8005c 100644 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h @@ -34,6 +34,8 @@ #include "model/CreateDataCorrectOrderResult.h" #include "model/CreateDataCronClearOrderRequest.h" #include "model/CreateDataCronClearOrderResult.h" +#include "model/CreateDataExportOrderRequest.h" +#include "model/CreateDataExportOrderResult.h" #include "model/CreateDataImportOrderRequest.h" #include "model/CreateDataImportOrderResult.h" #include "model/CreateFreeLockCorrectOrderRequest.h" @@ -128,14 +130,6 @@ #include "model/GetSQLReviewCheckResultStatusResult.h" #include "model/GetSQLReviewOptimizeDetailRequest.h" #include "model/GetSQLReviewOptimizeDetailResult.h" -#include "model/GetSparkJobDetailRequest.h" -#include "model/GetSparkJobDetailResult.h" -#include "model/GetSparkJobDriverLogRequest.h" -#include "model/GetSparkJobDriverLogResult.h" -#include "model/GetSparkJobExecutorLogsRequest.h" -#include "model/GetSparkJobExecutorLogsResult.h" -#include "model/GetSparkJobLogRequest.h" -#include "model/GetSparkJobLogResult.h" #include "model/GetStructSyncExecSqlDetailRequest.h" #include "model/GetStructSyncExecSqlDetailResult.h" #include "model/GetStructSyncJobAnalyzeResultRequest.h" @@ -158,8 +152,6 @@ #include "model/GrantUserPermissionResult.h" #include "model/InspectProxyAccessSecretRequest.h" #include "model/InspectProxyAccessSecretResult.h" -#include "model/KillSparkJobRequest.h" -#include "model/KillSparkJobResult.h" #include "model/ListColumnsRequest.h" #include "model/ListColumnsResult.h" #include "model/ListDBTaskSQLJobRequest.h" @@ -206,6 +198,8 @@ #include "model/ListSensitiveColumnsResult.h" #include "model/ListSensitiveColumnsDetailRequest.h" #include "model/ListSensitiveColumnsDetailResult.h" +#include "model/ListStandardGroupsRequest.h" +#include "model/ListStandardGroupsResult.h" #include "model/ListTablesRequest.h" #include "model/ListTablesResult.h" #include "model/ListUserPermissionsRequest.h" @@ -240,8 +234,6 @@ #include "model/SetOwnersResult.h" #include "model/SubmitOrderApprovalRequest.h" #include "model/SubmitOrderApprovalResult.h" -#include "model/SubmitSparkJobRequest.h" -#include "model/SubmitSparkJobResult.h" #include "model/SubmitStructSyncOrderApprovalRequest.h" #include "model/SubmitStructSyncOrderApprovalResult.h" #include "model/SyncDatabaseMetaRequest.h" @@ -279,6 +271,9 @@ namespace AlibabaCloud typedef Outcome CreateDataCronClearOrderOutcome; typedef std::future CreateDataCronClearOrderOutcomeCallable; typedef std::function&)> CreateDataCronClearOrderAsyncHandler; + typedef Outcome CreateDataExportOrderOutcome; + typedef std::future CreateDataExportOrderOutcomeCallable; + typedef std::function&)> CreateDataExportOrderAsyncHandler; typedef Outcome CreateDataImportOrderOutcome; typedef std::future CreateDataImportOrderOutcomeCallable; typedef std::function&)> CreateDataImportOrderAsyncHandler; @@ -420,18 +415,6 @@ namespace AlibabaCloud typedef Outcome GetSQLReviewOptimizeDetailOutcome; typedef std::future GetSQLReviewOptimizeDetailOutcomeCallable; typedef std::function&)> GetSQLReviewOptimizeDetailAsyncHandler; - typedef Outcome GetSparkJobDetailOutcome; - typedef std::future GetSparkJobDetailOutcomeCallable; - typedef std::function&)> GetSparkJobDetailAsyncHandler; - typedef Outcome GetSparkJobDriverLogOutcome; - typedef std::future GetSparkJobDriverLogOutcomeCallable; - typedef std::function&)> GetSparkJobDriverLogAsyncHandler; - typedef Outcome GetSparkJobExecutorLogsOutcome; - typedef std::future GetSparkJobExecutorLogsOutcomeCallable; - typedef std::function&)> GetSparkJobExecutorLogsAsyncHandler; - typedef Outcome GetSparkJobLogOutcome; - typedef std::future GetSparkJobLogOutcomeCallable; - typedef std::function&)> GetSparkJobLogAsyncHandler; typedef Outcome GetStructSyncExecSqlDetailOutcome; typedef std::future GetStructSyncExecSqlDetailOutcomeCallable; typedef std::function&)> GetStructSyncExecSqlDetailAsyncHandler; @@ -465,9 +448,6 @@ namespace AlibabaCloud typedef Outcome InspectProxyAccessSecretOutcome; typedef std::future InspectProxyAccessSecretOutcomeCallable; typedef std::function&)> InspectProxyAccessSecretAsyncHandler; - typedef Outcome KillSparkJobOutcome; - typedef std::future KillSparkJobOutcomeCallable; - typedef std::function&)> KillSparkJobAsyncHandler; typedef Outcome ListColumnsOutcome; typedef std::future ListColumnsOutcomeCallable; typedef std::function&)> ListColumnsAsyncHandler; @@ -537,6 +517,9 @@ namespace AlibabaCloud typedef Outcome ListSensitiveColumnsDetailOutcome; typedef std::future ListSensitiveColumnsDetailOutcomeCallable; typedef std::function&)> ListSensitiveColumnsDetailAsyncHandler; + typedef Outcome ListStandardGroupsOutcome; + typedef std::future ListStandardGroupsOutcomeCallable; + typedef std::function&)> ListStandardGroupsAsyncHandler; typedef Outcome ListTablesOutcome; typedef std::future ListTablesOutcomeCallable; typedef std::function&)> ListTablesAsyncHandler; @@ -588,9 +571,6 @@ namespace AlibabaCloud typedef Outcome SubmitOrderApprovalOutcome; typedef std::future SubmitOrderApprovalOutcomeCallable; typedef std::function&)> SubmitOrderApprovalAsyncHandler; - typedef Outcome SubmitSparkJobOutcome; - typedef std::future SubmitSparkJobOutcomeCallable; - typedef std::function&)> SubmitSparkJobAsyncHandler; typedef Outcome SubmitStructSyncOrderApprovalOutcome; typedef std::future SubmitStructSyncOrderApprovalOutcomeCallable; typedef std::function&)> SubmitStructSyncOrderApprovalAsyncHandler; @@ -629,6 +609,9 @@ namespace AlibabaCloud CreateDataCronClearOrderOutcome createDataCronClearOrder(const Model::CreateDataCronClearOrderRequest &request)const; void createDataCronClearOrderAsync(const Model::CreateDataCronClearOrderRequest& request, const CreateDataCronClearOrderAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; CreateDataCronClearOrderOutcomeCallable createDataCronClearOrderCallable(const Model::CreateDataCronClearOrderRequest& request) const; + CreateDataExportOrderOutcome createDataExportOrder(const Model::CreateDataExportOrderRequest &request)const; + void createDataExportOrderAsync(const Model::CreateDataExportOrderRequest& request, const CreateDataExportOrderAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + CreateDataExportOrderOutcomeCallable createDataExportOrderCallable(const Model::CreateDataExportOrderRequest& request) const; CreateDataImportOrderOutcome createDataImportOrder(const Model::CreateDataImportOrderRequest &request)const; void createDataImportOrderAsync(const Model::CreateDataImportOrderRequest& request, const CreateDataImportOrderAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; CreateDataImportOrderOutcomeCallable createDataImportOrderCallable(const Model::CreateDataImportOrderRequest& request) const; @@ -770,18 +753,6 @@ namespace AlibabaCloud GetSQLReviewOptimizeDetailOutcome getSQLReviewOptimizeDetail(const Model::GetSQLReviewOptimizeDetailRequest &request)const; void getSQLReviewOptimizeDetailAsync(const Model::GetSQLReviewOptimizeDetailRequest& request, const GetSQLReviewOptimizeDetailAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetSQLReviewOptimizeDetailOutcomeCallable getSQLReviewOptimizeDetailCallable(const Model::GetSQLReviewOptimizeDetailRequest& request) const; - GetSparkJobDetailOutcome getSparkJobDetail(const Model::GetSparkJobDetailRequest &request)const; - void getSparkJobDetailAsync(const Model::GetSparkJobDetailRequest& request, const GetSparkJobDetailAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - GetSparkJobDetailOutcomeCallable getSparkJobDetailCallable(const Model::GetSparkJobDetailRequest& request) const; - GetSparkJobDriverLogOutcome getSparkJobDriverLog(const Model::GetSparkJobDriverLogRequest &request)const; - void getSparkJobDriverLogAsync(const Model::GetSparkJobDriverLogRequest& request, const GetSparkJobDriverLogAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - GetSparkJobDriverLogOutcomeCallable getSparkJobDriverLogCallable(const Model::GetSparkJobDriverLogRequest& request) const; - GetSparkJobExecutorLogsOutcome getSparkJobExecutorLogs(const Model::GetSparkJobExecutorLogsRequest &request)const; - void getSparkJobExecutorLogsAsync(const Model::GetSparkJobExecutorLogsRequest& request, const GetSparkJobExecutorLogsAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - GetSparkJobExecutorLogsOutcomeCallable getSparkJobExecutorLogsCallable(const Model::GetSparkJobExecutorLogsRequest& request) const; - GetSparkJobLogOutcome getSparkJobLog(const Model::GetSparkJobLogRequest &request)const; - void getSparkJobLogAsync(const Model::GetSparkJobLogRequest& request, const GetSparkJobLogAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - GetSparkJobLogOutcomeCallable getSparkJobLogCallable(const Model::GetSparkJobLogRequest& request) const; GetStructSyncExecSqlDetailOutcome getStructSyncExecSqlDetail(const Model::GetStructSyncExecSqlDetailRequest &request)const; void getStructSyncExecSqlDetailAsync(const Model::GetStructSyncExecSqlDetailRequest& request, const GetStructSyncExecSqlDetailAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetStructSyncExecSqlDetailOutcomeCallable getStructSyncExecSqlDetailCallable(const Model::GetStructSyncExecSqlDetailRequest& request) const; @@ -815,9 +786,6 @@ namespace AlibabaCloud InspectProxyAccessSecretOutcome inspectProxyAccessSecret(const Model::InspectProxyAccessSecretRequest &request)const; void inspectProxyAccessSecretAsync(const Model::InspectProxyAccessSecretRequest& request, const InspectProxyAccessSecretAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; InspectProxyAccessSecretOutcomeCallable inspectProxyAccessSecretCallable(const Model::InspectProxyAccessSecretRequest& request) const; - KillSparkJobOutcome killSparkJob(const Model::KillSparkJobRequest &request)const; - void killSparkJobAsync(const Model::KillSparkJobRequest& request, const KillSparkJobAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - KillSparkJobOutcomeCallable killSparkJobCallable(const Model::KillSparkJobRequest& request) const; ListColumnsOutcome listColumns(const Model::ListColumnsRequest &request)const; void listColumnsAsync(const Model::ListColumnsRequest& request, const ListColumnsAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListColumnsOutcomeCallable listColumnsCallable(const Model::ListColumnsRequest& request) const; @@ -887,6 +855,9 @@ namespace AlibabaCloud ListSensitiveColumnsDetailOutcome listSensitiveColumnsDetail(const Model::ListSensitiveColumnsDetailRequest &request)const; void listSensitiveColumnsDetailAsync(const Model::ListSensitiveColumnsDetailRequest& request, const ListSensitiveColumnsDetailAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListSensitiveColumnsDetailOutcomeCallable listSensitiveColumnsDetailCallable(const Model::ListSensitiveColumnsDetailRequest& request) const; + ListStandardGroupsOutcome listStandardGroups(const Model::ListStandardGroupsRequest &request)const; + void listStandardGroupsAsync(const Model::ListStandardGroupsRequest& request, const ListStandardGroupsAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ListStandardGroupsOutcomeCallable listStandardGroupsCallable(const Model::ListStandardGroupsRequest& request) const; ListTablesOutcome listTables(const Model::ListTablesRequest &request)const; void listTablesAsync(const Model::ListTablesRequest& request, const ListTablesAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListTablesOutcomeCallable listTablesCallable(const Model::ListTablesRequest& request) const; @@ -938,9 +909,6 @@ namespace AlibabaCloud SubmitOrderApprovalOutcome submitOrderApproval(const Model::SubmitOrderApprovalRequest &request)const; void submitOrderApprovalAsync(const Model::SubmitOrderApprovalRequest& request, const SubmitOrderApprovalAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; SubmitOrderApprovalOutcomeCallable submitOrderApprovalCallable(const Model::SubmitOrderApprovalRequest& request) const; - SubmitSparkJobOutcome submitSparkJob(const Model::SubmitSparkJobRequest &request)const; - void submitSparkJobAsync(const Model::SubmitSparkJobRequest& request, const SubmitSparkJobAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; - SubmitSparkJobOutcomeCallable submitSparkJobCallable(const Model::SubmitSparkJobRequest& request) const; SubmitStructSyncOrderApprovalOutcome submitStructSyncOrderApproval(const Model::SubmitStructSyncOrderApprovalRequest &request)const; void submitStructSyncOrderApprovalAsync(const Model::SubmitStructSyncOrderApprovalRequest& request, const SubmitStructSyncOrderApprovalAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; SubmitStructSyncOrderApprovalOutcomeCallable submitStructSyncOrderApprovalCallable(const Model::SubmitStructSyncOrderApprovalRequest& request) const; diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateDataExportOrderRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateDataExportOrderRequest.h new file mode 100644 index 000000000..8c9ef667e --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateDataExportOrderRequest.h @@ -0,0 +1,64 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dms_enterprise { +namespace Model { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT CreateDataExportOrderRequest : public RpcServiceRequest { +public: + struct Param { + std::string classify; + struct DbItemListItem { + long dbId; + bool logic; + }; + DbItemListItem dbItemListItem; + std::vector dbItemList; + std::string execSQL; + }; + CreateDataExportOrderRequest(); + ~CreateDataExportOrderRequest(); + long getTid() const; + void setTid(long tid); + std::string getAttachmentKey() const; + void setAttachmentKey(const std::string &attachmentKey); + Param getParam() const; + void setParam(const Param ¶m); + std::string getComment() const; + void setComment(const std::string &comment); + std::vector getRelatedUserList() const; + void setRelatedUserList(const std::vector &relatedUserList); + +private: + long tid_; + std::string attachmentKey_; + Param param_; + std::string comment_; + std::vector relatedUserList_; +}; +} // namespace Model +} // namespace Dms_enterprise +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/SubmitSparkJobResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateDataExportOrderResult.h similarity index 67% rename from dms-enterprise/include/alibabacloud/dms-enterprise/model/SubmitSparkJobResult.h rename to dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateDataExportOrderResult.h index 5a3194fb6..3ff58ac7f 100644 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/SubmitSparkJobResult.h +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateDataExportOrderResult.h @@ -14,8 +14,8 @@ * limitations under the License. */ -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBRESULT_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBRESULT_H_ +#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERRESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERRESULT_H_ #include #include @@ -29,29 +29,29 @@ namespace AlibabaCloud { namespace Model { - class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT SubmitSparkJobResult : public ServiceResult + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT CreateDataExportOrderResult : public ServiceResult { public: - SubmitSparkJobResult(); - explicit SubmitSparkJobResult(const std::string &payload); - ~SubmitSparkJobResult(); + CreateDataExportOrderResult(); + explicit CreateDataExportOrderResult(const std::string &payload); + ~CreateDataExportOrderResult(); + std::vector getCreateOrderResult()const; std::string getErrorCode()const; std::string getErrorMessage()const; bool getSuccess()const; - long getJobId()const; protected: void parse(const std::string &payload); private: + std::vector createOrderResult_; std::string errorCode_; std::string errorMessage_; bool success_; - long jobId_; }; } } } -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBRESULT_H_ \ No newline at end of file +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDetailRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDetailRequest.h deleted file mode 100644 index ac8e1e836..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDetailRequest.h +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDETAILREQUEST_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDETAILREQUEST_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud { -namespace Dms_enterprise { -namespace Model { -class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobDetailRequest : public RpcServiceRequest { -public: - GetSparkJobDetailRequest(); - ~GetSparkJobDetailRequest(); - long getJobId() const; - void setJobId(long jobId); - long getTid() const; - void setTid(long tid); - -private: - long jobId_; - long tid_; -}; -} // namespace Model -} // namespace Dms_enterprise -} // namespace AlibabaCloud -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDETAILREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDetailResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDetailResult.h deleted file mode 100644 index 16a23fc20..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDetailResult.h +++ /dev/null @@ -1,70 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDETAILRESULT_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDETAILRESULT_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud -{ - namespace Dms_enterprise - { - namespace Model - { - class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobDetailResult : public ServiceResult - { - public: - struct JobDetail - { - std::string status; - std::string mainClass; - std::string configuration; - std::string endTime; - std::string mainFile; - std::string arguments; - std::string beginTime; - std::string submitTime; - std::string jobId; - std::string name; - }; - - - GetSparkJobDetailResult(); - explicit GetSparkJobDetailResult(const std::string &payload); - ~GetSparkJobDetailResult(); - JobDetail getJobDetail()const; - std::string getErrorCode()const; - std::string getErrorMessage()const; - bool getSuccess()const; - - protected: - void parse(const std::string &payload); - private: - JobDetail jobDetail_; - std::string errorCode_; - std::string errorMessage_; - bool success_; - - }; - } - } -} -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDETAILRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogRequest.h deleted file mode 100644 index c115daaca..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogRequest.h +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDRIVERLOGREQUEST_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDRIVERLOGREQUEST_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud { -namespace Dms_enterprise { -namespace Model { -class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobDriverLogRequest : public RpcServiceRequest { -public: - GetSparkJobDriverLogRequest(); - ~GetSparkJobDriverLogRequest(); - long getJobId() const; - void setJobId(long jobId); - long getTid() const; - void setTid(long tid); - -private: - long jobId_; - long tid_; -}; -} // namespace Model -} // namespace Dms_enterprise -} // namespace AlibabaCloud -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDRIVERLOGREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogResult.h deleted file mode 100644 index aa2d654b5..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobDriverLogResult.h +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDRIVERLOGRESULT_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDRIVERLOGRESULT_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud -{ - namespace Dms_enterprise - { - namespace Model - { - class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobDriverLogResult : public ServiceResult - { - public: - - - GetSparkJobDriverLogResult(); - explicit GetSparkJobDriverLogResult(const std::string &payload); - ~GetSparkJobDriverLogResult(); - std::string getErrorCode()const; - std::string getErrorMessage()const; - std::string getDriverLog()const; - bool getSuccess()const; - - protected: - void parse(const std::string &payload); - private: - std::string errorCode_; - std::string errorMessage_; - std::string driverLog_; - bool success_; - - }; - } - } -} -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBDRIVERLOGRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsRequest.h deleted file mode 100644 index b79f983f5..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsRequest.h +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBEXECUTORLOGSREQUEST_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBEXECUTORLOGSREQUEST_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud { -namespace Dms_enterprise { -namespace Model { -class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobExecutorLogsRequest : public RpcServiceRequest { -public: - GetSparkJobExecutorLogsRequest(); - ~GetSparkJobExecutorLogsRequest(); - long getJobId() const; - void setJobId(long jobId); - long getTid() const; - void setTid(long tid); - -private: - long jobId_; - long tid_; -}; -} // namespace Model -} // namespace Dms_enterprise -} // namespace AlibabaCloud -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBEXECUTORLOGSREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobLogRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobLogRequest.h deleted file mode 100644 index 0c5f6397e..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobLogRequest.h +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBLOGREQUEST_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBLOGREQUEST_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud { -namespace Dms_enterprise { -namespace Model { -class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobLogRequest : public RpcServiceRequest { -public: - GetSparkJobLogRequest(); - ~GetSparkJobLogRequest(); - long getJobId() const; - void setJobId(long jobId); - long getTid() const; - void setTid(long tid); - -private: - long jobId_; - long tid_; -}; -} // namespace Model -} // namespace Dms_enterprise -} // namespace AlibabaCloud -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBLOGREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobLogResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobLogResult.h deleted file mode 100644 index 4bf8a0453..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobLogResult.h +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBLOGRESULT_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBLOGRESULT_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud -{ - namespace Dms_enterprise - { - namespace Model - { - class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobLogResult : public ServiceResult - { - public: - - - GetSparkJobLogResult(); - explicit GetSparkJobLogResult(const std::string &payload); - ~GetSparkJobLogResult(); - std::string getLog()const; - std::string getErrorCode()const; - std::string getErrorMessage()const; - bool getSuccess()const; - - protected: - void parse(const std::string &payload); - private: - std::string log_; - std::string errorCode_; - std::string errorMessage_; - bool success_; - - }; - } - } -} -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBLOGRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/KillSparkJobResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/KillSparkJobResult.h deleted file mode 100644 index 41a688be3..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/KillSparkJobResult.h +++ /dev/null @@ -1,55 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_KILLSPARKJOBRESULT_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_KILLSPARKJOBRESULT_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud -{ - namespace Dms_enterprise - { - namespace Model - { - class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT KillSparkJobResult : public ServiceResult - { - public: - - - KillSparkJobResult(); - explicit KillSparkJobResult(const std::string &payload); - ~KillSparkJobResult(); - std::string getErrorCode()const; - std::string getErrorMessage()const; - bool getSuccess()const; - - protected: - void parse(const std::string &payload); - private: - std::string errorCode_; - std::string errorMessage_; - bool success_; - - }; - } - } -} -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_KILLSPARKJOBRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/KillSparkJobRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListStandardGroupsRequest.h similarity index 70% rename from dms-enterprise/include/alibabacloud/dms-enterprise/model/KillSparkJobRequest.h rename to dms-enterprise/include/alibabacloud/dms-enterprise/model/ListStandardGroupsRequest.h index 1595478d3..8cd731e49 100644 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/KillSparkJobRequest.h +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListStandardGroupsRequest.h @@ -14,8 +14,8 @@ * limitations under the License. */ -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_KILLSPARKJOBREQUEST_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_KILLSPARKJOBREQUEST_H_ +#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTSTANDARDGROUPSREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTSTANDARDGROUPSREQUEST_H_ #include #include @@ -26,20 +26,17 @@ namespace AlibabaCloud { namespace Dms_enterprise { namespace Model { -class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT KillSparkJobRequest : public RpcServiceRequest { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListStandardGroupsRequest : public RpcServiceRequest { public: - KillSparkJobRequest(); - ~KillSparkJobRequest(); - long getJobId() const; - void setJobId(long jobId); + ListStandardGroupsRequest(); + ~ListStandardGroupsRequest(); long getTid() const; void setTid(long tid); private: - long jobId_; long tid_; }; } // namespace Model } // namespace Dms_enterprise } // namespace AlibabaCloud -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_KILLSPARKJOBREQUEST_H_ +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTSTANDARDGROUPSREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListStandardGroupsResult.h similarity index 60% rename from dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsResult.h rename to dms-enterprise/include/alibabacloud/dms-enterprise/model/ListStandardGroupsResult.h index 6ed5bdec0..917d21c7c 100644 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsResult.h +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListStandardGroupsResult.h @@ -14,8 +14,8 @@ * limitations under the License. */ -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBEXECUTORLOGSRESULT_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBEXECUTORLOGSRESULT_H_ +#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTSTANDARDGROUPSRESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTSTANDARDGROUPSRESULT_H_ #include #include @@ -29,15 +29,23 @@ namespace AlibabaCloud { namespace Model { - class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetSparkJobExecutorLogsResult : public ServiceResult + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListStandardGroupsResult : public ServiceResult { public: + struct StandardGroupListItem + { + std::string groupName; + std::string description; + long lastMenderId; + std::string groupMode; + std::string dbType; + }; - GetSparkJobExecutorLogsResult(); - explicit GetSparkJobExecutorLogsResult(const std::string &payload); - ~GetSparkJobExecutorLogsResult(); - std::vector getExecutorLogs()const; + ListStandardGroupsResult(); + explicit ListStandardGroupsResult(const std::string &payload); + ~ListStandardGroupsResult(); + std::vector getStandardGroupList()const; std::string getErrorCode()const; std::string getErrorMessage()const; bool getSuccess()const; @@ -45,7 +53,7 @@ namespace AlibabaCloud protected: void parse(const std::string &payload); private: - std::vector executorLogs_; + std::vector standardGroupList_; std::string errorCode_; std::string errorMessage_; bool success_; @@ -54,4 +62,4 @@ namespace AlibabaCloud } } } -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBEXECUTORLOGSRESULT_H_ \ No newline at end of file +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTSTANDARDGROUPSRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/SubmitSparkJobRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/SubmitSparkJobRequest.h deleted file mode 100644 index 37979c9d7..000000000 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/SubmitSparkJobRequest.h +++ /dev/null @@ -1,71 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBREQUEST_H_ -#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBREQUEST_H_ - -#include -#include -#include -#include -#include - -namespace AlibabaCloud { -namespace Dms_enterprise { -namespace Model { -class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT SubmitSparkJobRequest : public RpcServiceRequest { -public: - struct OssInfo { - std::string endpoint; - std::string accessKeySecret; - std::string accessKeyId; - }; - SubmitSparkJobRequest(); - ~SubmitSparkJobRequest(); - std::string getMainClass() const; - void setMainClass(const std::string &mainClass); - std::map getConfiguration() const; - void setConfiguration(const std::map &configuration); - OssInfo getOssInfo() const; - void setOssInfo(const OssInfo &ossInfo); - long getTid() const; - void setTid(long tid); - std::string getMainFile() const; - void setMainFile(const std::string &mainFile); - std::string getName() const; - void setName(const std::string &name); - std::vector getFiles() const; - void setFiles(const std::vector &files); - std::string getAppCode() const; - void setAppCode(const std::string &appCode); - std::vector getArguments() const; - void setArguments(const std::vector &arguments); - -private: - std::string mainClass_; - std::map configuration_; - OssInfo ossInfo_; - long tid_; - std::string mainFile_; - std::string name_; - std::vector files_; - std::string appCode_; - std::vector arguments_; -}; -} // namespace Model -} // namespace Dms_enterprise -} // namespace AlibabaCloud -#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBREQUEST_H_ diff --git a/dms-enterprise/src/Dms-enterpriseClient.cc b/dms-enterprise/src/Dms-enterpriseClient.cc index f2b99f481..5baeada82 100644 --- a/dms-enterprise/src/Dms-enterpriseClient.cc +++ b/dms-enterprise/src/Dms-enterpriseClient.cc @@ -267,6 +267,42 @@ Dms_enterpriseClient::CreateDataCronClearOrderOutcomeCallable Dms_enterpriseClie return task->get_future(); } +Dms_enterpriseClient::CreateDataExportOrderOutcome Dms_enterpriseClient::createDataExportOrder(const CreateDataExportOrderRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return CreateDataExportOrderOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return CreateDataExportOrderOutcome(CreateDataExportOrderResult(outcome.result())); + else + return CreateDataExportOrderOutcome(outcome.error()); +} + +void Dms_enterpriseClient::createDataExportOrderAsync(const CreateDataExportOrderRequest& request, const CreateDataExportOrderAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, createDataExportOrder(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::CreateDataExportOrderOutcomeCallable Dms_enterpriseClient::createDataExportOrderCallable(const CreateDataExportOrderRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->createDataExportOrder(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dms_enterpriseClient::CreateDataImportOrderOutcome Dms_enterpriseClient::createDataImportOrder(const CreateDataImportOrderRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1959,150 +1995,6 @@ Dms_enterpriseClient::GetSQLReviewOptimizeDetailOutcomeCallable Dms_enterpriseCl return task->get_future(); } -Dms_enterpriseClient::GetSparkJobDetailOutcome Dms_enterpriseClient::getSparkJobDetail(const GetSparkJobDetailRequest &request) const -{ - auto endpointOutcome = endpointProvider_->getEndpoint(); - if (!endpointOutcome.isSuccess()) - return GetSparkJobDetailOutcome(endpointOutcome.error()); - - auto outcome = makeRequest(endpointOutcome.result(), request); - - if (outcome.isSuccess()) - return GetSparkJobDetailOutcome(GetSparkJobDetailResult(outcome.result())); - else - return GetSparkJobDetailOutcome(outcome.error()); -} - -void Dms_enterpriseClient::getSparkJobDetailAsync(const GetSparkJobDetailRequest& request, const GetSparkJobDetailAsyncHandler& handler, const std::shared_ptr& context) const -{ - auto fn = [this, request, handler, context]() - { - handler(this, request, getSparkJobDetail(request), context); - }; - - asyncExecute(new Runnable(fn)); -} - -Dms_enterpriseClient::GetSparkJobDetailOutcomeCallable Dms_enterpriseClient::getSparkJobDetailCallable(const GetSparkJobDetailRequest &request) const -{ - auto task = std::make_shared>( - [this, request]() - { - return this->getSparkJobDetail(request); - }); - - asyncExecute(new Runnable([task]() { (*task)(); })); - return task->get_future(); -} - -Dms_enterpriseClient::GetSparkJobDriverLogOutcome Dms_enterpriseClient::getSparkJobDriverLog(const GetSparkJobDriverLogRequest &request) const -{ - auto endpointOutcome = endpointProvider_->getEndpoint(); - if (!endpointOutcome.isSuccess()) - return GetSparkJobDriverLogOutcome(endpointOutcome.error()); - - auto outcome = makeRequest(endpointOutcome.result(), request); - - if (outcome.isSuccess()) - return GetSparkJobDriverLogOutcome(GetSparkJobDriverLogResult(outcome.result())); - else - return GetSparkJobDriverLogOutcome(outcome.error()); -} - -void Dms_enterpriseClient::getSparkJobDriverLogAsync(const GetSparkJobDriverLogRequest& request, const GetSparkJobDriverLogAsyncHandler& handler, const std::shared_ptr& context) const -{ - auto fn = [this, request, handler, context]() - { - handler(this, request, getSparkJobDriverLog(request), context); - }; - - asyncExecute(new Runnable(fn)); -} - -Dms_enterpriseClient::GetSparkJobDriverLogOutcomeCallable Dms_enterpriseClient::getSparkJobDriverLogCallable(const GetSparkJobDriverLogRequest &request) const -{ - auto task = std::make_shared>( - [this, request]() - { - return this->getSparkJobDriverLog(request); - }); - - asyncExecute(new Runnable([task]() { (*task)(); })); - return task->get_future(); -} - -Dms_enterpriseClient::GetSparkJobExecutorLogsOutcome Dms_enterpriseClient::getSparkJobExecutorLogs(const GetSparkJobExecutorLogsRequest &request) const -{ - auto endpointOutcome = endpointProvider_->getEndpoint(); - if (!endpointOutcome.isSuccess()) - return GetSparkJobExecutorLogsOutcome(endpointOutcome.error()); - - auto outcome = makeRequest(endpointOutcome.result(), request); - - if (outcome.isSuccess()) - return GetSparkJobExecutorLogsOutcome(GetSparkJobExecutorLogsResult(outcome.result())); - else - return GetSparkJobExecutorLogsOutcome(outcome.error()); -} - -void Dms_enterpriseClient::getSparkJobExecutorLogsAsync(const GetSparkJobExecutorLogsRequest& request, const GetSparkJobExecutorLogsAsyncHandler& handler, const std::shared_ptr& context) const -{ - auto fn = [this, request, handler, context]() - { - handler(this, request, getSparkJobExecutorLogs(request), context); - }; - - asyncExecute(new Runnable(fn)); -} - -Dms_enterpriseClient::GetSparkJobExecutorLogsOutcomeCallable Dms_enterpriseClient::getSparkJobExecutorLogsCallable(const GetSparkJobExecutorLogsRequest &request) const -{ - auto task = std::make_shared>( - [this, request]() - { - return this->getSparkJobExecutorLogs(request); - }); - - asyncExecute(new Runnable([task]() { (*task)(); })); - return task->get_future(); -} - -Dms_enterpriseClient::GetSparkJobLogOutcome Dms_enterpriseClient::getSparkJobLog(const GetSparkJobLogRequest &request) const -{ - auto endpointOutcome = endpointProvider_->getEndpoint(); - if (!endpointOutcome.isSuccess()) - return GetSparkJobLogOutcome(endpointOutcome.error()); - - auto outcome = makeRequest(endpointOutcome.result(), request); - - if (outcome.isSuccess()) - return GetSparkJobLogOutcome(GetSparkJobLogResult(outcome.result())); - else - return GetSparkJobLogOutcome(outcome.error()); -} - -void Dms_enterpriseClient::getSparkJobLogAsync(const GetSparkJobLogRequest& request, const GetSparkJobLogAsyncHandler& handler, const std::shared_ptr& context) const -{ - auto fn = [this, request, handler, context]() - { - handler(this, request, getSparkJobLog(request), context); - }; - - asyncExecute(new Runnable(fn)); -} - -Dms_enterpriseClient::GetSparkJobLogOutcomeCallable Dms_enterpriseClient::getSparkJobLogCallable(const GetSparkJobLogRequest &request) const -{ - auto task = std::make_shared>( - [this, request]() - { - return this->getSparkJobLog(request); - }); - - asyncExecute(new Runnable([task]() { (*task)(); })); - return task->get_future(); -} - Dms_enterpriseClient::GetStructSyncExecSqlDetailOutcome Dms_enterpriseClient::getStructSyncExecSqlDetail(const GetStructSyncExecSqlDetailRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -2499,42 +2391,6 @@ Dms_enterpriseClient::InspectProxyAccessSecretOutcomeCallable Dms_enterpriseClie return task->get_future(); } -Dms_enterpriseClient::KillSparkJobOutcome Dms_enterpriseClient::killSparkJob(const KillSparkJobRequest &request) const -{ - auto endpointOutcome = endpointProvider_->getEndpoint(); - if (!endpointOutcome.isSuccess()) - return KillSparkJobOutcome(endpointOutcome.error()); - - auto outcome = makeRequest(endpointOutcome.result(), request); - - if (outcome.isSuccess()) - return KillSparkJobOutcome(KillSparkJobResult(outcome.result())); - else - return KillSparkJobOutcome(outcome.error()); -} - -void Dms_enterpriseClient::killSparkJobAsync(const KillSparkJobRequest& request, const KillSparkJobAsyncHandler& handler, const std::shared_ptr& context) const -{ - auto fn = [this, request, handler, context]() - { - handler(this, request, killSparkJob(request), context); - }; - - asyncExecute(new Runnable(fn)); -} - -Dms_enterpriseClient::KillSparkJobOutcomeCallable Dms_enterpriseClient::killSparkJobCallable(const KillSparkJobRequest &request) const -{ - auto task = std::make_shared>( - [this, request]() - { - return this->killSparkJob(request); - }); - - asyncExecute(new Runnable([task]() { (*task)(); })); - return task->get_future(); -} - Dms_enterpriseClient::ListColumnsOutcome Dms_enterpriseClient::listColumns(const ListColumnsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -3363,6 +3219,42 @@ Dms_enterpriseClient::ListSensitiveColumnsDetailOutcomeCallable Dms_enterpriseCl return task->get_future(); } +Dms_enterpriseClient::ListStandardGroupsOutcome Dms_enterpriseClient::listStandardGroups(const ListStandardGroupsRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ListStandardGroupsOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ListStandardGroupsOutcome(ListStandardGroupsResult(outcome.result())); + else + return ListStandardGroupsOutcome(outcome.error()); +} + +void Dms_enterpriseClient::listStandardGroupsAsync(const ListStandardGroupsRequest& request, const ListStandardGroupsAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, listStandardGroups(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::ListStandardGroupsOutcomeCallable Dms_enterpriseClient::listStandardGroupsCallable(const ListStandardGroupsRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->listStandardGroups(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dms_enterpriseClient::ListTablesOutcome Dms_enterpriseClient::listTables(const ListTablesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -3975,42 +3867,6 @@ Dms_enterpriseClient::SubmitOrderApprovalOutcomeCallable Dms_enterpriseClient::s return task->get_future(); } -Dms_enterpriseClient::SubmitSparkJobOutcome Dms_enterpriseClient::submitSparkJob(const SubmitSparkJobRequest &request) const -{ - auto endpointOutcome = endpointProvider_->getEndpoint(); - if (!endpointOutcome.isSuccess()) - return SubmitSparkJobOutcome(endpointOutcome.error()); - - auto outcome = makeRequest(endpointOutcome.result(), request); - - if (outcome.isSuccess()) - return SubmitSparkJobOutcome(SubmitSparkJobResult(outcome.result())); - else - return SubmitSparkJobOutcome(outcome.error()); -} - -void Dms_enterpriseClient::submitSparkJobAsync(const SubmitSparkJobRequest& request, const SubmitSparkJobAsyncHandler& handler, const std::shared_ptr& context) const -{ - auto fn = [this, request, handler, context]() - { - handler(this, request, submitSparkJob(request), context); - }; - - asyncExecute(new Runnable(fn)); -} - -Dms_enterpriseClient::SubmitSparkJobOutcomeCallable Dms_enterpriseClient::submitSparkJobCallable(const SubmitSparkJobRequest &request) const -{ - auto task = std::make_shared>( - [this, request]() - { - return this->submitSparkJob(request); - }); - - asyncExecute(new Runnable([task]() { (*task)(); })); - return task->get_future(); -} - Dms_enterpriseClient::SubmitStructSyncOrderApprovalOutcome Dms_enterpriseClient::submitStructSyncOrderApproval(const SubmitStructSyncOrderApprovalRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); diff --git a/dms-enterprise/src/model/CreateDataExportOrderRequest.cc b/dms-enterprise/src/model/CreateDataExportOrderRequest.cc new file mode 100644 index 000000000..4fdca2c98 --- /dev/null +++ b/dms-enterprise/src/model/CreateDataExportOrderRequest.cc @@ -0,0 +1,79 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +using AlibabaCloud::Dms_enterprise::Model::CreateDataExportOrderRequest; + +CreateDataExportOrderRequest::CreateDataExportOrderRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "CreateDataExportOrder") { + setMethod(HttpRequest::Method::Post); +} + +CreateDataExportOrderRequest::~CreateDataExportOrderRequest() {} + +long CreateDataExportOrderRequest::getTid() const { + return tid_; +} + +void CreateDataExportOrderRequest::setTid(long tid) { + tid_ = tid; + setParameter(std::string("Tid"), std::to_string(tid)); +} + +std::string CreateDataExportOrderRequest::getAttachmentKey() const { + return attachmentKey_; +} + +void CreateDataExportOrderRequest::setAttachmentKey(const std::string &attachmentKey) { + attachmentKey_ = attachmentKey; + setParameter(std::string("AttachmentKey"), attachmentKey); +} + +CreateDataExportOrderRequest::Param CreateDataExportOrderRequest::getParam() const { + return param_; +} + +void CreateDataExportOrderRequest::setParam(const CreateDataExportOrderRequest::Param ¶m) { + param_ = param; + setParameter(std::string("Param") + ".Classify", param.classify); + for(int dep1 = 0; dep1 != param.dbItemList.size(); dep1++) { + setParameter(std::string("Param") + ".DbItemList." + std::to_string(dep1 + 1) + ".DbId", std::to_string(param.dbItemList[dep1].dbId)); + setParameter(std::string("Param") + ".DbItemList." + std::to_string(dep1 + 1) + ".Logic", param.dbItemList[dep1].logic ? "true" : "false"); + } + setParameter(std::string("Param") + ".ExecSQL", param.execSQL); +} + +std::string CreateDataExportOrderRequest::getComment() const { + return comment_; +} + +void CreateDataExportOrderRequest::setComment(const std::string &comment) { + comment_ = comment; + setParameter(std::string("Comment"), comment); +} + +std::vector CreateDataExportOrderRequest::getRelatedUserList() const { + return relatedUserList_; +} + +void CreateDataExportOrderRequest::setRelatedUserList(const std::vector &relatedUserList) { + relatedUserList_ = relatedUserList; + for(int dep1 = 0; dep1 != relatedUserList.size(); dep1++) { + setParameter(std::string("RelatedUserList") + "." + std::to_string(dep1 + 1), std::to_string(relatedUserList[dep1])); + } +} + diff --git a/dms-enterprise/src/model/SubmitSparkJobResult.cc b/dms-enterprise/src/model/CreateDataExportOrderResult.cc similarity index 61% rename from dms-enterprise/src/model/SubmitSparkJobResult.cc rename to dms-enterprise/src/model/CreateDataExportOrderResult.cc index 96b840264..aab9ad3c2 100644 --- a/dms-enterprise/src/model/SubmitSparkJobResult.cc +++ b/dms-enterprise/src/model/CreateDataExportOrderResult.cc @@ -14,59 +14,60 @@ * limitations under the License. */ -#include +#include #include using namespace AlibabaCloud::Dms_enterprise; using namespace AlibabaCloud::Dms_enterprise::Model; -SubmitSparkJobResult::SubmitSparkJobResult() : +CreateDataExportOrderResult::CreateDataExportOrderResult() : ServiceResult() {} -SubmitSparkJobResult::SubmitSparkJobResult(const std::string &payload) : +CreateDataExportOrderResult::CreateDataExportOrderResult(const std::string &payload) : ServiceResult() { parse(payload); } -SubmitSparkJobResult::~SubmitSparkJobResult() +CreateDataExportOrderResult::~CreateDataExportOrderResult() {} -void SubmitSparkJobResult::parse(const std::string &payload) +void CreateDataExportOrderResult::parse(const std::string &payload) { Json::Reader reader; Json::Value value; reader.parse(payload, value); setRequestId(value["RequestId"].asString()); + auto allCreateOrderResult = value["CreateOrderResult"]["OrderIds"]; + for (const auto &item : allCreateOrderResult) + createOrderResult_.push_back(item.asString()); if(!value["Success"].isNull()) success_ = value["Success"].asString() == "true"; if(!value["ErrorMessage"].isNull()) errorMessage_ = value["ErrorMessage"].asString(); if(!value["ErrorCode"].isNull()) errorCode_ = value["ErrorCode"].asString(); - if(!value["JobId"].isNull()) - jobId_ = std::stol(value["JobId"].asString()); } -std::string SubmitSparkJobResult::getErrorCode()const +std::vector CreateDataExportOrderResult::getCreateOrderResult()const +{ + return createOrderResult_; +} + +std::string CreateDataExportOrderResult::getErrorCode()const { return errorCode_; } -std::string SubmitSparkJobResult::getErrorMessage()const +std::string CreateDataExportOrderResult::getErrorMessage()const { return errorMessage_; } -bool SubmitSparkJobResult::getSuccess()const +bool CreateDataExportOrderResult::getSuccess()const { return success_; } -long SubmitSparkJobResult::getJobId()const -{ - return jobId_; -} - diff --git a/dms-enterprise/src/model/GetSparkJobDetailRequest.cc b/dms-enterprise/src/model/GetSparkJobDetailRequest.cc deleted file mode 100644 index 827f6dcd5..000000000 --- a/dms-enterprise/src/model/GetSparkJobDetailRequest.cc +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include - -using AlibabaCloud::Dms_enterprise::Model::GetSparkJobDetailRequest; - -GetSparkJobDetailRequest::GetSparkJobDetailRequest() - : RpcServiceRequest("dms-enterprise", "2018-11-01", "GetSparkJobDetail") { - setMethod(HttpRequest::Method::Post); -} - -GetSparkJobDetailRequest::~GetSparkJobDetailRequest() {} - -long GetSparkJobDetailRequest::getJobId() const { - return jobId_; -} - -void GetSparkJobDetailRequest::setJobId(long jobId) { - jobId_ = jobId; - setParameter(std::string("JobId"), std::to_string(jobId)); -} - -long GetSparkJobDetailRequest::getTid() const { - return tid_; -} - -void GetSparkJobDetailRequest::setTid(long tid) { - tid_ = tid; - setParameter(std::string("Tid"), std::to_string(tid)); -} - diff --git a/dms-enterprise/src/model/GetSparkJobDetailResult.cc b/dms-enterprise/src/model/GetSparkJobDetailResult.cc deleted file mode 100644 index 2494cbf57..000000000 --- a/dms-enterprise/src/model/GetSparkJobDetailResult.cc +++ /dev/null @@ -1,91 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include -#include - -using namespace AlibabaCloud::Dms_enterprise; -using namespace AlibabaCloud::Dms_enterprise::Model; - -GetSparkJobDetailResult::GetSparkJobDetailResult() : - ServiceResult() -{} - -GetSparkJobDetailResult::GetSparkJobDetailResult(const std::string &payload) : - ServiceResult() -{ - parse(payload); -} - -GetSparkJobDetailResult::~GetSparkJobDetailResult() -{} - -void GetSparkJobDetailResult::parse(const std::string &payload) -{ - Json::Reader reader; - Json::Value value; - reader.parse(payload, value); - setRequestId(value["RequestId"].asString()); - auto jobDetailNode = value["JobDetail"]; - if(!jobDetailNode["JobId"].isNull()) - jobDetail_.jobId = jobDetailNode["JobId"].asString(); - if(!jobDetailNode["Name"].isNull()) - jobDetail_.name = jobDetailNode["Name"].asString(); - if(!jobDetailNode["Status"].isNull()) - jobDetail_.status = jobDetailNode["Status"].asString(); - if(!jobDetailNode["MainClass"].isNull()) - jobDetail_.mainClass = jobDetailNode["MainClass"].asString(); - if(!jobDetailNode["MainFile"].isNull()) - jobDetail_.mainFile = jobDetailNode["MainFile"].asString(); - if(!jobDetailNode["Arguments"].isNull()) - jobDetail_.arguments = jobDetailNode["Arguments"].asString(); - if(!jobDetailNode["Configuration"].isNull()) - jobDetail_.configuration = jobDetailNode["Configuration"].asString(); - if(!jobDetailNode["SubmitTime"].isNull()) - jobDetail_.submitTime = jobDetailNode["SubmitTime"].asString(); - if(!jobDetailNode["BeginTime"].isNull()) - jobDetail_.beginTime = jobDetailNode["BeginTime"].asString(); - if(!jobDetailNode["EndTime"].isNull()) - jobDetail_.endTime = jobDetailNode["EndTime"].asString(); - if(!value["Success"].isNull()) - success_ = value["Success"].asString() == "true"; - if(!value["ErrorMessage"].isNull()) - errorMessage_ = value["ErrorMessage"].asString(); - if(!value["ErrorCode"].isNull()) - errorCode_ = value["ErrorCode"].asString(); - -} - -GetSparkJobDetailResult::JobDetail GetSparkJobDetailResult::getJobDetail()const -{ - return jobDetail_; -} - -std::string GetSparkJobDetailResult::getErrorCode()const -{ - return errorCode_; -} - -std::string GetSparkJobDetailResult::getErrorMessage()const -{ - return errorMessage_; -} - -bool GetSparkJobDetailResult::getSuccess()const -{ - return success_; -} - diff --git a/dms-enterprise/src/model/GetSparkJobDriverLogRequest.cc b/dms-enterprise/src/model/GetSparkJobDriverLogRequest.cc deleted file mode 100644 index 892b61e68..000000000 --- a/dms-enterprise/src/model/GetSparkJobDriverLogRequest.cc +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include - -using AlibabaCloud::Dms_enterprise::Model::GetSparkJobDriverLogRequest; - -GetSparkJobDriverLogRequest::GetSparkJobDriverLogRequest() - : RpcServiceRequest("dms-enterprise", "2018-11-01", "GetSparkJobDriverLog") { - setMethod(HttpRequest::Method::Post); -} - -GetSparkJobDriverLogRequest::~GetSparkJobDriverLogRequest() {} - -long GetSparkJobDriverLogRequest::getJobId() const { - return jobId_; -} - -void GetSparkJobDriverLogRequest::setJobId(long jobId) { - jobId_ = jobId; - setParameter(std::string("JobId"), std::to_string(jobId)); -} - -long GetSparkJobDriverLogRequest::getTid() const { - return tid_; -} - -void GetSparkJobDriverLogRequest::setTid(long tid) { - tid_ = tid; - setParameter(std::string("Tid"), std::to_string(tid)); -} - diff --git a/dms-enterprise/src/model/GetSparkJobDriverLogResult.cc b/dms-enterprise/src/model/GetSparkJobDriverLogResult.cc deleted file mode 100644 index c8807ceef..000000000 --- a/dms-enterprise/src/model/GetSparkJobDriverLogResult.cc +++ /dev/null @@ -1,72 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include -#include - -using namespace AlibabaCloud::Dms_enterprise; -using namespace AlibabaCloud::Dms_enterprise::Model; - -GetSparkJobDriverLogResult::GetSparkJobDriverLogResult() : - ServiceResult() -{} - -GetSparkJobDriverLogResult::GetSparkJobDriverLogResult(const std::string &payload) : - ServiceResult() -{ - parse(payload); -} - -GetSparkJobDriverLogResult::~GetSparkJobDriverLogResult() -{} - -void GetSparkJobDriverLogResult::parse(const std::string &payload) -{ - Json::Reader reader; - Json::Value value; - reader.parse(payload, value); - setRequestId(value["RequestId"].asString()); - if(!value["Success"].isNull()) - success_ = value["Success"].asString() == "true"; - if(!value["ErrorMessage"].isNull()) - errorMessage_ = value["ErrorMessage"].asString(); - if(!value["ErrorCode"].isNull()) - errorCode_ = value["ErrorCode"].asString(); - if(!value["DriverLog"].isNull()) - driverLog_ = value["DriverLog"].asString(); - -} - -std::string GetSparkJobDriverLogResult::getErrorCode()const -{ - return errorCode_; -} - -std::string GetSparkJobDriverLogResult::getErrorMessage()const -{ - return errorMessage_; -} - -std::string GetSparkJobDriverLogResult::getDriverLog()const -{ - return driverLog_; -} - -bool GetSparkJobDriverLogResult::getSuccess()const -{ - return success_; -} - diff --git a/dms-enterprise/src/model/GetSparkJobExecutorLogsRequest.cc b/dms-enterprise/src/model/GetSparkJobExecutorLogsRequest.cc deleted file mode 100644 index 8431f570a..000000000 --- a/dms-enterprise/src/model/GetSparkJobExecutorLogsRequest.cc +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include - -using AlibabaCloud::Dms_enterprise::Model::GetSparkJobExecutorLogsRequest; - -GetSparkJobExecutorLogsRequest::GetSparkJobExecutorLogsRequest() - : RpcServiceRequest("dms-enterprise", "2018-11-01", "GetSparkJobExecutorLogs") { - setMethod(HttpRequest::Method::Post); -} - -GetSparkJobExecutorLogsRequest::~GetSparkJobExecutorLogsRequest() {} - -long GetSparkJobExecutorLogsRequest::getJobId() const { - return jobId_; -} - -void GetSparkJobExecutorLogsRequest::setJobId(long jobId) { - jobId_ = jobId; - setParameter(std::string("JobId"), std::to_string(jobId)); -} - -long GetSparkJobExecutorLogsRequest::getTid() const { - return tid_; -} - -void GetSparkJobExecutorLogsRequest::setTid(long tid) { - tid_ = tid; - setParameter(std::string("Tid"), std::to_string(tid)); -} - diff --git a/dms-enterprise/src/model/GetSparkJobExecutorLogsResult.cc b/dms-enterprise/src/model/GetSparkJobExecutorLogsResult.cc deleted file mode 100644 index 2bb66d61d..000000000 --- a/dms-enterprise/src/model/GetSparkJobExecutorLogsResult.cc +++ /dev/null @@ -1,73 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include -#include - -using namespace AlibabaCloud::Dms_enterprise; -using namespace AlibabaCloud::Dms_enterprise::Model; - -GetSparkJobExecutorLogsResult::GetSparkJobExecutorLogsResult() : - ServiceResult() -{} - -GetSparkJobExecutorLogsResult::GetSparkJobExecutorLogsResult(const std::string &payload) : - ServiceResult() -{ - parse(payload); -} - -GetSparkJobExecutorLogsResult::~GetSparkJobExecutorLogsResult() -{} - -void GetSparkJobExecutorLogsResult::parse(const std::string &payload) -{ - Json::Reader reader; - Json::Value value; - reader.parse(payload, value); - setRequestId(value["RequestId"].asString()); - auto allExecutorLogs = value["ExecutorLogs"]["executorLogs"]; - for (const auto &item : allExecutorLogs) - executorLogs_.push_back(item.asString()); - if(!value["Success"].isNull()) - success_ = value["Success"].asString() == "true"; - if(!value["ErrorMessage"].isNull()) - errorMessage_ = value["ErrorMessage"].asString(); - if(!value["ErrorCode"].isNull()) - errorCode_ = value["ErrorCode"].asString(); - -} - -std::vector GetSparkJobExecutorLogsResult::getExecutorLogs()const -{ - return executorLogs_; -} - -std::string GetSparkJobExecutorLogsResult::getErrorCode()const -{ - return errorCode_; -} - -std::string GetSparkJobExecutorLogsResult::getErrorMessage()const -{ - return errorMessage_; -} - -bool GetSparkJobExecutorLogsResult::getSuccess()const -{ - return success_; -} - diff --git a/dms-enterprise/src/model/GetSparkJobLogRequest.cc b/dms-enterprise/src/model/GetSparkJobLogRequest.cc deleted file mode 100644 index 1f3ed9509..000000000 --- a/dms-enterprise/src/model/GetSparkJobLogRequest.cc +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include - -using AlibabaCloud::Dms_enterprise::Model::GetSparkJobLogRequest; - -GetSparkJobLogRequest::GetSparkJobLogRequest() - : RpcServiceRequest("dms-enterprise", "2018-11-01", "GetSparkJobLog") { - setMethod(HttpRequest::Method::Post); -} - -GetSparkJobLogRequest::~GetSparkJobLogRequest() {} - -long GetSparkJobLogRequest::getJobId() const { - return jobId_; -} - -void GetSparkJobLogRequest::setJobId(long jobId) { - jobId_ = jobId; - setParameter(std::string("JobId"), std::to_string(jobId)); -} - -long GetSparkJobLogRequest::getTid() const { - return tid_; -} - -void GetSparkJobLogRequest::setTid(long tid) { - tid_ = tid; - setParameter(std::string("Tid"), std::to_string(tid)); -} - diff --git a/dms-enterprise/src/model/GetSparkJobLogResult.cc b/dms-enterprise/src/model/GetSparkJobLogResult.cc deleted file mode 100644 index 469693960..000000000 --- a/dms-enterprise/src/model/GetSparkJobLogResult.cc +++ /dev/null @@ -1,72 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include -#include - -using namespace AlibabaCloud::Dms_enterprise; -using namespace AlibabaCloud::Dms_enterprise::Model; - -GetSparkJobLogResult::GetSparkJobLogResult() : - ServiceResult() -{} - -GetSparkJobLogResult::GetSparkJobLogResult(const std::string &payload) : - ServiceResult() -{ - parse(payload); -} - -GetSparkJobLogResult::~GetSparkJobLogResult() -{} - -void GetSparkJobLogResult::parse(const std::string &payload) -{ - Json::Reader reader; - Json::Value value; - reader.parse(payload, value); - setRequestId(value["RequestId"].asString()); - if(!value["Success"].isNull()) - success_ = value["Success"].asString() == "true"; - if(!value["ErrorMessage"].isNull()) - errorMessage_ = value["ErrorMessage"].asString(); - if(!value["ErrorCode"].isNull()) - errorCode_ = value["ErrorCode"].asString(); - if(!value["Log"].isNull()) - log_ = value["Log"].asString(); - -} - -std::string GetSparkJobLogResult::getLog()const -{ - return log_; -} - -std::string GetSparkJobLogResult::getErrorCode()const -{ - return errorCode_; -} - -std::string GetSparkJobLogResult::getErrorMessage()const -{ - return errorMessage_; -} - -bool GetSparkJobLogResult::getSuccess()const -{ - return success_; -} - diff --git a/dms-enterprise/src/model/KillSparkJobResult.cc b/dms-enterprise/src/model/KillSparkJobResult.cc deleted file mode 100644 index aca2fe9da..000000000 --- a/dms-enterprise/src/model/KillSparkJobResult.cc +++ /dev/null @@ -1,65 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include -#include - -using namespace AlibabaCloud::Dms_enterprise; -using namespace AlibabaCloud::Dms_enterprise::Model; - -KillSparkJobResult::KillSparkJobResult() : - ServiceResult() -{} - -KillSparkJobResult::KillSparkJobResult(const std::string &payload) : - ServiceResult() -{ - parse(payload); -} - -KillSparkJobResult::~KillSparkJobResult() -{} - -void KillSparkJobResult::parse(const std::string &payload) -{ - Json::Reader reader; - Json::Value value; - reader.parse(payload, value); - setRequestId(value["RequestId"].asString()); - if(!value["Success"].isNull()) - success_ = value["Success"].asString() == "true"; - if(!value["ErrorMessage"].isNull()) - errorMessage_ = value["ErrorMessage"].asString(); - if(!value["ErrorCode"].isNull()) - errorCode_ = value["ErrorCode"].asString(); - -} - -std::string KillSparkJobResult::getErrorCode()const -{ - return errorCode_; -} - -std::string KillSparkJobResult::getErrorMessage()const -{ - return errorMessage_; -} - -bool KillSparkJobResult::getSuccess()const -{ - return success_; -} - diff --git a/dms-enterprise/src/model/KillSparkJobRequest.cc b/dms-enterprise/src/model/ListStandardGroupsRequest.cc similarity index 55% rename from dms-enterprise/src/model/KillSparkJobRequest.cc rename to dms-enterprise/src/model/ListStandardGroupsRequest.cc index 7eecabef5..cc06715cd 100644 --- a/dms-enterprise/src/model/KillSparkJobRequest.cc +++ b/dms-enterprise/src/model/ListStandardGroupsRequest.cc @@ -14,31 +14,22 @@ * limitations under the License. */ -#include +#include -using AlibabaCloud::Dms_enterprise::Model::KillSparkJobRequest; +using AlibabaCloud::Dms_enterprise::Model::ListStandardGroupsRequest; -KillSparkJobRequest::KillSparkJobRequest() - : RpcServiceRequest("dms-enterprise", "2018-11-01", "KillSparkJob") { +ListStandardGroupsRequest::ListStandardGroupsRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "ListStandardGroups") { setMethod(HttpRequest::Method::Post); } -KillSparkJobRequest::~KillSparkJobRequest() {} +ListStandardGroupsRequest::~ListStandardGroupsRequest() {} -long KillSparkJobRequest::getJobId() const { - return jobId_; -} - -void KillSparkJobRequest::setJobId(long jobId) { - jobId_ = jobId; - setParameter(std::string("JobId"), std::to_string(jobId)); -} - -long KillSparkJobRequest::getTid() const { +long ListStandardGroupsRequest::getTid() const { return tid_; } -void KillSparkJobRequest::setTid(long tid) { +void ListStandardGroupsRequest::setTid(long tid) { tid_ = tid; setParameter(std::string("Tid"), std::to_string(tid)); } diff --git a/dms-enterprise/src/model/ListStandardGroupsResult.cc b/dms-enterprise/src/model/ListStandardGroupsResult.cc new file mode 100644 index 000000000..cc3b73733 --- /dev/null +++ b/dms-enterprise/src/model/ListStandardGroupsResult.cc @@ -0,0 +1,86 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Dms_enterprise; +using namespace AlibabaCloud::Dms_enterprise::Model; + +ListStandardGroupsResult::ListStandardGroupsResult() : + ServiceResult() +{} + +ListStandardGroupsResult::ListStandardGroupsResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ListStandardGroupsResult::~ListStandardGroupsResult() +{} + +void ListStandardGroupsResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto allStandardGroupListNode = value["StandardGroupList"]["StandardGroupListItem"]; + for (auto valueStandardGroupListStandardGroupListItem : allStandardGroupListNode) + { + StandardGroupListItem standardGroupListObject; + if(!valueStandardGroupListStandardGroupListItem["GroupName"].isNull()) + standardGroupListObject.groupName = valueStandardGroupListStandardGroupListItem["GroupName"].asString(); + if(!valueStandardGroupListStandardGroupListItem["Description"].isNull()) + standardGroupListObject.description = valueStandardGroupListStandardGroupListItem["Description"].asString(); + if(!valueStandardGroupListStandardGroupListItem["DbType"].isNull()) + standardGroupListObject.dbType = valueStandardGroupListStandardGroupListItem["DbType"].asString(); + if(!valueStandardGroupListStandardGroupListItem["LastMenderId"].isNull()) + standardGroupListObject.lastMenderId = std::stol(valueStandardGroupListStandardGroupListItem["LastMenderId"].asString()); + if(!valueStandardGroupListStandardGroupListItem["GroupMode"].isNull()) + standardGroupListObject.groupMode = valueStandardGroupListStandardGroupListItem["GroupMode"].asString(); + standardGroupList_.push_back(standardGroupListObject); + } + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + +} + +std::vector ListStandardGroupsResult::getStandardGroupList()const +{ + return standardGroupList_; +} + +std::string ListStandardGroupsResult::getErrorCode()const +{ + return errorCode_; +} + +std::string ListStandardGroupsResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool ListStandardGroupsResult::getSuccess()const +{ + return success_; +} + diff --git a/dms-enterprise/src/model/SubmitSparkJobRequest.cc b/dms-enterprise/src/model/SubmitSparkJobRequest.cc deleted file mode 100644 index 9ca693548..000000000 --- a/dms-enterprise/src/model/SubmitSparkJobRequest.cc +++ /dev/null @@ -1,116 +0,0 @@ -/* - * Copyright 2009-2017 Alibaba Cloud All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include - -using AlibabaCloud::Dms_enterprise::Model::SubmitSparkJobRequest; - -SubmitSparkJobRequest::SubmitSparkJobRequest() - : RpcServiceRequest("dms-enterprise", "2018-11-01", "SubmitSparkJob") { - setMethod(HttpRequest::Method::Post); -} - -SubmitSparkJobRequest::~SubmitSparkJobRequest() {} - -std::string SubmitSparkJobRequest::getMainClass() const { - return mainClass_; -} - -void SubmitSparkJobRequest::setMainClass(const std::string &mainClass) { - mainClass_ = mainClass; - setBodyParameter(std::string("MainClass"), mainClass); -} - -std::map SubmitSparkJobRequest::getConfiguration() const { - return configuration_; -} - -void SubmitSparkJobRequest::setConfiguration(const std::map &configuration) { - configuration_ = configuration; - for(auto const &iter1 : configuration) { - setBodyParameter(std::string("Configuration") + "." + iter1.first, iter1.second); - } -} - -SubmitSparkJobRequest::OssInfo SubmitSparkJobRequest::getOssInfo() const { - return ossInfo_; -} - -void SubmitSparkJobRequest::setOssInfo(const SubmitSparkJobRequest::OssInfo &ossInfo) { - ossInfo_ = ossInfo; - setBodyParameter(std::string("OssInfo") + ".Endpoint", ossInfo.endpoint); - setBodyParameter(std::string("OssInfo") + ".AccessKeySecret", ossInfo.accessKeySecret); - setBodyParameter(std::string("OssInfo") + ".AccessKeyId", ossInfo.accessKeyId); -} - -long SubmitSparkJobRequest::getTid() const { - return tid_; -} - -void SubmitSparkJobRequest::setTid(long tid) { - tid_ = tid; - setParameter(std::string("Tid"), std::to_string(tid)); -} - -std::string SubmitSparkJobRequest::getMainFile() const { - return mainFile_; -} - -void SubmitSparkJobRequest::setMainFile(const std::string &mainFile) { - mainFile_ = mainFile; - setBodyParameter(std::string("MainFile"), mainFile); -} - -std::string SubmitSparkJobRequest::getName() const { - return name_; -} - -void SubmitSparkJobRequest::setName(const std::string &name) { - name_ = name; - setBodyParameter(std::string("Name"), name); -} - -std::vector SubmitSparkJobRequest::getFiles() const { - return files_; -} - -void SubmitSparkJobRequest::setFiles(const std::vector &files) { - files_ = files; - for(int dep1 = 0; dep1 != files.size(); dep1++) { - setBodyParameter(std::string("Files") + "." + std::to_string(dep1 + 1), files[dep1]); - } -} - -std::string SubmitSparkJobRequest::getAppCode() const { - return appCode_; -} - -void SubmitSparkJobRequest::setAppCode(const std::string &appCode) { - appCode_ = appCode; - setBodyParameter(std::string("AppCode"), appCode); -} - -std::vector SubmitSparkJobRequest::getArguments() const { - return arguments_; -} - -void SubmitSparkJobRequest::setArguments(const std::vector &arguments) { - arguments_ = arguments; - for(int dep1 = 0; dep1 != arguments.size(); dep1++) { - setBodyParameter(std::string("Arguments") + "." + std::to_string(dep1 + 1), arguments[dep1]); - } -} -