fun createTable()

in analytics-kotlin/src/main/kotlin/services/timestream/TimestreamInitializer.kt [51:66]

• 16 lines of code
• 2 McCabe index (conditional complexity)

    fun createTable(databaseName: String, tableName: String) {
        LOG.info("Creating table")
        val createTableRequest = CreateTableRequest()
        createTableRequest.databaseName = databaseName
        createTableRequest.tableName = tableName
        val retentionProperties = RetentionProperties()
            .withMemoryStoreRetentionPeriodInHours(HT_TTL_HOURS)
            .withMagneticStoreRetentionPeriodInDays(CT_TTL_DAYS)
        createTableRequest.retentionProperties = retentionProperties
        try {
            writeClient.createTable(createTableRequest)
            LOG.info("Table [$tableName] successfully created.")
        } catch (e: ConflictException) {
            LOG.info("Table [$tableName] exists on database [$databaseName]. Skipping table creation")
        }
    }