(long eventId, boolean suppressLogging)
| 245 | public long getCreateEventId() { return createEventId_; } |
| 246 | |
| 247 | public void setCreateEventId(long eventId, boolean suppressLogging) { |
| 248 | if (eventId < createEventId_) { |
| 249 | if (!suppressLogging) { |
| 250 | LOG.warn("Ignored stale createEventId: {}. Current id: {}", |
| 251 | eventId, createEventId_); |
| 252 | } |
| 253 | return; |
| 254 | } |
| 255 | createEventId_ = eventId; |
| 256 | if (!suppressLogging) { |
| 257 | LOG.debug("createEventId_ for table: {} set to: {}", getFullName(), createEventId_); |
| 258 | } |
| 259 | // Don't need to sync table from events older than create event id. |
| 260 | if (lastSyncedEventId_ < eventId) { |
| 261 | setLastSyncedEventId(eventId, suppressLogging); |
| 262 | } |
| 263 | } |
| 264 | |
| 265 | public long getLastSyncedEventId() { |
| 266 | return lastSyncedEventId_; |
no test coverage detected