Disabled Spark Job API.

This commit is contained in:
sdk-team
2022-03-10 08:13:59 +00:00
parent 878b123ba6
commit 3f43b4048c
32 changed files with 384 additions and 1506 deletions

View File

@@ -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

View File

@@ -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<Error, Model::CreateDataCronClearOrderResult> CreateDataCronClearOrderOutcome;
typedef std::future<CreateDataCronClearOrderOutcome> CreateDataCronClearOrderOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::CreateDataCronClearOrderRequest&, const CreateDataCronClearOrderOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> CreateDataCronClearOrderAsyncHandler;
typedef Outcome<Error, Model::CreateDataExportOrderResult> CreateDataExportOrderOutcome;
typedef std::future<CreateDataExportOrderOutcome> CreateDataExportOrderOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::CreateDataExportOrderRequest&, const CreateDataExportOrderOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> CreateDataExportOrderAsyncHandler;
typedef Outcome<Error, Model::CreateDataImportOrderResult> CreateDataImportOrderOutcome;
typedef std::future<CreateDataImportOrderOutcome> CreateDataImportOrderOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::CreateDataImportOrderRequest&, const CreateDataImportOrderOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> CreateDataImportOrderAsyncHandler;
@@ -420,18 +415,6 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::GetSQLReviewOptimizeDetailResult> GetSQLReviewOptimizeDetailOutcome;
typedef std::future<GetSQLReviewOptimizeDetailOutcome> GetSQLReviewOptimizeDetailOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetSQLReviewOptimizeDetailRequest&, const GetSQLReviewOptimizeDetailOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetSQLReviewOptimizeDetailAsyncHandler;
typedef Outcome<Error, Model::GetSparkJobDetailResult> GetSparkJobDetailOutcome;
typedef std::future<GetSparkJobDetailOutcome> GetSparkJobDetailOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetSparkJobDetailRequest&, const GetSparkJobDetailOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetSparkJobDetailAsyncHandler;
typedef Outcome<Error, Model::GetSparkJobDriverLogResult> GetSparkJobDriverLogOutcome;
typedef std::future<GetSparkJobDriverLogOutcome> GetSparkJobDriverLogOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetSparkJobDriverLogRequest&, const GetSparkJobDriverLogOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetSparkJobDriverLogAsyncHandler;
typedef Outcome<Error, Model::GetSparkJobExecutorLogsResult> GetSparkJobExecutorLogsOutcome;
typedef std::future<GetSparkJobExecutorLogsOutcome> GetSparkJobExecutorLogsOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetSparkJobExecutorLogsRequest&, const GetSparkJobExecutorLogsOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetSparkJobExecutorLogsAsyncHandler;
typedef Outcome<Error, Model::GetSparkJobLogResult> GetSparkJobLogOutcome;
typedef std::future<GetSparkJobLogOutcome> GetSparkJobLogOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetSparkJobLogRequest&, const GetSparkJobLogOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetSparkJobLogAsyncHandler;
typedef Outcome<Error, Model::GetStructSyncExecSqlDetailResult> GetStructSyncExecSqlDetailOutcome;
typedef std::future<GetStructSyncExecSqlDetailOutcome> GetStructSyncExecSqlDetailOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::GetStructSyncExecSqlDetailRequest&, const GetStructSyncExecSqlDetailOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> GetStructSyncExecSqlDetailAsyncHandler;
@@ -465,9 +448,6 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::InspectProxyAccessSecretResult> InspectProxyAccessSecretOutcome;
typedef std::future<InspectProxyAccessSecretOutcome> InspectProxyAccessSecretOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::InspectProxyAccessSecretRequest&, const InspectProxyAccessSecretOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> InspectProxyAccessSecretAsyncHandler;
typedef Outcome<Error, Model::KillSparkJobResult> KillSparkJobOutcome;
typedef std::future<KillSparkJobOutcome> KillSparkJobOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::KillSparkJobRequest&, const KillSparkJobOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> KillSparkJobAsyncHandler;
typedef Outcome<Error, Model::ListColumnsResult> ListColumnsOutcome;
typedef std::future<ListColumnsOutcome> ListColumnsOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListColumnsRequest&, const ListColumnsOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListColumnsAsyncHandler;
@@ -537,6 +517,9 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::ListSensitiveColumnsDetailResult> ListSensitiveColumnsDetailOutcome;
typedef std::future<ListSensitiveColumnsDetailOutcome> ListSensitiveColumnsDetailOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListSensitiveColumnsDetailRequest&, const ListSensitiveColumnsDetailOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListSensitiveColumnsDetailAsyncHandler;
typedef Outcome<Error, Model::ListStandardGroupsResult> ListStandardGroupsOutcome;
typedef std::future<ListStandardGroupsOutcome> ListStandardGroupsOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListStandardGroupsRequest&, const ListStandardGroupsOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListStandardGroupsAsyncHandler;
typedef Outcome<Error, Model::ListTablesResult> ListTablesOutcome;
typedef std::future<ListTablesOutcome> ListTablesOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::ListTablesRequest&, const ListTablesOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListTablesAsyncHandler;
@@ -588,9 +571,6 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::SubmitOrderApprovalResult> SubmitOrderApprovalOutcome;
typedef std::future<SubmitOrderApprovalOutcome> SubmitOrderApprovalOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::SubmitOrderApprovalRequest&, const SubmitOrderApprovalOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> SubmitOrderApprovalAsyncHandler;
typedef Outcome<Error, Model::SubmitSparkJobResult> SubmitSparkJobOutcome;
typedef std::future<SubmitSparkJobOutcome> SubmitSparkJobOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::SubmitSparkJobRequest&, const SubmitSparkJobOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> SubmitSparkJobAsyncHandler;
typedef Outcome<Error, Model::SubmitStructSyncOrderApprovalResult> SubmitStructSyncOrderApprovalOutcome;
typedef std::future<SubmitStructSyncOrderApprovalOutcome> SubmitStructSyncOrderApprovalOutcomeCallable;
typedef std::function<void(const Dms_enterpriseClient*, const Model::SubmitStructSyncOrderApprovalRequest&, const SubmitStructSyncOrderApprovalOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& context = nullptr) const;
SubmitStructSyncOrderApprovalOutcomeCallable submitStructSyncOrderApprovalCallable(const Model::SubmitStructSyncOrderApprovalRequest& request) const;

View File

@@ -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 <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
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<DbItemListItem> 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 &param);
std::string getComment() const;
void setComment(const std::string &comment);
std::vector<long> getRelatedUserList() const;
void setRelatedUserList(const std::vector<long> &relatedUserList);
private:
long tid_;
std::string attachmentKey_;
Param param_;
std::string comment_;
std::vector<long> relatedUserList_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERREQUEST_H_

View File

@@ -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 <string>
#include <vector>
@@ -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<std::string> 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<std::string> createOrderResult_;
std::string errorCode_;
std::string errorMessage_;
bool success_;
long jobId_;
};
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBRESULT_H_
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_CREATEDATAEXPORTORDERRESULT_H_

View File

@@ -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 <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
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_

View File

@@ -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 <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
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_

View File

@@ -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 <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
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_

View File

@@ -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 <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
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_

View File

@@ -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 <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
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_

View File

@@ -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 <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
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_

View File

@@ -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 <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
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_

View File

@@ -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 <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
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_

View File

@@ -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 <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
@@ -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_

View File

@@ -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 <string>
#include <vector>
@@ -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<std::string> getExecutorLogs()const;
ListStandardGroupsResult();
explicit ListStandardGroupsResult(const std::string &payload);
~ListStandardGroupsResult();
std::vector<StandardGroupListItem> 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<std::string> executorLogs_;
std::vector<StandardGroupListItem> standardGroupList_;
std::string errorCode_;
std::string errorMessage_;
bool success_;
@@ -54,4 +62,4 @@ namespace AlibabaCloud
}
}
}
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETSPARKJOBEXECUTORLOGSRESULT_H_
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTSTANDARDGROUPSRESULT_H_

View File

@@ -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 <alibabacloud/dms-enterprise/Dms_enterpriseExport.h>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <string>
#include <vector>
#include <map>
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<std::string, std::string> getConfiguration() const;
void setConfiguration(const std::map<std::string, std::string> &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<std::string> getFiles() const;
void setFiles(const std::vector<std::string> &files);
std::string getAppCode() const;
void setAppCode(const std::string &appCode);
std::vector<std::string> getArguments() const;
void setArguments(const std::vector<std::string> &arguments);
private:
std::string mainClass_;
std::map<std::string, std::string> configuration_;
OssInfo ossInfo_;
long tid_;
std::string mainFile_;
std::string name_;
std::vector<std::string> files_;
std::string appCode_;
std::vector<std::string> arguments_;
};
} // namespace Model
} // namespace Dms_enterprise
} // namespace AlibabaCloud
#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_SUBMITSPARKJOBREQUEST_H_

View File

@@ -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<const AsyncCallerContext>& 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<std::packaged_task<CreateDataExportOrderOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<GetSparkJobDetailOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<GetSparkJobDriverLogOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<GetSparkJobExecutorLogsOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<GetSparkJobLogOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<KillSparkJobOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<ListStandardGroupsOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<SubmitSparkJobOutcome()>>(
[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();

View File

@@ -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 <alibabacloud/dms-enterprise/model/CreateDataExportOrderRequest.h>
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 &param) {
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::long> CreateDataExportOrderRequest::getRelatedUserList() const {
return relatedUserList_;
}
void CreateDataExportOrderRequest::setRelatedUserList(const std::vector<CreateDataExportOrderRequest::long> &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]));
}
}

View File

@@ -14,59 +14,60 @@
* limitations under the License.
*/
#include <alibabacloud/dms-enterprise/model/SubmitSparkJobResult.h>
#include <alibabacloud/dms-enterprise/model/CreateDataExportOrderResult.h>
#include <json/json.h>
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<std::string> 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_;
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobDetailRequest.h>
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));
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobDetailResult.h>
#include <json/json.h>
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_;
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobDriverLogRequest.h>
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));
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobDriverLogResult.h>
#include <json/json.h>
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_;
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsRequest.h>
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));
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobExecutorLogsResult.h>
#include <json/json.h>
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<std::string> 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_;
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobLogRequest.h>
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));
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/GetSparkJobLogResult.h>
#include <json/json.h>
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_;
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/KillSparkJobResult.h>
#include <json/json.h>
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_;
}

View File

@@ -14,31 +14,22 @@
* limitations under the License.
*/
#include <alibabacloud/dms-enterprise/model/KillSparkJobRequest.h>
#include <alibabacloud/dms-enterprise/model/ListStandardGroupsRequest.h>
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));
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/ListStandardGroupsResult.h>
#include <json/json.h>
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::StandardGroupListItem> 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_;
}

View File

@@ -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 <alibabacloud/dms-enterprise/model/SubmitSparkJobRequest.h>
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<std::string, std::string> SubmitSparkJobRequest::getConfiguration() const {
return configuration_;
}
void SubmitSparkJobRequest::setConfiguration(const std::map<std::string, std::string> &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::std::string> SubmitSparkJobRequest::getFiles() const {
return files_;
}
void SubmitSparkJobRequest::setFiles(const std::vector<SubmitSparkJobRequest::std::string> &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::std::string> SubmitSparkJobRequest::getArguments() const {
return arguments_;
}
void SubmitSparkJobRequest::setArguments(const std::vector<SubmitSparkJobRequest::std::string> &arguments) {
arguments_ = arguments;
for(int dep1 = 0; dep1 != arguments.size(); dep1++) {
setBodyParameter(std::string("Arguments") + "." + std::to_string(dep1 + 1), arguments[dep1]);
}
}