val jdbcSource = JdbcSource.builder()
.setDBUrl("jdbc:postgresql://db:5432/postgres")
.setSql("SELECT player_id, past_logins FROM user_initial_data")
.setUsername("postgres")
.setPassword("example")
.setTypeInformation(TypeInformation.of(PlayerLoggedInEvent::class.java))
.setResultExtractor { LoggedInEvent(it.getInt(1).toString(), it.getInt(2), Instant.now().toEpochMilli()) }
.build()
val snapshotsStream = env.fromSource(jdbcSource, WatermarkStrategy.noWatermarks(), "LoggedInSnapshots")
< /code>
В настоящее время я испытываю две проблемы с этим решением: < /p>
- Я не могу запланировать это, чтобы выполнить каждые n секунд, так что есть какой -нибудь простой способ сделать это с существующим инструментом? Я хочу, чтобы это было запланировано и непрерывно работало в пределах той же работы.
Подробнее здесь: https://stackoverflow.com/questions/795 ... dbc-source
