public Schema()

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));
            }
        }
    }