冲突解决

src/main/java/com/jz/dmp/cmdexectool/common/constant/CommConstant.java

@@ -61,6 +61,7 @@ public class CommConstant {
 	public static final String WATERDROP_FTL_SINK_JDBC = "sink_jdbc.ftl";
 	public static final String WATERDROP_FTL_SINK_KAFKA = "sink_kafka.ftl";
 	public static final String WATERDROP_FTL_SINK_API = "sink_api.ftl";
+	public static final String WATERDROP_FTL_SINK_KUDU = "source_sink_kudu.ftl";
 	
 	//其他script模板
 	public static final String FTL_SFTP_DOWNLOAD = "sftp_download.ftl";//ftp下载
@@ -73,4 +74,10 @@ public class CommConstant {
 	public static final String EXECUTION_ENGINE_JDBC = "jdbc";//jdbc
 	public static final String EXECUTION_ENGINE_SPARK = "spark";//spark
 	
+	/***************************************************/
+	//主键冲突处理方式
+	public static final String PRIMARY_KEY_CONFLICT_INSERT = "insert";
+	public static final String PRIMARY_KEY_CONFLICT_UPDATE = "update";
+	public static final String PRIMARY_KEY_CONFLICT_REPLACE = "replace";
+	
 }