in analytics/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java [50:66]
public void createTable(String databaseName, String tableName) {
logger.info("Creating table");
CreateTableRequest createTableRequest = new CreateTableRequest();
createTableRequest.setDatabaseName(databaseName);
createTableRequest.setTableName(tableName);
final RetentionProperties retentionProperties = new RetentionProperties()
.withMemoryStoreRetentionPeriodInHours(HT_TTL_HOURS)
.withMagneticStoreRetentionPeriodInDays(CT_TTL_DAYS);
createTableRequest.setRetentionProperties(retentionProperties);
try {
writeClient.createTable(createTableRequest);
logger.info("Table [" + tableName + "] successfully created.");
} catch (ConflictException e) {
logger.info("Table [" + tableName + "] exists on database [" + databaseName + "]. Skipping table creation");
}
}