### Question:
CassandraSchemaHandler { public boolean validSchema(Cluster cluster, String schemaName) throws Exception { log.debug("Validating schema %s on cluster %s", schemaName, cluster); KeyspaceManager keyspaceManager = Pelops.createKeyspaceManager(cluster); try { KsDef ksDef = keyspaceManager.getKeyspaceSchema(schemaName); if (ksDef == null) { log.debug("Keyspace not found"); return false; } if (!validateTable(ksDef, "nodes")) return false; if (!validateTable(ksDef, "applications")) return false; if (!validateTable(ksDef, "addresses")) return false; if (!validateTable(ksDef, "clients")) return false; if (!validateTable(ksDef, "ips")) return false; if (!validateTable(ksDef, "calls")) return false; if (!validateTable(ksDef, "jids")) return false; return true; } catch (TTransportException te) { log.error("It looks like the Cassandra Server is down"); log.error(te.getMessage(), te); throw te; } catch (Exception e) { log.warn(e.getMessage()); } return false; }  boolean schemaExists(Cluster cluster, String schemaName); boolean validSchema(Cluster cluster, String schemaName); void buildSchema(Cluster cluster, String schemaName); void buildSchema(Cluster cluster, String schemaName, boolean dropExisting); void dropSchema(String schemaName, KeyspaceManager keyspaceManager); void setSchemaWaitPeriod(int schemaWaitPeriod); void setWaitForSyncing(boolean waitForSyncing);  }### Answer:
@Test public void testValidSchema() throws Exception { CassandraSchemaHandler schemaHandler = new CassandraSchemaHandler(); Cluster cluster = new Cluster("localhost", Integer.parseInt(CassandraDatastoreTest.CASSANDRA_TESTING_PORT), false); schemaHandler.buildSchema(cluster, "rayo"); assertTrue(schemaHandler.validSchema(cluster, "rayo")); }