diff --git a/dbtng_migrator.batch.inc b/dbtng_migrator.batch.inc
index cb56ba0..8e70e2c 100644
--- a/dbtng_migrator.batch.inc
+++ b/dbtng_migrator.batch.inc
@@ -27,10 +27,13 @@ function dbtng_migrator_batch_install_schema($origin, $destination) {
   foreach ($modules as $module) {
     $schema = drupal_get_schema_unprocessed($module);
     _drupal_schema_initialize($schema, $module, FALSE);
+    $altered_schema = $schema;
+    drupal_alter('schema', $altered_schema);
 
     db_set_active($destination);
     foreach ($schema as $name => $table) {
-      db_create_table($name, $table);
+      $altered_table = $altered_schema[$name];
+      db_create_table($name, $altered_table);
       if (db_table_exists($name)) {
         drupal_set_message(t("@table was successfully created.", array('@table' => $name)));
       }
@@ -61,7 +64,7 @@ function dbtng_migrator_batch_migrate_table($origin, $destination, &$context) {
       if (!is_array($schema)) {
         continue;
       }
-      foreach ($schema as $table => $info) { 
+      foreach ($schema as $table => $info) {
         $tables[] = $table;
       }
     }
@@ -108,8 +111,8 @@ function dbtng_migrator_batch_migrate_table($origin, $destination, &$context) {
       db_set_active($destination);
       $insert = db_insert($table)->fields(array_keys($schema['fields']));
       foreach ($rows as $row) {
-         $insert->values((array) $row); 
-      } 
+         $insert->values((array) $row);
+      }
       $insert->execute();
       $count += $limit;
     }