Skip to content

Commit 6cd4f20

Browse files
committed
Rebase onto sourceddl branch with resolved comments
1 parent 75bc4ab commit 6cd4f20

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDb.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,8 @@
4747
import com.google.cloud.teleport.v2.spanner.migrations.utils.ShardFileReader;
4848
import com.google.cloud.teleport.v2.spanner.sourceddl.CassandraInformationSchemaScanner;
4949
import com.google.cloud.teleport.v2.spanner.sourceddl.MySqlInformationSchemaScanner;
50-
import com.google.cloud.teleport.v2.spanner.sourceddl.SourceInformationSchemaScanner;
5150
import com.google.cloud.teleport.v2.spanner.sourceddl.SourceSchema;
51+
import com.google.cloud.teleport.v2.spanner.sourceddl.SourceSchemaScanner;
5252
import com.google.cloud.teleport.v2.templates.SpannerToSourceDb.Options;
5353
import com.google.cloud.teleport.v2.templates.changestream.TrimmedShardedDataChangeRecord;
5454
import com.google.cloud.teleport.v2.templates.constants.Constants;
@@ -563,7 +563,7 @@ public static PipelineResult run(Options options) {
563563
LOG.info("Cassandra config is: {}", shards.get(0));
564564
shardingMode = Constants.SHARDING_MODE_SINGLE_SHARD;
565565
}
566-
SourceInformationSchemaScanner scanner = null;
566+
SourceSchemaScanner scanner = null;
567567
SourceSchema sourceSchema = null;
568568
try {
569569
if (options.getSourceType().equals(MYSQL_SOURCE_TYPE)) {

0 commit comments

Comments
 (0)