Skip to content

Commit 99b7403

Browse files
sargenttisargentti
committed
Add DSS Commons module.
1 parent bb04bb3 commit 99b7403

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

51 files changed

+3489
-0
lines changed

‎dss-commons/dss-common/pom.xml

Lines changed: 116 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,116 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<!--
3+
~ Copyright 2019 WeBank
4+
~ Licensed under the Apache License, Version 2.0 (the "License");
5+
~ you may not use this file except in compliance with the License.
6+
~ You may obtain a copy of the License at
7+
~
8+
~ http://www.apache.org/licenses/LICENSE-2.0
9+
~
10+
~ Unless required by applicable law or agreed to in writing, software
11+
~ distributed under the License is distributed on an "AS IS" BASIS,
12+
~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
~ See the License for the specific language governing permissions and
14+
~ limitations under the License.
15+
~
16+
-->
17+
18+
<project xmlns="http://maven.apache.org/POM/4.0.0"
19+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
20+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
21+
<modelVersion>4.0.0</modelVersion>
22+
<parent>
23+
<artifactId>dss-commons</artifactId>
24+
<groupId>com.webank.wedatasphere.dss</groupId>
25+
<version>1.0.0</version>
26+
</parent>
27+
<artifactId>dss-common</artifactId>
28+
29+
<dependencies>
30+
<dependency>
31+
<groupId>com.webank.wedatasphere.linkis</groupId>
32+
<artifactId>linkis-common</artifactId>
33+
</dependency>
34+
<dependency>
35+
<groupId>com.google.code.gson</groupId>
36+
<artifactId>gson</artifactId>
37+
</dependency>
38+
<dependency>
39+
<groupId>com.fasterxml.jackson.core</groupId>
40+
<artifactId>jackson-databind</artifactId>
41+
</dependency>
42+
<dependency>
43+
<groupId>org.codehaus.jackson</groupId>
44+
<artifactId>jackson-mapper-asl</artifactId>
45+
</dependency>
46+
<dependency>
47+
<groupId>org.scala-lang</groupId>
48+
<artifactId>scala-library</artifactId>
49+
</dependency>
50+
<dependency>
51+
<groupId>org.scala-lang</groupId>
52+
<artifactId>scala-compiler</artifactId>
53+
</dependency>
54+
<dependency>
55+
<groupId>org.scala-lang</groupId>
56+
<artifactId>scala-reflect</artifactId>
57+
</dependency>
58+
<dependency>
59+
<groupId>org.scala-lang</groupId>
60+
<artifactId>scalap</artifactId>
61+
</dependency>
62+
<dependency>
63+
<groupId>commons-lang</groupId>
64+
<artifactId>commons-lang</artifactId>
65+
</dependency>
66+
<dependency>
67+
<groupId>com.webank.wedatasphere.linkis</groupId>
68+
<artifactId>linkis-label-common</artifactId>
69+
<version>${linkis.version}</version>
70+
</dependency>
71+
<dependency>
72+
<groupId>com.webank.wedatasphere.linkis</groupId>
73+
<artifactId>linkis-protocol</artifactId>
74+
<version>${linkis.version}</version>
75+
</dependency>
76+
</dependencies>
77+
78+
<build>
79+
<plugins>
80+
<plugin>
81+
<groupId>org.apache.maven.plugins</groupId>
82+
<artifactId>maven-compiler-plugin</artifactId>
83+
<version>3.3</version>
84+
<configuration>
85+
<source>1.8</source>
86+
<target>1.8</target>
87+
<encoding>UTF-8</encoding>
88+
</configuration>
89+
</plugin>
90+
<plugin>
91+
<groupId>org.apache.maven.plugins</groupId>
92+
<artifactId>maven-deploy-plugin</artifactId>
93+
</plugin>
94+
95+
<plugin>
96+
<groupId>net.alchim31.maven</groupId>
97+
<artifactId>scala-maven-plugin</artifactId>
98+
</plugin>
99+
<plugin>
100+
<groupId>org.apache.maven.plugins</groupId>
101+
<artifactId>maven-jar-plugin</artifactId>
102+
</plugin>
103+
</plugins>
104+
</build>
105+
<profiles>
106+
<profile>
107+
<id>product</id>
108+
<properties>
109+
<project.release.version>1.0.0-SNAPSHOT</project.release.version>
110+
</properties>
111+
</profile>
112+
</profiles>
113+
114+
115+
116+
</project>

‎dss-commons/dss-common/src/main/java/com/webank/wedatasphere/dss/common/conf/DSSCommonConf.java

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.common.conf;
18+
19+
import com.webank.wedatasphere.linkis.common.conf.CommonVars;
20+
21+
/**
22+
* @Author alexyang
23+
* @Date 2020/3/27
24+
*/
25+
public class DSSCommonConf {
26+
27+
public static final CommonVars<String> DSS_IO_ENV = CommonVars.apply("wds.dss.server.io.env", "BDAP_DEV");
28+
public static final CommonVars<String> DSS_EXPORT_ENV = CommonVars.apply("wds.dss.server.export.env", "生产中心");
29+
30+
public static final CommonVars<String> DSS_EXPORT_URL = CommonVars.apply("wds.dss.server.export.url", "/appcom/tmp/dss");
31+
public static final CommonVars<String> DSS_INPUT_TOKEN = CommonVars.apply("wds.dss.server.input.token", "QML-AUTH");
32+
33+
public static final CommonVars<String> DSS_UPLOAD_PATH = CommonVars.apply("wds.dss.file.upload.dir", "/appcom/tmp/uploads");
34+
public static final CommonVars<String> DSS_INPUT_RESTFUL_URL = CommonVars.apply("wds.dss.server.input.url", "http://localhost:9004/api/rest_j/v1/dss/input");
35+
36+
37+
}

‎dss-commons/dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/DSSWorkspace.java

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.common.entity;
18+
19+
/**
20+
* Created by enjoyyin on 2021/7/1.
21+
*/
22+
public interface DSSWorkspace {
23+
24+
String getWorkspaceName();
25+
26+
}

‎dss-commons/dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/IOEnv.java

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.common.entity;
18+
19+
public enum IOEnv {
20+
/**
21+
*
22+
*/
23+
BDP_DEV,BDP_PRODUCTION,BDAP_DEV,BDAP_PRODUCTION
24+
}

‎dss-commons/dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/IOType.java

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.common.entity;
18+
19+
public enum IOType {
20+
/**
21+
* 区分工程导出和工作流导出
22+
* basepath/IO.properties
23+
* type=PROJECT 或者 type=FLOE
24+
*/
25+
PROJECT,FLOW,ORCHESTRATOR
26+
}

‎dss-commons/dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/InputRelation.java

Lines changed: 75 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,75 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.common.entity;
18+
19+
public class InputRelation {
20+
21+
private Long id;
22+
private String type;
23+
private IOEnv sourceEnv;
24+
private Long sourceID;
25+
private IOEnv targetEnv;
26+
private Long targetID;
27+
28+
public Long getId() {
29+
return id;
30+
}
31+
32+
public void setId(Long id) {
33+
this.id = id;
34+
}
35+
36+
public String getType() {
37+
return type;
38+
}
39+
40+
public void setType(String type) {
41+
this.type = type;
42+
}
43+
44+
public IOEnv getSourceEnv() {
45+
return sourceEnv;
46+
}
47+
48+
public void setSourceEnv(IOEnv sourceEnv) {
49+
this.sourceEnv = sourceEnv;
50+
}
51+
52+
public Long getSourceID() {
53+
return sourceID;
54+
}
55+
56+
public void setSourceID(Long sourceID) {
57+
this.sourceID = sourceID;
58+
}
59+
60+
public IOEnv getTargetEnv() {
61+
return targetEnv;
62+
}
63+
64+
public void setTargetEnv(IOEnv targetEnv) {
65+
this.targetEnv = targetEnv;
66+
}
67+
68+
public Long getTargetID() {
69+
return targetID;
70+
}
71+
72+
public void setTargetID(Long targetID) {
73+
this.targetID = targetID;
74+
}
75+
}

‎dss-commons/dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/PublishType.java

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.common.entity;
18+
19+
/**
20+
* @author allenlliu
21+
* @date 2020/12/16 11:53
22+
*/
23+
public enum PublishType {
24+
FULL,DELTA
25+
}

‎dss-commons/dss-common/src/main/java/com/webank/wedatasphere/dss/common/entity/Resource.java

Lines changed: 58 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,58 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.common.entity;
18+
19+
import java.io.Serializable;
20+
21+
public class Resource implements Serializable {
22+
private String fileName;
23+
private String resourceId;
24+
private String version;
25+
26+
public String getFileName() {
27+
return fileName;
28+
}
29+
30+
public void setFileName(String fileName) {
31+
this.fileName = fileName;
32+
}
33+
34+
public String getResourceId() {
35+
return resourceId;
36+
}
37+
38+
public void setResourceId(String resourceId) {
39+
this.resourceId = resourceId;
40+
}
41+
42+
public String getVersion() {
43+
return version;
44+
}
45+
46+
public void setVersion(String version) {
47+
this.version = version;
48+
}
49+
50+
/* @Override
51+
public String toString() {
52+
return "{" +
53+
"fileName='" + fileName + '\'' +
54+
", resourceId='" + resourceId + '\'' +
55+
", version='" + version + '\'' +
56+
'}';
57+
}*/
58+
}

0 commit comments

Comments
 (0)