Modify ListTaskFlowsByPage API. Add output parameters: CronBeginDate,…

… CronEndDate. Modified input parameter CronParam as ScheduleParam.

aliyun-java-sdk-dms-enterprise/ChangeLog.txt

@@ -1,3 +1,6 @@
+2023-05-26 Version: 1.49.0
+- Modify ListTaskFlowsByPage API. Add output parameters: CronBeginDate, CronEndDate. Modified input parameter CronParam as ScheduleParam.
+
 2023-05-15 Version: 1.48.0
 - Support SkipDataCorrectRowCheck API.
 

aliyun-java-sdk-dms-enterprise/pom.xml

@@ -4,7 +4,7 @@
   <groupId>com.aliyun</groupId>
   <artifactId>aliyun-java-sdk-dms-enterprise</artifactId>
   <packaging>jar</packaging>
-  <version>1.48.0</version>
+  <version>1.49.0</version>
   <name>aliyun-java-sdk-dms-enterprise</name>
   <url>http://www.aliyun.com</url>
   <description>Aliyun Open API SDK for Java

aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageRequest.java

@@ -0,0 +1,80 @@
+/*
+ * 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.
+ */
+
+package com.aliyuncs.dms_enterprise.model.v20181101;
+
+import com.aliyuncs.RpcAcsRequest;
+import com.aliyuncs.http.MethodType;
+import com.aliyuncs.dms_enterprise.Endpoint;
+
+/**
+ * @author auto create
+ * @version 
+ */
+public class AnalyzeSQLLineageRequest extends RpcAcsRequest<AnalyzeSQLLineageResponse> {
+
+
+	private String sqlContent;
+
+	private Long tid;
+
+	private Long dbId;
+	public AnalyzeSQLLineageRequest() {
+		super("dms-enterprise", "2018-11-01", "AnalyzeSQLLineage", "dms-enterprise");
+		setMethod(MethodType.POST);
+		try {
+			com.aliyuncs.AcsRequest.class.getDeclaredField("productEndpointMap").set(this, Endpoint.endpointMap);
+			com.aliyuncs.AcsRequest.class.getDeclaredField("productEndpointRegional").set(this, Endpoint.endpointRegionalType);
+		} catch (Exception e) {}
+	}
+
+	public String getSqlContent() {
+		return this.sqlContent;
+	}
+
+	public void setSqlContent(String sqlContent) {
+		this.sqlContent = sqlContent;
+		if(sqlContent != null){
+			putQueryParameter("SqlContent", sqlContent);
+		}
+	}
+
+	public Long getTid() {
+		return this.tid;
+	}
+
+	public void setTid(Long tid) {
+		this.tid = tid;
+		if(tid != null){
+			putQueryParameter("Tid", tid.toString());
+		}
+	}
+
+	public Long getDbId() {
+		return this.dbId;
+	}
+
+	public void setDbId(Long dbId) {
+		this.dbId = dbId;
+		if(dbId != null){
+			putQueryParameter("DbId", dbId.toString());
+		}
+	}
+
+	@Override
+	public Class<AnalyzeSQLLineageResponse> getResponseClass() {
+		return AnalyzeSQLLineageResponse.class;
+	}
+
+}

aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageResponse.java

@@ -0,0 +1,242 @@
+/*
+ * 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.
+ */
+
+package com.aliyuncs.dms_enterprise.model.v20181101;
+
+import java.util.List;
+import com.aliyuncs.AcsResponse;
+import com.aliyuncs.dms_enterprise.transform.v20181101.AnalyzeSQLLineageResponseUnmarshaller;
+import com.aliyuncs.transform.UnmarshallerContext;
+
+/**
+ * @author auto create
+ * @version 
+ */
+public class AnalyzeSQLLineageResponse extends AcsResponse {
+
+	private String requestId;
+
+	private Boolean success;
+
+	private String errorMessage;
+
+	private String errorCode;
+
+	private LineageResult lineageResult;
+
+	public String getRequestId() {
+		return this.requestId;
+	}
+
+	public void setRequestId(String requestId) {
+		this.requestId = requestId;
+	}
+
+	public Boolean getSuccess() {
+		return this.success;
+	}
+
+	public void setSuccess(Boolean success) {
+		this.success = success;
+	}
+
+	public String getErrorMessage() {
+		return this.errorMessage;
+	}
+
+	public void setErrorMessage(String errorMessage) {
+		this.errorMessage = errorMessage;
+	}
+
+	public String getErrorCode() {
+		return this.errorCode;
+	}
+
+	public void setErrorCode(String errorCode) {
+		this.errorCode = errorCode;
+	}
+
+	public LineageResult getLineageResult() {
+		return this.lineageResult;
+	}
+
+	public void setLineageResult(LineageResult lineageResult) {
+		this.lineageResult = lineageResult;
+	}
+
+	public static class LineageResult {
+
+		private List<LineageItem> lineages;
+
+		private List<ObjectMetadataItem> objectMetadata;
+
+		public List<LineageItem> getLineages() {
+			return this.lineages;
+		}
+
+		public void setLineages(List<LineageItem> lineages) {
+			this.lineages = lineages;
+		}
+
+		public List<ObjectMetadataItem> getObjectMetadata() {
+			return this.objectMetadata;
+		}
+
+		public void setObjectMetadata(List<ObjectMetadataItem> objectMetadata) {
+			this.objectMetadata = objectMetadata;
+		}
+
+		public static class LineageItem {
+
+			private String lineageType;
+
+			private String src;
+
+			private String dst;
+
+			private String operType;
+
+			private ProcessDetail processDetail;
+
+			public String getLineageType() {
+				return this.lineageType;
+			}
+
+			public void setLineageType(String lineageType) {
+				this.lineageType = lineageType;
+			}
+
+			public String getSrc() {
+				return this.src;
+			}
+
+			public void setSrc(String src) {
+				this.src = src;
+			}
+
+			public String getDst() {
+				return this.dst;
+			}
+
+			public void setDst(String dst) {
+				this.dst = dst;
+			}
+
+			public String getOperType() {
+				return this.operType;
+			}
+
+			public void setOperType(String operType) {
+				this.operType = operType;
+			}
+
+			public ProcessDetail getProcessDetail() {
+				return this.processDetail;
+			}
+
+			public void setProcessDetail(ProcessDetail processDetail) {
+				this.processDetail = processDetail;
+			}
+
+			public static class ProcessDetail {
+
+				private String code;
+
+				private String calWay;
+
+				public String getCode() {
+					return this.code;
+				}
+
+				public void setCode(String code) {
+					this.code = code;
+				}
+
+				public String getCalWay() {
+					return this.calWay;
+				}
+
+				public void setCalWay(String calWay) {
+					this.calWay = calWay;
+				}
+			}
+		}
+
+		public static class ObjectMetadataItem {
+
+			private String name;
+
+			private String type;
+
+			private String source;
+
+			private List<Field> fields;
+
+			public String getName() {
+				return this.name;
+			}
+
+			public void setName(String name) {
+				this.name = name;
+			}
+
+			public String getType() {
+				return this.type;
+			}
+
+			public void setType(String type) {
+				this.type = type;
+			}
+
+			public String getSource() {
+				return this.source;
+			}
+
+			public void setSource(String source) {
+				this.source = source;
+			}
+
+			public List<Field> getFields() {
+				return this.fields;
+			}
+
+			public void setFields(List<Field> fields) {
+				this.fields = fields;
+			}
+
+			public static class Field {
+
+				private String name;
+
+				public String getName() {
+					return this.name;
+				}
+
+				public void setName(String name) {
+					this.name = name;
+				}
+			}
+		}
+	}
+
+	@Override
+	public AnalyzeSQLLineageResponse getInstance(UnmarshallerContext context) {
+		return	AnalyzeSQLLineageResponseUnmarshaller.unmarshall(this, context);
+	}
+
+	@Override
+	public boolean checkShowJsonItemName() {
+		return false;
+	}
+}

aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillRequest.java

@@ -41,6 +41,9 @@ public class BackFillRequest extends RpcAcsRequest<BackFillResponse> {
 	@SerializedName("startNodeIds")
 	private List<Long> startNodeIds;
 
+	@SerializedName("filterNodeIds")
+	private List<Long> filterNodeIds;
+
 	private String backFillDateBegin;
 
 	private String backFillDate;
@@ -123,6 +126,17 @@ public void setStartNodeIds(List<Long> startNodeIds) {
 		}	
 	}
 
+	public List<Long> getFilterNodeIds() {
+		return this.filterNodeIds;
+	}
+
+	public void setFilterNodeIds(List<Long> filterNodeIds) {
+		this.filterNodeIds = filterNodeIds;	
+		if (filterNodeIds != null) {
+			putQueryParameter("FilterNodeIds" , new Gson().toJson(filterNodeIds));
+		}	
+	}
+
 	public String getBackFillDateBegin() {
 		return this.backFillDateBegin;
 	}

aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillResponse.java

@@ -32,6 +32,8 @@ public class BackFillResponse extends AcsResponse {
 
 	private Boolean success;
 
+	private Long dagInstanceId;
+
 	private Long nodeId;
 
 	public String getRequestId() {
@@ -66,6 +68,14 @@ public void setSuccess(Boolean success) {
 		this.success = success;
 	}
 
+	public Long getDagInstanceId() {
+		return this.dagInstanceId;
+	}
+
+	public void setDagInstanceId(Long dagInstanceId) {
+		this.dagInstanceId = dagInstanceId;
+	}
+
 	public Long getNodeId() {
 		return this.nodeId;
 	}