diff --git a/VERSION b/VERSION index 38e821df0..d315bcd55 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.36.1599 \ No newline at end of file +1.36.1600 \ No newline at end of file diff --git a/dataworks-public/CMakeLists.txt b/dataworks-public/CMakeLists.txt index 4a888e55d..5f83be87b 100644 --- a/dataworks-public/CMakeLists.txt +++ b/dataworks-public/CMakeLists.txt @@ -117,6 +117,8 @@ set(dataworks-public_public_header_model include/alibabacloud/dataworks-public/model/DeleteFolderResult.h include/alibabacloud/dataworks-public/model/DeleteFromMetaCategoryRequest.h include/alibabacloud/dataworks-public/model/DeleteFromMetaCategoryResult.h + include/alibabacloud/dataworks-public/model/DeleteLineageRelationRequest.h + include/alibabacloud/dataworks-public/model/DeleteLineageRelationResult.h include/alibabacloud/dataworks-public/model/DeleteMetaCategoryRequest.h include/alibabacloud/dataworks-public/model/DeleteMetaCategoryResult.h include/alibabacloud/dataworks-public/model/DeleteMetaCollectionRequest.h @@ -353,6 +355,8 @@ set(dataworks-public_public_header_model include/alibabacloud/dataworks-public/model/ListInstanceHistoryResult.h include/alibabacloud/dataworks-public/model/ListInstancesRequest.h include/alibabacloud/dataworks-public/model/ListInstancesResult.h + include/alibabacloud/dataworks-public/model/ListLineageRequest.h + include/alibabacloud/dataworks-public/model/ListLineageResult.h include/alibabacloud/dataworks-public/model/ListManualDagInstancesRequest.h include/alibabacloud/dataworks-public/model/ListManualDagInstancesResult.h include/alibabacloud/dataworks-public/model/ListMetaCollectionEntitiesRequest.h @@ -419,6 +423,8 @@ set(dataworks-public_public_header_model include/alibabacloud/dataworks-public/model/QueryDISyncTaskConfigProcessResultResult.h include/alibabacloud/dataworks-public/model/QueryPublicModelEngineRequest.h include/alibabacloud/dataworks-public/model/QueryPublicModelEngineResult.h + include/alibabacloud/dataworks-public/model/RegisterLineageRelationRequest.h + include/alibabacloud/dataworks-public/model/RegisterLineageRelationResult.h include/alibabacloud/dataworks-public/model/RemoveProjectMemberFromRoleRequest.h include/alibabacloud/dataworks-public/model/RemoveProjectMemberFromRoleResult.h include/alibabacloud/dataworks-public/model/RestartInstanceRequest.h @@ -626,6 +632,8 @@ set(dataworks-public_src src/model/DeleteFolderResult.cc src/model/DeleteFromMetaCategoryRequest.cc src/model/DeleteFromMetaCategoryResult.cc + src/model/DeleteLineageRelationRequest.cc + src/model/DeleteLineageRelationResult.cc src/model/DeleteMetaCategoryRequest.cc src/model/DeleteMetaCategoryResult.cc src/model/DeleteMetaCollectionRequest.cc @@ -862,6 +870,8 @@ set(dataworks-public_src src/model/ListInstanceHistoryResult.cc src/model/ListInstancesRequest.cc src/model/ListInstancesResult.cc + src/model/ListLineageRequest.cc + src/model/ListLineageResult.cc src/model/ListManualDagInstancesRequest.cc src/model/ListManualDagInstancesResult.cc src/model/ListMetaCollectionEntitiesRequest.cc @@ -928,6 +938,8 @@ set(dataworks-public_src src/model/QueryDISyncTaskConfigProcessResultResult.cc src/model/QueryPublicModelEngineRequest.cc src/model/QueryPublicModelEngineResult.cc + src/model/RegisterLineageRelationRequest.cc + src/model/RegisterLineageRelationResult.cc src/model/RemoveProjectMemberFromRoleRequest.cc src/model/RemoveProjectMemberFromRoleResult.cc src/model/RestartInstanceRequest.cc diff --git a/dataworks-public/include/alibabacloud/dataworks-public/Dataworks_publicClient.h b/dataworks-public/include/alibabacloud/dataworks-public/Dataworks_publicClient.h index cf02379b7..4ce2e900f 100644 --- a/dataworks-public/include/alibabacloud/dataworks-public/Dataworks_publicClient.h +++ b/dataworks-public/include/alibabacloud/dataworks-public/Dataworks_publicClient.h @@ -118,6 +118,8 @@ #include "model/DeleteFolderResult.h" #include "model/DeleteFromMetaCategoryRequest.h" #include "model/DeleteFromMetaCategoryResult.h" +#include "model/DeleteLineageRelationRequest.h" +#include "model/DeleteLineageRelationResult.h" #include "model/DeleteMetaCategoryRequest.h" #include "model/DeleteMetaCategoryResult.h" #include "model/DeleteMetaCollectionRequest.h" @@ -354,6 +356,8 @@ #include "model/ListInstanceHistoryResult.h" #include "model/ListInstancesRequest.h" #include "model/ListInstancesResult.h" +#include "model/ListLineageRequest.h" +#include "model/ListLineageResult.h" #include "model/ListManualDagInstancesRequest.h" #include "model/ListManualDagInstancesResult.h" #include "model/ListMetaCollectionEntitiesRequest.h" @@ -420,6 +424,8 @@ #include "model/QueryDISyncTaskConfigProcessResultResult.h" #include "model/QueryPublicModelEngineRequest.h" #include "model/QueryPublicModelEngineResult.h" +#include "model/RegisterLineageRelationRequest.h" +#include "model/RegisterLineageRelationResult.h" #include "model/RemoveProjectMemberFromRoleRequest.h" #include "model/RemoveProjectMemberFromRoleResult.h" #include "model/RestartInstanceRequest.h" @@ -681,6 +687,9 @@ namespace AlibabaCloud typedef Outcome DeleteFromMetaCategoryOutcome; typedef std::future DeleteFromMetaCategoryOutcomeCallable; typedef std::function&)> DeleteFromMetaCategoryAsyncHandler; + typedef Outcome DeleteLineageRelationOutcome; + typedef std::future DeleteLineageRelationOutcomeCallable; + typedef std::function&)> DeleteLineageRelationAsyncHandler; typedef Outcome DeleteMetaCategoryOutcome; typedef std::future DeleteMetaCategoryOutcomeCallable; typedef std::function&)> DeleteMetaCategoryAsyncHandler; @@ -1035,6 +1044,9 @@ namespace AlibabaCloud typedef Outcome ListInstancesOutcome; typedef std::future ListInstancesOutcomeCallable; typedef std::function&)> ListInstancesAsyncHandler; + typedef Outcome ListLineageOutcome; + typedef std::future ListLineageOutcomeCallable; + typedef std::function&)> ListLineageAsyncHandler; typedef Outcome ListManualDagInstancesOutcome; typedef std::future ListManualDagInstancesOutcomeCallable; typedef std::function&)> ListManualDagInstancesAsyncHandler; @@ -1134,6 +1146,9 @@ namespace AlibabaCloud typedef Outcome QueryPublicModelEngineOutcome; typedef std::future QueryPublicModelEngineOutcomeCallable; typedef std::function&)> QueryPublicModelEngineAsyncHandler; + typedef Outcome RegisterLineageRelationOutcome; + typedef std::future RegisterLineageRelationOutcomeCallable; + typedef std::function&)> RegisterLineageRelationAsyncHandler; typedef Outcome RemoveProjectMemberFromRoleOutcome; typedef std::future RemoveProjectMemberFromRoleOutcomeCallable; typedef std::function&)> RemoveProjectMemberFromRoleAsyncHandler; @@ -1445,6 +1460,9 @@ namespace AlibabaCloud DeleteFromMetaCategoryOutcome deleteFromMetaCategory(const Model::DeleteFromMetaCategoryRequest &request)const; void deleteFromMetaCategoryAsync(const Model::DeleteFromMetaCategoryRequest& request, const DeleteFromMetaCategoryAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DeleteFromMetaCategoryOutcomeCallable deleteFromMetaCategoryCallable(const Model::DeleteFromMetaCategoryRequest& request) const; + DeleteLineageRelationOutcome deleteLineageRelation(const Model::DeleteLineageRelationRequest &request)const; + void deleteLineageRelationAsync(const Model::DeleteLineageRelationRequest& request, const DeleteLineageRelationAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + DeleteLineageRelationOutcomeCallable deleteLineageRelationCallable(const Model::DeleteLineageRelationRequest& request) const; DeleteMetaCategoryOutcome deleteMetaCategory(const Model::DeleteMetaCategoryRequest &request)const; void deleteMetaCategoryAsync(const Model::DeleteMetaCategoryRequest& request, const DeleteMetaCategoryAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DeleteMetaCategoryOutcomeCallable deleteMetaCategoryCallable(const Model::DeleteMetaCategoryRequest& request) const; @@ -1799,6 +1817,9 @@ namespace AlibabaCloud ListInstancesOutcome listInstances(const Model::ListInstancesRequest &request)const; void listInstancesAsync(const Model::ListInstancesRequest& request, const ListInstancesAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListInstancesOutcomeCallable listInstancesCallable(const Model::ListInstancesRequest& request) const; + ListLineageOutcome listLineage(const Model::ListLineageRequest &request)const; + void listLineageAsync(const Model::ListLineageRequest& request, const ListLineageAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ListLineageOutcomeCallable listLineageCallable(const Model::ListLineageRequest& request) const; ListManualDagInstancesOutcome listManualDagInstances(const Model::ListManualDagInstancesRequest &request)const; void listManualDagInstancesAsync(const Model::ListManualDagInstancesRequest& request, const ListManualDagInstancesAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListManualDagInstancesOutcomeCallable listManualDagInstancesCallable(const Model::ListManualDagInstancesRequest& request) const; @@ -1898,6 +1919,9 @@ namespace AlibabaCloud QueryPublicModelEngineOutcome queryPublicModelEngine(const Model::QueryPublicModelEngineRequest &request)const; void queryPublicModelEngineAsync(const Model::QueryPublicModelEngineRequest& request, const QueryPublicModelEngineAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; QueryPublicModelEngineOutcomeCallable queryPublicModelEngineCallable(const Model::QueryPublicModelEngineRequest& request) const; + RegisterLineageRelationOutcome registerLineageRelation(const Model::RegisterLineageRelationRequest &request)const; + void registerLineageRelationAsync(const Model::RegisterLineageRelationRequest& request, const RegisterLineageRelationAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + RegisterLineageRelationOutcomeCallable registerLineageRelationCallable(const Model::RegisterLineageRelationRequest& request) const; RemoveProjectMemberFromRoleOutcome removeProjectMemberFromRole(const Model::RemoveProjectMemberFromRoleRequest &request)const; void removeProjectMemberFromRoleAsync(const Model::RemoveProjectMemberFromRoleRequest& request, const RemoveProjectMemberFromRoleAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; RemoveProjectMemberFromRoleOutcomeCallable removeProjectMemberFromRoleCallable(const Model::RemoveProjectMemberFromRoleRequest& request) const; diff --git a/dataworks-public/include/alibabacloud/dataworks-public/model/DeleteLineageRelationRequest.h b/dataworks-public/include/alibabacloud/dataworks-public/model/DeleteLineageRelationRequest.h new file mode 100644 index 000000000..caea10cea --- /dev/null +++ b/dataworks-public/include/alibabacloud/dataworks-public/model/DeleteLineageRelationRequest.h @@ -0,0 +1,48 @@ +/* + * 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_DATAWORKS_PUBLIC_MODEL_DELETELINEAGERELATIONREQUEST_H_ +#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_DELETELINEAGERELATIONREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dataworks_public { +namespace Model { +class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT DeleteLineageRelationRequest : public RpcServiceRequest { +public: + DeleteLineageRelationRequest(); + ~DeleteLineageRelationRequest(); + std::string getSrcEntityQualifiedName() const; + void setSrcEntityQualifiedName(const std::string &srcEntityQualifiedName); + std::string getDestEntityQualifiedName() const; + void setDestEntityQualifiedName(const std::string &destEntityQualifiedName); + std::string getRelationshipGuid() const; + void setRelationshipGuid(const std::string &relationshipGuid); + +private: + std::string srcEntityQualifiedName_; + std::string destEntityQualifiedName_; + std::string relationshipGuid_; +}; +} // namespace Model +} // namespace Dataworks_public +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_DELETELINEAGERELATIONREQUEST_H_ diff --git a/dataworks-public/include/alibabacloud/dataworks-public/model/DeleteLineageRelationResult.h b/dataworks-public/include/alibabacloud/dataworks-public/model/DeleteLineageRelationResult.h new file mode 100644 index 000000000..78f87cdca --- /dev/null +++ b/dataworks-public/include/alibabacloud/dataworks-public/model/DeleteLineageRelationResult.h @@ -0,0 +1,59 @@ +/* + * 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_DATAWORKS_PUBLIC_MODEL_DELETELINEAGERELATIONRESULT_H_ +#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_DELETELINEAGERELATIONRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dataworks_public + { + namespace Model + { + class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT DeleteLineageRelationResult : public ServiceResult + { + public: + + + DeleteLineageRelationResult(); + explicit DeleteLineageRelationResult(const std::string &payload); + ~DeleteLineageRelationResult(); + bool getStatus()const; + int getHttpStatusCode()const; + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + bool status_; + int httpStatusCode_; + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_DELETELINEAGERELATIONRESULT_H_ \ No newline at end of file diff --git a/dataworks-public/include/alibabacloud/dataworks-public/model/ListLineageRequest.h b/dataworks-public/include/alibabacloud/dataworks-public/model/ListLineageRequest.h new file mode 100644 index 000000000..4e3860544 --- /dev/null +++ b/dataworks-public/include/alibabacloud/dataworks-public/model/ListLineageRequest.h @@ -0,0 +1,54 @@ +/* + * 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_DATAWORKS_PUBLIC_MODEL_LISTLINEAGEREQUEST_H_ +#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTLINEAGEREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dataworks_public { +namespace Model { +class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT ListLineageRequest : public RpcServiceRequest { +public: + ListLineageRequest(); + ~ListLineageRequest(); + std::string getEntityQualifiedName() const; + void setEntityQualifiedName(const std::string &entityQualifiedName); + std::string getNextToken() const; + void setNextToken(const std::string &nextToken); + int getPageSize() const; + void setPageSize(int pageSize); + std::string getKeyword() const; + void setKeyword(const std::string &keyword); + std::string getDirection() const; + void setDirection(const std::string &direction); + +private: + std::string entityQualifiedName_; + std::string nextToken_; + int pageSize_; + std::string keyword_; + std::string direction_; +}; +} // namespace Model +} // namespace Dataworks_public +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTLINEAGEREQUEST_H_ diff --git a/dataworks-public/include/alibabacloud/dataworks-public/model/ListLineageResult.h b/dataworks-public/include/alibabacloud/dataworks-public/model/ListLineageResult.h new file mode 100644 index 000000000..745c80d7d --- /dev/null +++ b/dataworks-public/include/alibabacloud/dataworks-public/model/ListLineageResult.h @@ -0,0 +1,83 @@ +/* + * 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_DATAWORKS_PUBLIC_MODEL_LISTLINEAGERESULT_H_ +#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTLINEAGERESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dataworks_public + { + namespace Model + { + class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT ListLineageResult : public ServiceResult + { + public: + struct Data + { + struct DataEntityListItem + { + struct Entity + { + std::string entityContent; + long tenantId; + std::string qualifiedName; + }; + struct RelationListItem + { + std::string datasource; + std::string type; + std::string channel; + std::string guid; + }; + Entity entity; + std::vector relationList; + long createTimestamp; + }; + std::string nextToken; + std::vector dataEntityList; + }; + + + ListLineageResult(); + explicit ListLineageResult(const std::string &payload); + ~ListLineageResult(); + int getHttpStatusCode()const; + Data getData()const; + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + int httpStatusCode_; + Data data_; + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTLINEAGERESULT_H_ \ No newline at end of file diff --git a/dataworks-public/include/alibabacloud/dataworks-public/model/RegisterLineageRelationRequest.h b/dataworks-public/include/alibabacloud/dataworks-public/model/RegisterLineageRelationRequest.h new file mode 100644 index 000000000..239caf6fb --- /dev/null +++ b/dataworks-public/include/alibabacloud/dataworks-public/model/RegisterLineageRelationRequest.h @@ -0,0 +1,63 @@ +/* + * 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_DATAWORKS_PUBLIC_MODEL_REGISTERLINEAGERELATIONREQUEST_H_ +#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_REGISTERLINEAGERELATIONREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dataworks_public { +namespace Model { +class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT RegisterLineageRelationRequest : public RpcServiceRequest { +public: + struct LineageRelationRegisterVO { + struct DestEntity { + std::string parentName; + std::string qualifiedName; + std::string name; + std::string detailUrl; + }; + DestEntity destEntity; + long createTimestamp; + struct Relationship { + std::string type; + }; + Relationship relationship; + struct SrcEntity { + std::string parentName; + std::string qualifiedName; + std::string name; + std::string detailUrl; + }; + SrcEntity srcEntity; + }; + RegisterLineageRelationRequest(); + ~RegisterLineageRelationRequest(); + LineageRelationRegisterVO getLineageRelationRegisterVO() const; + void setLineageRelationRegisterVO(const LineageRelationRegisterVO &lineageRelationRegisterVO); + +private: + LineageRelationRegisterVO lineageRelationRegisterVO_; +}; +} // namespace Model +} // namespace Dataworks_public +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_REGISTERLINEAGERELATIONREQUEST_H_ diff --git a/dataworks-public/include/alibabacloud/dataworks-public/model/RegisterLineageRelationResult.h b/dataworks-public/include/alibabacloud/dataworks-public/model/RegisterLineageRelationResult.h new file mode 100644 index 000000000..714d42929 --- /dev/null +++ b/dataworks-public/include/alibabacloud/dataworks-public/model/RegisterLineageRelationResult.h @@ -0,0 +1,65 @@ +/* + * 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_DATAWORKS_PUBLIC_MODEL_REGISTERLINEAGERELATIONRESULT_H_ +#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_REGISTERLINEAGERELATIONRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dataworks_public + { + namespace Model + { + class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT RegisterLineageRelationResult : public ServiceResult + { + public: + struct LineageRelation + { + std::string destEntityQualifiedName; + std::string relationshipGuid; + std::string srcEntityQualifiedName; + }; + + + RegisterLineageRelationResult(); + explicit RegisterLineageRelationResult(const std::string &payload); + ~RegisterLineageRelationResult(); + LineageRelation getLineageRelation()const; + int getHttpStatusCode()const; + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + LineageRelation lineageRelation_; + int httpStatusCode_; + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_REGISTERLINEAGERELATIONRESULT_H_ \ No newline at end of file diff --git a/dataworks-public/src/Dataworks-publicClient.cc b/dataworks-public/src/Dataworks-publicClient.cc index 5fdec1556..bfdc39292 100644 --- a/dataworks-public/src/Dataworks-publicClient.cc +++ b/dataworks-public/src/Dataworks-publicClient.cc @@ -1779,6 +1779,42 @@ Dataworks_publicClient::DeleteFromMetaCategoryOutcomeCallable Dataworks_publicCl return task->get_future(); } +Dataworks_publicClient::DeleteLineageRelationOutcome Dataworks_publicClient::deleteLineageRelation(const DeleteLineageRelationRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return DeleteLineageRelationOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return DeleteLineageRelationOutcome(DeleteLineageRelationResult(outcome.result())); + else + return DeleteLineageRelationOutcome(outcome.error()); +} + +void Dataworks_publicClient::deleteLineageRelationAsync(const DeleteLineageRelationRequest& request, const DeleteLineageRelationAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, deleteLineageRelation(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dataworks_publicClient::DeleteLineageRelationOutcomeCallable Dataworks_publicClient::deleteLineageRelationCallable(const DeleteLineageRelationRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->deleteLineageRelation(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dataworks_publicClient::DeleteMetaCategoryOutcome Dataworks_publicClient::deleteMetaCategory(const DeleteMetaCategoryRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -6027,6 +6063,42 @@ Dataworks_publicClient::ListInstancesOutcomeCallable Dataworks_publicClient::lis return task->get_future(); } +Dataworks_publicClient::ListLineageOutcome Dataworks_publicClient::listLineage(const ListLineageRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ListLineageOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ListLineageOutcome(ListLineageResult(outcome.result())); + else + return ListLineageOutcome(outcome.error()); +} + +void Dataworks_publicClient::listLineageAsync(const ListLineageRequest& request, const ListLineageAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, listLineage(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dataworks_publicClient::ListLineageOutcomeCallable Dataworks_publicClient::listLineageCallable(const ListLineageRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->listLineage(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dataworks_publicClient::ListManualDagInstancesOutcome Dataworks_publicClient::listManualDagInstances(const ListManualDagInstancesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -7215,6 +7287,42 @@ Dataworks_publicClient::QueryPublicModelEngineOutcomeCallable Dataworks_publicCl return task->get_future(); } +Dataworks_publicClient::RegisterLineageRelationOutcome Dataworks_publicClient::registerLineageRelation(const RegisterLineageRelationRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return RegisterLineageRelationOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return RegisterLineageRelationOutcome(RegisterLineageRelationResult(outcome.result())); + else + return RegisterLineageRelationOutcome(outcome.error()); +} + +void Dataworks_publicClient::registerLineageRelationAsync(const RegisterLineageRelationRequest& request, const RegisterLineageRelationAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, registerLineageRelation(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dataworks_publicClient::RegisterLineageRelationOutcomeCallable Dataworks_publicClient::registerLineageRelationCallable(const RegisterLineageRelationRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->registerLineageRelation(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dataworks_publicClient::RemoveProjectMemberFromRoleOutcome Dataworks_publicClient::removeProjectMemberFromRole(const RemoveProjectMemberFromRoleRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); diff --git a/dataworks-public/src/model/DeleteLineageRelationRequest.cc b/dataworks-public/src/model/DeleteLineageRelationRequest.cc new file mode 100644 index 000000000..a9fb6db1e --- /dev/null +++ b/dataworks-public/src/model/DeleteLineageRelationRequest.cc @@ -0,0 +1,54 @@ +/* + * 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::Dataworks_public::Model::DeleteLineageRelationRequest; + +DeleteLineageRelationRequest::DeleteLineageRelationRequest() + : RpcServiceRequest("dataworks-public", "2020-05-18", "DeleteLineageRelation") { + setMethod(HttpRequest::Method::Post); +} + +DeleteLineageRelationRequest::~DeleteLineageRelationRequest() {} + +std::string DeleteLineageRelationRequest::getSrcEntityQualifiedName() const { + return srcEntityQualifiedName_; +} + +void DeleteLineageRelationRequest::setSrcEntityQualifiedName(const std::string &srcEntityQualifiedName) { + srcEntityQualifiedName_ = srcEntityQualifiedName; + setParameter(std::string("SrcEntityQualifiedName"), srcEntityQualifiedName); +} + +std::string DeleteLineageRelationRequest::getDestEntityQualifiedName() const { + return destEntityQualifiedName_; +} + +void DeleteLineageRelationRequest::setDestEntityQualifiedName(const std::string &destEntityQualifiedName) { + destEntityQualifiedName_ = destEntityQualifiedName; + setParameter(std::string("DestEntityQualifiedName"), destEntityQualifiedName); +} + +std::string DeleteLineageRelationRequest::getRelationshipGuid() const { + return relationshipGuid_; +} + +void DeleteLineageRelationRequest::setRelationshipGuid(const std::string &relationshipGuid) { + relationshipGuid_ = relationshipGuid; + setParameter(std::string("RelationshipGuid"), relationshipGuid); +} + diff --git a/dataworks-public/src/model/DeleteLineageRelationResult.cc b/dataworks-public/src/model/DeleteLineageRelationResult.cc new file mode 100644 index 000000000..42bb5fd17 --- /dev/null +++ b/dataworks-public/src/model/DeleteLineageRelationResult.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 +#include + +using namespace AlibabaCloud::Dataworks_public; +using namespace AlibabaCloud::Dataworks_public::Model; + +DeleteLineageRelationResult::DeleteLineageRelationResult() : + ServiceResult() +{} + +DeleteLineageRelationResult::DeleteLineageRelationResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +DeleteLineageRelationResult::~DeleteLineageRelationResult() +{} + +void DeleteLineageRelationResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + if(!value["Status"].isNull()) + status_ = value["Status"].asString() == "true"; + +} + +bool DeleteLineageRelationResult::getStatus()const +{ + return status_; +} + +int DeleteLineageRelationResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string DeleteLineageRelationResult::getErrorCode()const +{ + return errorCode_; +} + +std::string DeleteLineageRelationResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool DeleteLineageRelationResult::getSuccess()const +{ + return success_; +} + diff --git a/dataworks-public/src/model/ListLineageRequest.cc b/dataworks-public/src/model/ListLineageRequest.cc new file mode 100644 index 000000000..22aab6c66 --- /dev/null +++ b/dataworks-public/src/model/ListLineageRequest.cc @@ -0,0 +1,72 @@ +/* + * 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::Dataworks_public::Model::ListLineageRequest; + +ListLineageRequest::ListLineageRequest() + : RpcServiceRequest("dataworks-public", "2020-05-18", "ListLineage") { + setMethod(HttpRequest::Method::Post); +} + +ListLineageRequest::~ListLineageRequest() {} + +std::string ListLineageRequest::getEntityQualifiedName() const { + return entityQualifiedName_; +} + +void ListLineageRequest::setEntityQualifiedName(const std::string &entityQualifiedName) { + entityQualifiedName_ = entityQualifiedName; + setParameter(std::string("EntityQualifiedName"), entityQualifiedName); +} + +std::string ListLineageRequest::getNextToken() const { + return nextToken_; +} + +void ListLineageRequest::setNextToken(const std::string &nextToken) { + nextToken_ = nextToken; + setParameter(std::string("NextToken"), nextToken); +} + +int ListLineageRequest::getPageSize() const { + return pageSize_; +} + +void ListLineageRequest::setPageSize(int pageSize) { + pageSize_ = pageSize; + setParameter(std::string("PageSize"), std::to_string(pageSize)); +} + +std::string ListLineageRequest::getKeyword() const { + return keyword_; +} + +void ListLineageRequest::setKeyword(const std::string &keyword) { + keyword_ = keyword; + setParameter(std::string("Keyword"), keyword); +} + +std::string ListLineageRequest::getDirection() const { + return direction_; +} + +void ListLineageRequest::setDirection(const std::string &direction) { + direction_ = direction; + setParameter(std::string("Direction"), direction); +} + diff --git a/dataworks-public/src/model/ListLineageResult.cc b/dataworks-public/src/model/ListLineageResult.cc new file mode 100644 index 000000000..8ceeefd09 --- /dev/null +++ b/dataworks-public/src/model/ListLineageResult.cc @@ -0,0 +1,109 @@ +/* + * 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::Dataworks_public; +using namespace AlibabaCloud::Dataworks_public::Model; + +ListLineageResult::ListLineageResult() : + ServiceResult() +{} + +ListLineageResult::ListLineageResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ListLineageResult::~ListLineageResult() +{} + +void ListLineageResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto dataNode = value["Data"]; + if(!dataNode["NextToken"].isNull()) + data_.nextToken = dataNode["NextToken"].asString(); + auto allDataEntityListNode = dataNode["DataEntityList"]["DataEntityListItem"]; + for (auto dataNodeDataEntityListDataEntityListItem : allDataEntityListNode) + { + Data::DataEntityListItem dataEntityListItemObject; + if(!dataNodeDataEntityListDataEntityListItem["CreateTimestamp"].isNull()) + dataEntityListItemObject.createTimestamp = std::stol(dataNodeDataEntityListDataEntityListItem["CreateTimestamp"].asString()); + auto allRelationListNode = dataNodeDataEntityListDataEntityListItem["RelationList"]["RelationListItem"]; + for (auto dataNodeDataEntityListDataEntityListItemRelationListRelationListItem : allRelationListNode) + { + Data::DataEntityListItem::RelationListItem relationListObject; + if(!dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Guid"].isNull()) + relationListObject.guid = dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Guid"].asString(); + if(!dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Datasource"].isNull()) + relationListObject.datasource = dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Datasource"].asString(); + if(!dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Type"].isNull()) + relationListObject.type = dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Type"].asString(); + if(!dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Channel"].isNull()) + relationListObject.channel = dataNodeDataEntityListDataEntityListItemRelationListRelationListItem["Channel"].asString(); + dataEntityListItemObject.relationList.push_back(relationListObject); + } + auto entityNode = value["Entity"]; + if(!entityNode["QualifiedName"].isNull()) + dataEntityListItemObject.entity.qualifiedName = entityNode["QualifiedName"].asString(); + if(!entityNode["TenantId"].isNull()) + dataEntityListItemObject.entity.tenantId = std::stol(entityNode["TenantId"].asString()); + if(!entityNode["EntityContent"].isNull()) + dataEntityListItemObject.entity.entityContent = entityNode["EntityContent"].asString(); + data_.dataEntityList.push_back(dataEntityListItemObject); + } + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + +} + +int ListLineageResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +ListLineageResult::Data ListLineageResult::getData()const +{ + return data_; +} + +std::string ListLineageResult::getErrorCode()const +{ + return errorCode_; +} + +std::string ListLineageResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool ListLineageResult::getSuccess()const +{ + return success_; +} + diff --git a/dataworks-public/src/model/RegisterLineageRelationRequest.cc b/dataworks-public/src/model/RegisterLineageRelationRequest.cc new file mode 100644 index 000000000..2765f2ac8 --- /dev/null +++ b/dataworks-public/src/model/RegisterLineageRelationRequest.cc @@ -0,0 +1,45 @@ +/* + * 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::Dataworks_public::Model::RegisterLineageRelationRequest; + +RegisterLineageRelationRequest::RegisterLineageRelationRequest() + : RpcServiceRequest("dataworks-public", "2020-05-18", "RegisterLineageRelation") { + setMethod(HttpRequest::Method::Post); +} + +RegisterLineageRelationRequest::~RegisterLineageRelationRequest() {} + +RegisterLineageRelationRequest::LineageRelationRegisterVO RegisterLineageRelationRequest::getLineageRelationRegisterVO() const { + return lineageRelationRegisterVO_; +} + +void RegisterLineageRelationRequest::setLineageRelationRegisterVO(const RegisterLineageRelationRequest::LineageRelationRegisterVO &lineageRelationRegisterVO) { + lineageRelationRegisterVO_ = lineageRelationRegisterVO; + setBodyParameter(std::string("LineageRelationRegisterVO") + ".DestEntity.ParentName", lineageRelationRegisterVO.destEntity.parentName); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".DestEntity.QualifiedName", lineageRelationRegisterVO.destEntity.qualifiedName); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".DestEntity.Name", lineageRelationRegisterVO.destEntity.name); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".DestEntity.DetailUrl", lineageRelationRegisterVO.destEntity.detailUrl); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".CreateTimestamp", std::to_string(lineageRelationRegisterVO.createTimestamp)); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".Relationship.Type", lineageRelationRegisterVO.relationship.type); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".SrcEntity.ParentName", lineageRelationRegisterVO.srcEntity.parentName); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".SrcEntity.QualifiedName", lineageRelationRegisterVO.srcEntity.qualifiedName); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".SrcEntity.Name", lineageRelationRegisterVO.srcEntity.name); + setBodyParameter(std::string("LineageRelationRegisterVO") + ".SrcEntity.DetailUrl", lineageRelationRegisterVO.srcEntity.detailUrl); +} + diff --git a/dataworks-public/src/model/RegisterLineageRelationResult.cc b/dataworks-public/src/model/RegisterLineageRelationResult.cc new file mode 100644 index 000000000..eb4aa2c27 --- /dev/null +++ b/dataworks-public/src/model/RegisterLineageRelationResult.cc @@ -0,0 +1,84 @@ +/* + * 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::Dataworks_public; +using namespace AlibabaCloud::Dataworks_public::Model; + +RegisterLineageRelationResult::RegisterLineageRelationResult() : + ServiceResult() +{} + +RegisterLineageRelationResult::RegisterLineageRelationResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +RegisterLineageRelationResult::~RegisterLineageRelationResult() +{} + +void RegisterLineageRelationResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto lineageRelationNode = value["LineageRelation"]; + if(!lineageRelationNode["SrcEntityQualifiedName"].isNull()) + lineageRelation_.srcEntityQualifiedName = lineageRelationNode["SrcEntityQualifiedName"].asString(); + if(!lineageRelationNode["DestEntityQualifiedName"].isNull()) + lineageRelation_.destEntityQualifiedName = lineageRelationNode["DestEntityQualifiedName"].asString(); + if(!lineageRelationNode["RelationshipGuid"].isNull()) + lineageRelation_.relationshipGuid = lineageRelationNode["RelationshipGuid"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + +} + +RegisterLineageRelationResult::LineageRelation RegisterLineageRelationResult::getLineageRelation()const +{ + return lineageRelation_; +} + +int RegisterLineageRelationResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string RegisterLineageRelationResult::getErrorCode()const +{ + return errorCode_; +} + +std::string RegisterLineageRelationResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool RegisterLineageRelationResult::getSuccess()const +{ + return success_; +} +