private AmazonWebServiceRequest createRequest()

in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java [215:239]

• 22 lines of code
• 5 McCabe index (conditional complexity)

    private AmazonWebServiceRequest createRequest(final Record record) {
        final String eventName = record.getEventName();
        final AmazonWebServiceRequest request;
        if (eventName.equalsIgnoreCase(OperationType.INSERT.toString()) || eventName.equalsIgnoreCase(OperationType.MODIFY.toString())) {
            // For INSERT or MODIFY: Put the new image in the DynamoDB table
            PutItemRequest putItemRequest = new PutItemRequest();
            putItemRequest.setItem(record.getDynamodb().getNewImage());
            putItemRequest.setTableName(getTableName());
            request = putItemRequest;
        } else if (eventName.equalsIgnoreCase(OperationType.REMOVE.toString())) {
            // For REMOVE: Delete the item from the DynamoDB table
            DeleteItemRequest deleteItemRequest = new DeleteItemRequest();
            deleteItemRequest.setKey(record.getDynamodb().getKeys());
            deleteItemRequest.setTableName(getTableName());
            request = deleteItemRequest;
        } else {
            // This should only happen if DynamoDB Streams adds/changes its operation types
            log.warn("Unsupported operation type detected: " + eventName + ". Record: " + record);
            request = null;
        }
        if (null != request) {
            request.getRequestClientOptions().appendUserAgent(USER_AGENT);
        }
        return request;
    }