public void consumeRecord()

in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java [95:105]

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

    public void consumeRecord(final Record record, final int recordBytes, final String sequenceNumber) {
        // Use HashMap to deduplicate using the DynamoDB key as the key.
        getBuffer().put(record.getDynamodb().getKeys(), record);
        // Sequence number bound maintenance
        setLastSequenceNumber(sequenceNumber);
        if (getFirstSequenceNumber() == null) {
            setFirstSequenceNumber(getLastSequenceNumber());
        }
        setProcessedRecords(getProcessedRecords() + 1);
        emitCloudWatchMetrics();
    }