in resume-api/resume-api-cassandraql/src/main/java/org/apache/camel/example/resume/cassandra/main/ExampleDao.java [75:90]
public void createTable() {
SimpleStatement statement = SchemaBuilder.createTable(TABLE_NAME)
.ifNotExists()
.withPartitionKey("id", DataTypes.TIMEUUID)
.withClusteringColumn("number", DataTypes.BIGINT)
.withColumn("text", DataTypes.TEXT)
.builder()
.setTimeout(Duration.ofSeconds(10)).build();
LOG.info("Executing create table {}", statement);
ResultSet rs = session.execute(statement);
if (!rs.wasApplied()) {
LOG.warn("The create table statement did not execute");
}
}