Skip to content

Commit

Permalink
Dataphin openapi start.
Browse files Browse the repository at this point in the history
  • Loading branch information
sdk-team committed Dec 30, 2024
1 parent 9b9b28c commit a2281a3
Show file tree
Hide file tree
Showing 137 changed files with 19,136 additions and 1 deletion.
3 changes: 3 additions & 0 deletions aliyun-java-sdk-dataphin-public/ChangeLog.txt
Original file line number Diff line number Diff line change
@@ -1,3 +1,6 @@
2024-12-30 Version: 1.0.3
- Dataphin openapi start.

2024-10-11 Version: 1.0.2
- Dataphin v4.3 openapi.

Expand Down
2 changes: 1 addition & 1 deletion aliyun-java-sdk-dataphin-public/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-dataphin-public</artifactId>
<packaging>jar</packaging>
<version>1.0.2</version>
<version>1.0.3</version>
<name>aliyun-java-sdk-dataphin-public</name>
<url>http://www.aliyun.com</url>
<description>Aliyun Open API SDK for Java
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,192 @@
/*
* 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.dataphin_public.model.v20230630;

import com.aliyuncs.RpcAcsRequest;
import java.util.List;
import com.google.gson.Gson;
import com.google.gson.annotations.SerializedName;
import com.aliyuncs.http.ProtocolType;
import com.aliyuncs.http.MethodType;

/**
* @author auto create
* @version
*/
public class CreateBatchTaskRequest extends RpcAcsRequest<CreateBatchTaskResponse> {


private Long opTenantId;

@SerializedName("createCommand")
private CreateCommand createCommand;
public CreateBatchTaskRequest() {
super("dataphin-public", "2023-06-30", "CreateBatchTask");
setProtocol(ProtocolType.HTTPS);
setMethod(MethodType.POST);
}

public Long getOpTenantId() {
return this.opTenantId;
}

public void setOpTenantId(Long opTenantId) {
this.opTenantId = opTenantId;
if(opTenantId != null){
putQueryParameter("OpTenantId", opTenantId.toString());
}
}

public CreateCommand getCreateCommand() {
return this.createCommand;
}

public void setCreateCommand(CreateCommand createCommand) {
this.createCommand = createCommand;
if (createCommand != null) {
putBodyParameter("CreateCommand" , new Gson().toJson(createCommand));
}
}

public static class CreateCommand {

@SerializedName("ScheduleType")
private Integer scheduleType;

@SerializedName("TaskType")
private Integer taskType;

@SerializedName("Engine")
private String engine;

@SerializedName("Name")
private String name;

@SerializedName("DataSourceId")
private String dataSourceId;

@SerializedName("DataSourceSchema")
private String dataSourceSchema;

@SerializedName("Description")
private String description;

@SerializedName("DataSourceCatalog")
private String dataSourceCatalog;

@SerializedName("Directory")
private String directory;

@SerializedName("ProjectId")
private Long projectId;

@SerializedName("PythonModuleList")
private List<String> pythonModuleList;

public Integer getScheduleType() {
return this.scheduleType;
}

public void setScheduleType(Integer scheduleType) {
this.scheduleType = scheduleType;
}

public Integer getTaskType() {
return this.taskType;
}

public void setTaskType(Integer taskType) {
this.taskType = taskType;
}

public String getEngine() {
return this.engine;
}

public void setEngine(String engine) {
this.engine = engine;
}

public String getName() {
return this.name;
}

public void setName(String name) {
this.name = name;
}

public String getDataSourceId() {
return this.dataSourceId;
}

public void setDataSourceId(String dataSourceId) {
this.dataSourceId = dataSourceId;
}

public String getDataSourceSchema() {
return this.dataSourceSchema;
}

public void setDataSourceSchema(String dataSourceSchema) {
this.dataSourceSchema = dataSourceSchema;
}

public String getDescription() {
return this.description;
}

public void setDescription(String description) {
this.description = description;
}

public String getDataSourceCatalog() {
return this.dataSourceCatalog;
}

public void setDataSourceCatalog(String dataSourceCatalog) {
this.dataSourceCatalog = dataSourceCatalog;
}

public String getDirectory() {
return this.directory;
}

public void setDirectory(String directory) {
this.directory = directory;
}

public Long getProjectId() {
return this.projectId;
}

public void setProjectId(Long projectId) {
this.projectId = projectId;
}

public List<String> getPythonModuleList() {
return this.pythonModuleList;
}

public void setPythonModuleList(List<String> pythonModuleList) {
this.pythonModuleList = pythonModuleList;
}
}

@Override
public Class<CreateBatchTaskResponse> getResponseClass() {
return CreateBatchTaskResponse.class;
}

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,109 @@
/*
* 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.dataphin_public.model.v20230630;

import com.aliyuncs.AcsResponse;
import com.aliyuncs.dataphin_public.transform.v20230630.CreateBatchTaskResponseUnmarshaller;
import com.aliyuncs.transform.UnmarshallerContext;

/**
* @author auto create
* @version
*/
public class CreateBatchTaskResponse extends AcsResponse {

private String requestId;

private Boolean success;

private Integer httpStatusCode;

private String code;

private String message;

private CreateResult createResult;

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 Integer getHttpStatusCode() {
return this.httpStatusCode;
}

public void setHttpStatusCode(Integer httpStatusCode) {
this.httpStatusCode = httpStatusCode;
}

public String getCode() {
return this.code;
}

public void setCode(String code) {
this.code = code;
}

public String getMessage() {
return this.message;
}

public void setMessage(String message) {
this.message = message;
}

public CreateResult getCreateResult() {
return this.createResult;
}

public void setCreateResult(CreateResult createResult) {
this.createResult = createResult;
}

public static class CreateResult {

private Long fileId;

public Long getFileId() {
return this.fileId;
}

public void setFileId(Long fileId) {
this.fileId = fileId;
}
}

@Override
public CreateBatchTaskResponse getInstance(UnmarshallerContext context) {
return CreateBatchTaskResponseUnmarshaller.unmarshall(this, context);
}

@Override
public boolean checkShowJsonItemName() {
return false;
}
}
Loading

0 comments on commit a2281a3

Please sign in to comment.