The data import and export service module provides an interface for data import and export. fix #380

Author: JackChen0810

dss-apps/dss-datapipe-server/src/main/java/com/webank/wedatasphere/dss/datapipe/config/DataPipeServiceConfiguration.java

@@ -18,11 +18,7 @@
 
 import com.webank.wedatasphere.linkis.common.conf.CommonVars;
 
-/**
- * @author allenlliu
- * @version 2.0.0
- * @date 2020/08/12 03:46 PM
- */
+
 public class DataPipeServiceConfiguration {
     public final static CommonVars<String> LINKIS_AUTHOR_USER_TOKEN = CommonVars.apply("wds.linkis.client.api.service.author.user.token","172.0.0.1");
     public final static CommonVars<String> LINKIS_ADMIN_USER = CommonVars.apply("wds.linkis.client.api.service.adminuser","ws");

dss-apps/dss-datapipe-server/src/main/java/com/webank/wedatasphere/dss/datapipe/dao/DataPipeDao.java

@@ -17,11 +17,7 @@
 package com.webank.wedatasphere.dss.datapipe.dao;
 
 
-/**
- * dao
- *
- * @author zhulixin
- */
+
 public interface DataPipeDao {
 
 

dss-apps/dss-datapipe-server/src/main/java/com/webank/wedatasphere/dss/datapipe/exception/DataPipeExecuteException.java

@@ -18,11 +18,7 @@
 
 import com.webank.wedatasphere.linkis.common.exception.ErrorException;
 
-/**
- * @author allenlliu
- * @version 2.0.0
- * @date 2020/08/31 02:31 PM
- */
+
 public class DataPipeExecuteException extends ErrorException {
 
         public DataPipeExecuteException(int errCode, String desc) {

dss-apps/dss-datapipe-server/src/main/java/com/webank/wedatasphere/dss/datapipe/execute/LinkisJobSubmit.java

@@ -31,11 +31,7 @@
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
-/**
- * @author allenlliu
- * @version 2.0.0
- * @date 2020/08/12 03:33 PM
- */
+
 public class LinkisJobSubmit {
 
     public static UJESClient getClient(Map<String, String> props) {

dss-apps/dss-datapipe-server/src/main/java/com/webank/wedatasphere/dss/datapipe/restful/DSSEntranceRestfulApi.java

@@ -43,9 +43,7 @@
 import java.util.HashMap;
 import java.util.Map;
 
-/**
- * created by v_wbzwchen on 2021/04/28
- */
+
 @Path("/dss/datapipe")
 @Component
 @Produces(MediaType.APPLICATION_JSON)

dss-apps/dss-datapipe-server/src/main/scala/com/webank/wedatasphere/dss/datapipe/entrance/background/AbstractBackGroundService.scala

@@ -16,9 +16,7 @@
 
 package com.webank.wedatasphere.dss.datapipe.entrance.background
 
-/**
-  * Created by enjoyyin on 2018/12/4.
-  */
+
 abstract class AbstractBackGroundService extends BackGroundService{
 
 }

dss-apps/dss-datapipe-server/src/main/scala/com/webank/wedatasphere/dss/datapipe/entrance/background/BackGroundService.scala

@@ -18,9 +18,7 @@ package com.webank.wedatasphere.dss.datapipe.entrance.background
 
 import com.webank.wedatasphere.linkis.server.socket.controller.ServerEvent
 
-/**
-  * Created by enjoyyin on 2018/12/4.
-  */
+
 trait BackGroundService {
   val serviceType:String
   def operation(serverEvent: ServerEvent):ServerEvent

dss-apps/dss-datapipe-server/src/main/scala/com/webank/wedatasphere/dss/datapipe/entrance/background/BackGroundServiceUtils.scala

@@ -33,9 +33,6 @@ import com.webank.wedatasphere.linkis.storage.utils.FileSystemUtils
 import org.apache.commons.io.IOUtils
 import org.apache.commons.lang.time.DateFormatUtils
 
-/**
-  * Created by v_wbjftang on 2019/2/25.
-  */
 object BackGroundServiceUtils extends Logging {
 
   private val CODE_STORE_PREFIX = CommonVars("bdp.dataworkcloud.bgservice.store.prefix", "hdfs:///tmp/bdp-ide/")

dss-apps/dss-datapipe-server/src/main/scala/com/webank/wedatasphere/dss/datapipe/entrance/background/ExportBackGroundService.scala

@@ -24,9 +24,7 @@ import com.webank.wedatasphere.linkis.common.utils.Logging
 import com.webank.wedatasphere.linkis.server._
 import com.webank.wedatasphere.linkis.server.socket.controller.ServerEvent
 
-/**
-  * Created by allenlliu on 2018/12/4.
-  */
+
 class ExportBackGroundService extends AbstractBackGroundService with Logging{
   override val serviceType: String = "export"
 

dss-apps/dss-datapipe-server/src/main/scala/com/webank/wedatasphere/dss/datapipe/entrance/background/LoadBackGroundService.scala

@@ -22,9 +22,7 @@ import com.google.gson.{JsonObject, JsonParser}
 import com.webank.wedatasphere.linkis.server._
 import com.webank.wedatasphere.linkis.server.socket.controller.ServerEvent
 
-/**
-  * Created by allenlliu on 2018/12/4.
-  */
+
 class LoadBackGroundService extends AbstractBackGroundService {
 
   override val serviceType: String = "load"