in spark-job/src/main/java/org/apache/cassandra/diff/Schema.java [27:38]
public Schema(Metadata metadata, JobConfiguration configuration) {
Set<String> keyspaceFilter = getKeyspaceFilter(configuration);
qualifiedTables = new HashSet<>();
for (KeyspaceMetadata keyspaceMetadata : metadata.getKeyspaces()) {
if (keyspaceFilter.contains(keyspaceMetadata.getName()))
continue;
for (TableMetadata tableMetadata : keyspaceMetadata.getTables()) {
qualifiedTables.add(KeyspaceTablePair.from(tableMetadata));
}
}
}