DatastreamToSQL - log schema map details

v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSQL.java

@@ -356,6 +356,7 @@
     CdcJdbcIO.DataSourceConfiguration dataSourceConfiguration = getDataSourceConfiguration(options);
     validateOptions(options, dataSourceConfiguration);
     Map<String, String> schemaMap = parseSchemaMap(options.getSchemaMap());
+    LOG.info("Parsed schema map: {}", schemaMap);
 
     /*
      * Stage 1: Ingest and Normalize Data to FailsafeElement with JSON Strings

v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/transforms/CreateDml.java

@@ -63,10 +63,12 @@
     String driverName = this.dataSourceConfiguration.getDriverClassName().get();
     switch (driverName) {
       case "org.postgresql.Driver":
-        datastreamToDML = DatastreamToPostgresDML.of(dataSourceConfiguration);
+        datastreamToDML =
+            DatastreamToPostgresDML.of(dataSourceConfiguration).withSchemaMap(this.schemaMap);
         break;
       case "com.mysql.cj.jdbc.Driver":
-        datastreamToDML = DatastreamToMySQLDML.of(dataSourceConfiguration);
+        datastreamToDML =
+            DatastreamToMySQLDML.of(dataSourceConfiguration).withSchemaMap(this.schemaMap);
         break;
       default:
         throw new IllegalArgumentException(

v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToDML.java

@@ -55,7 +55,7 @@ public abstract class DatastreamToDML
   private CdcJdbcIO.DataSourceConfiguration dataSourceConfiguration;
   private DataSource dataSource;
   public String quoteCharacter;
-  private static Map<String, String> schemaMap = new HashMap<String, String>();
+  protected Map<String, String> schemaMap = new HashMap<String, String>();
 
   public abstract String getDefaultQuoteCharacter();