Added Impala and Flink engines support.

assembly/src/main/assembly/assembly.xml

@@ -218,6 +218,48 @@
       </includes>
     </fileSet>
 
+    <!--impala-->
+    <fileSet>
+      <directory>
+        ${project.parent.basedir}/ujes/definedEngines/impala/entrance/target/
+      </directory>
+      <outputDirectory>share/linkis/ujes/impala</outputDirectory>
+      <includes>
+        <include>*.zip</include>
+      </includes>
+    </fileSet>
+
+    <fileSet>
+      <directory>
+        ${project.parent.basedir}/ujes/definedEngines/impala/enginemanager/target/
+      </directory>
+      <outputDirectory>share/linkis/ujes/impala</outputDirectory>
+      <includes>
+        <include>*.zip</include>
+      </includes>
+    </fileSet>
+
+    <!--flink-->
+    <fileSet>
+      <directory>
+        ${project.parent.basedir}/ujes/definedEngines/flink/entrance/target/
+      </directory>
+      <outputDirectory>share/linkis/ujes/flink</outputDirectory>
+      <includes>
+        <include>*.zip</include>
+      </includes>
+    </fileSet>
+
+    <fileSet>
+      <directory>
+        ${project.parent.basedir}/ujes/definedEngines/flink/enginemanager/target/
+      </directory>
+      <outputDirectory>share/linkis/ujes/flink</outputDirectory>
+      <includes>
+        <include>*.zip</include>
+      </includes>
+    </fileSet>
+
     <!--resourcemanager-->
     <fileSet>
       <directory>

pom.xml

@@ -120,6 +120,14 @@
 
         <module>ujes/definedEngines/es/entrance</module>
 
+        <module>ujes/definedEngines/impala/engine</module>
+        <module>ujes/definedEngines/impala/enginemanager</module>
+        <module>ujes/definedEngines/impala/entrance</module>
+
+        <module>ujes/definedEngines/flink/engine</module>
+        <module>ujes/definedEngines/flink/enginemanager</module>
+        <module>ujes/definedEngines/flink/entrance</module>
+
         <module>gateway/core</module>
         <module>gateway/springcloudgateway</module>
         <module>gateway/gateway-ujes-support</module>
@@ -569,6 +577,42 @@
                 <version>${project.version}</version>
             </dependency>
 
+            <dependency>
+                <groupId>com.webank.wedatasphere.linkis</groupId>
+                <artifactId>linkis-ujes-impala-engine</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.webank.wedatasphere.linkis</groupId>
+                <artifactId>linkis-ujes-impala-enginemanager</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.webank.wedatasphere.linkis</groupId>
+                <artifactId>linkis-ujes-impala-entracne</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.webank.wedatasphere.linkis</groupId>
+                <artifactId>linkis-ujes-flink-engine</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.webank.wedatasphere.linkis</groupId>
+                <artifactId>linkis-ujes-flink-enginemanager</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.webank.wedatasphere.linkis</groupId>
+                <artifactId>linkis-ujes-flink-entracne</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+
             <dependency>
                 <groupId>com.webank.wedatasphere.linkis</groupId>
                 <artifactId>linkis-variable</artifactId>

ujes/definedEngines/flink/engine/.gitignore

@@ -0,0 +1 @@
+/target/

ujes/definedEngines/flink/engine/README.md

@@ -0,0 +1,5 @@
+1、支持datastream、SQL 开发
+2、支持dev、prod 环境
+3、支持SQL dev环境下的结果集自动获取，包括批流。
+4、支持多版本、多集群模型
+5、支持hive catalog模式