DBZ-7167 Provide a public API from the connector implementations to r…

…etrieve the list of matching collections or tables based on the different include-/exclude lists

src/main/java/io/debezium/connector/vitess/VitessConnector.java

@@ -32,7 +32,7 @@
 import io.debezium.connector.common.RelationalBaseSourceConnector;
 import io.debezium.connector.vitess.connection.VitessReplicationConnection;
 import io.debezium.relational.RelationalDatabaseConnectorConfig;
-import io.debezium.rest.model.DataCollection;
+import io.debezium.relational.TableId;
 import io.debezium.util.Strings;
 import io.grpc.StatusRuntimeException;
 import io.vitess.proto.Query;
@@ -393,13 +393,16 @@ protected Map<String, ConfigValue> validateAllFields(Configuration config) {
         return results;
     }
 
+    @SuppressWarnings("unchecked")
     @Override
-    public List<DataCollection> getMatchingCollections(Configuration configuration) {
+    public List<TableId> getMatchingCollections(Configuration configuration) {
         VitessConnectorConfig vitessConnectorConfig = new VitessConnectorConfig(configuration);
         String keyspace = vitessConnectorConfig.getKeyspace();
         List<String> allTables = getKeyspaceTables(vitessConnectorConfig);
         List<String> includedTables = getIncludedTables(keyspace,
                 vitessConnectorConfig.tableIncludeList(), allTables);
-        return includedTables.stream().map(table -> new DataCollection(keyspace, table)).collect(Collectors.toList());
+        return includedTables.stream()
+                .map(table -> new TableId(keyspace, null, table))
+                .collect(Collectors.toList());
     }
 }