MappingCassandraConverter cassandraConverter = new MappingCassandraConverter();
CassandraAdminTemplate cassandraTemplate = new CassandraAdminTemplate(AbstractEmbeddedCassandraIntegrationTest
.cluster().connect(), cassandraConverter);
CreateKeyspaceSpecification createKeyspaceSpecification = new CreateKeyspaceSpecification(keySpace).ifNotExists();
cassandraTemplate.execute(createKeyspaceSpecification);
cassandraTemplate.execute("USE " + keySpace);
cassandraTemplate.createTable(true, CqlIdentifier.cqlId("users"), User.class, new HashMap<String, Object>());
for (CassandraPersistentEntity<?> entity : cassandraTemplate.getConverter().getMappingContext()