enable flink-cdc pipeline mode

Author: baisui1981

tis-incr/tis-chunjun-base-plugin/src/main/java/com/qlangtech/tis/plugins/incr/flink/chunjun/script/ChunjunSqlType.java

@@ -27,6 +27,7 @@
 import com.qlangtech.tis.plugin.ds.IColMetaGetter;
 import com.qlangtech.tis.plugins.incr.flink.connector.ChunjunSinkFactory;
 import com.qlangtech.tis.plugins.incr.flink.connector.streamscript.BasicFlinkStreamScriptCreator;
+import com.qlangtech.tis.sql.parser.tuple.creator.AdapterStreamTemplateData;
 import com.qlangtech.tis.sql.parser.tuple.creator.IStreamIncrGenerateStrategy;
 
 import java.util.List;
@@ -68,7 +69,7 @@ public IStreamTemplateData decorateMergeData(IStreamTemplateData mergeData) {
         }
     }
 
-    public static class ChunjunTemplateData extends IStreamIncrGenerateStrategy.AdapterStreamTemplateData {
+    public static class ChunjunTemplateData extends AdapterStreamTemplateData {
         private IStreamTableMeataCreator.ISinkStreamMetaCreator sinkStreamMetaGetter;
         private final IEndTypeGetter.EndType endType;
 

tis-incr/tis-flink-extends/src/main/java/com/qlangtech/tis/realtime/DTOSourceTagProcessFunction.java

@@ -18,6 +18,7 @@
 
 package com.qlangtech.tis.realtime;
 
+import com.qlangtech.tis.datax.TableAlias;
 import com.qlangtech.tis.plugin.ds.ISelectedTab;
 import com.qlangtech.tis.realtime.transfer.DTO;
 import org.apache.flink.util.OutputTag;
@@ -29,13 +30,18 @@
 import java.util.stream.Stream;
 
 /**
- *
  * @author: 百岁（baisui@qlangtech.com）
  * @create: 2025-01-04 09:22
  **/
 public class DTOSourceTagProcessFunction extends SourceProcessFunction<DTO> {
     public static final String KEY_MERGE_ALL_TABS_IN_ONE_BUS = "merge_all_tabs_in_one_bus";
 
+    public static TableAlias createAllMergeTableAlias() {
+        return TableAlias.create(DTOSourceTagProcessFunction.KEY_MERGE_ALL_TABS_IN_ONE_BUS
+                , DTOSourceTagProcessFunction.KEY_MERGE_ALL_TABS_IN_ONE_BUS);
+    }
+
+
     public static Set<String> createFocusTabs(boolean flinkCDCPipelineEnable, List<ISelectedTab> tabs) {
         return (flinkCDCPipelineEnable
                 ? Stream.of(DTOSourceTagProcessFunction.KEY_MERGE_ALL_TABS_IN_ONE_BUS)