public Stream getLocksByPartitionKey()

in src/main/java/com/amazonaws/services/dynamodbv2/AmazonDynamoDBLockClient.java [1072:1089]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    public Stream<LockItem> getLocksByPartitionKey(String key, final boolean deleteOnRelease) {
        Map<String, String> expressionAttributeNames = new HashMap<>();
        expressionAttributeNames.put(PK_PATH_EXPRESSION_VARIABLE, this.partitionKeyName);
        Map<String, AttributeValue> expressionAttributeValues = new HashMap<>();
        expressionAttributeValues.put(PK_VALUE_EXPRESSION_VARIABLE, AttributeValue.builder().s(key).build());
        final QueryRequest queryRequest = QueryRequest.builder()
            .tableName(this.tableName)
            .keyConditionExpression(QUERY_PK_EXPRESSION)
            .expressionAttributeNames(expressionAttributeNames)
            .expressionAttributeValues(expressionAttributeValues)
            .build();
        final LockItemPaginatedQueryIterator
            iterator = new LockItemPaginatedQueryIterator(
            this.dynamoDB, queryRequest, item -> getLockItem(key, deleteOnRelease, item));

        final Iterable<LockItem> iterable = () -> iterator;
        return StreamSupport.stream(iterable.spliterator(), false /*isParallelStream*/);
    }