in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timescale/TimescaleDataService.java [104:118]
public long getLastTimestamp(String query) {
return jdbcTemplate.query(query, rs -> {
if (rs.next()) {
Timestamp lastEventTime = rs.getTimestamp("EventTime");
if (lastEventTime != null) {
return lastEventTime.getTime();
} else {
return 0l;
}
} else {
return 0l;
}
});
}