private static Map getRequestItems()

in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java [102:120]

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

    private static Map<String, AttributeValue> getRequestItems(WriteRequest request) {
        if (request.putRequest() != null) {
            if (request.putRequest().hasItem()) {
                return request.putRequest().item();
            } else {
                throw new InvalidRequestException(
                        "PutItemRequest " + request + " does not contain request items.");
            }
        } else if (request.deleteRequest() != null) {
            if (request.deleteRequest().hasKey()) {
                return request.deleteRequest().key();
            } else {
                throw new InvalidRequestException(
                        "DeleteItemRequest " + request + " does not contain request key.");
            }
        } else {
            throw new InvalidRequestException("Empty write request " + request);
        }
    }