private boolean shouldPublish()

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;
    }