in analytics/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java [123:132]
private boolean shouldPublish() {
if (bufferedRecords.size() >= batchSize) {
logger.debug("Batch of size " + bufferedRecords.size() + " should get published");
return true;
} else if (System.currentTimeMillis() - emptyListTimestamp >= RECORDS_FLUSH_INTERVAL_MILLISECONDS) {
logger.debug("Records after flush interval should get published");
return true;
}
return false;
}