diff --git a/v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/CassandraSourceMetadata.java b/v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/CassandraSourceMetadata.java index f0b876391..9e19252dd 100644 --- a/v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/CassandraSourceMetadata.java +++ b/v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/CassandraSourceMetadata.java @@ -181,12 +181,7 @@ private static Map convertSourceToNameAndColsTable( private static NameAndCols convertSourceTableToNameAndCols(SourceTable sourceTable) { Map columnNames = sourceTable.columns().stream() - .collect( - Collectors.toMap( - SourceColumn::name, - SourceColumn - ::name // Could be expanded to map to more useful data, like column types - )); + .collect(Collectors.toMap(SourceColumn::name, SourceColumn::name)); return new NameAndCols(sourceTable.name(), columnNames); }