public void invoke()

in analytics/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java [68:79]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    public void invoke(Collection<TimestreamPoint> points, Context context) {
        bufferedRecords.addAll(createRecords(points));

        if (shouldPublish()) {
            while (!bufferedRecords.isEmpty()) {
                List<Record> recordsToSend = new ArrayList<>(batchSize);
                bufferedRecords.drainTo(recordsToSend, batchSize);

                writeBatch(recordsToSend);
            }
        }
    }