public void createTable()

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