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,6 +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.util.Strings;
 import io.grpc.StatusRuntimeException;
 import io.vitess.proto.Query;
@@ -391,4 +392,14 @@ protected Map<String, ConfigValue> validateAllFields(Configuration config) {
         }
         return results;
     }
+
+    @Override
+    public List<DataCollection> 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());
+    }
 }