提交代码

src/main/java/com/jz/dmp/cmdexectool/scheduler/dao/datasource/MyBaseDataSource.java

+package com.jz.dmp.cmdexectool.scheduler.dao.datasource;
+
+import com.jz.dmp.cmdexectool.scheduler.common.enums.DbType;
+import com.jz.dmp.cmdexectool.scheduler.common.enums.MyDbType;
+
+/**
+ * @ClassName: MyBaseDataSource
+ * @Description: TODO(DMP自定义的数据源)
+ * @author ybz
+ * @date 2021年3月5日
+ *
+ */
+public class MyBaseDataSource extends BaseDataSource{
+	
+	/**
+	 * 数据源类型
+	 */
+	private MyDbType myDbType;
+	
+	public MyDbType getMyDbType() {
+		return myDbType;
+	}
+
+	public void setMyDbType(MyDbType myDbType) {
+		this.myDbType = myDbType;
+	}
+
+	@Override
+	public String driverClassSelector() {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public DbType dbTypeSelector() {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+}

src/main/resources/templates/source_hive.ftl

+spark {
+<#if catalogImplementation??>
+  spark.sql.catalogImplementation = "${catalogImplementation!}"
+</#if>
+}
+
+hive {
+<#if pre_sql??>
+    # 进行预处理的sql, 如果不需要预处理,可以使用select * from hive_db.hive_table
+    pre_sql = "${pre_sql!}"
+</#if>
+<#if result_table_name??>
+    result_table_name = "${result_table_name!}"
+</#if>
+}
\ No newline at end of file