public void snapshotState()

in analytics/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java [140:145]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    public void snapshotState(FunctionSnapshotContext functionSnapshotContext) throws Exception {
        checkPointedState.clear();
        for (Record bufferedRecord : bufferedRecords) {
            checkPointedState.add(bufferedRecord);
        }
    }