diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressions.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressions.java index b8a78b31a..e06fa43fb 100644 --- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressions.java +++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressions.java @@ -130,8 +130,7 @@ public interface AggregationExpressions { } NestedDelegatingExpressionAggregationOperationContext nea = new NestedDelegatingExpressionAggregationOperationContext(context); - DBObject mappedCondition = ((AggregationExpression) condition).toDbObject(nea); - return mappedCondition; + return ((AggregationExpression) condition).toDbObject(nea); } /** @@ -223,7 +222,7 @@ public interface AggregationExpressions { public AsBuilder filter(List array) { Assert.notNull(array, "Array must not be null!"); - filter.input = new ArrayList(array); + filter.input = new ArrayList(array); return this; } @@ -287,7 +286,5 @@ public interface AggregationExpressions { return filter; } } - } - }