[Feature][Connector-V2][Tablestore] Support Source connector for Tab…

…lestore apache#7448

seatunnel-connectors-v2/connector-tablestore/src/main/java/org/apache/seatunnel/connectors/seatunnel/tablestore/source/TableStoreDBSource.java

@@ -25,8 +25,8 @@
 import org.apache.seatunnel.api.source.SourceSplitEnumerator;
 import org.apache.seatunnel.api.source.SupportColumnProjection;
 import org.apache.seatunnel.api.source.SupportParallelism;
+import org.apache.seatunnel.api.table.catalog.CatalogTable;
 import org.apache.seatunnel.api.table.catalog.CatalogTableUtil;
-import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
 import org.apache.seatunnel.common.constants.JobMode;
@@ -35,6 +35,9 @@
 import com.google.auto.service.AutoService;
 import lombok.extern.slf4j.Slf4j;
 
+import java.util.ArrayList;
+import java.util.List;
+
 @Slf4j
 @AutoService(SeaTunnelSource.class)
 public class TableStoreDBSource
@@ -51,6 +54,13 @@ public String getPluginName() {
         return "Tablestore";
     }
 
+    @Override
+    public List<CatalogTable> getProducedCatalogTables() {
+        List<CatalogTable> list = new ArrayList<>();
+
+        return SeaTunnelSource.super.getProducedCatalogTables();
+    }
+
     public TableStoreDBSource(ReadonlyConfig config) {
         this.tablestoreOptions = TablestoreOptions.of(config);
         CatalogTableUtil.buildWithConfig(config);
@@ -64,11 +74,6 @@ public Boundedness getBoundedness() {
                 : Boundedness.UNBOUNDED;
     }
 
-    @Override
-    public SeaTunnelDataType<SeaTunnelRow> getProducedType() {
-        return this.typeInfo;
-    }
-
     @Override
     public SourceReader<SeaTunnelRow, TableStoreDBSourceSplit> createReader(Context readerContext)
             throws Exception {