15
15
*/
16
16
package org .springframework .data .mongodb .core ;
17
17
18
- import org .springframework .data .mongodb .core .aggregation .AggregationOperation ;
19
- import org .springframework .data .mongodb .core .aggregation .AggregationPipeline ;
20
18
import reactor .core .publisher .Flux ;
21
19
import reactor .core .publisher .Mono ;
22
20
27
25
import org .bson .Document ;
28
26
import org .reactivestreams .Publisher ;
29
27
import org .reactivestreams .Subscription ;
28
+
30
29
import org .springframework .data .geo .GeoResult ;
31
30
import org .springframework .data .mongodb .ReactiveMongoDatabaseFactory ;
32
31
import org .springframework .data .mongodb .core .aggregation .Aggregation ;
32
+ import org .springframework .data .mongodb .core .aggregation .AggregationOperation ;
33
33
import org .springframework .data .mongodb .core .aggregation .AggregationOptions ;
34
+ import org .springframework .data .mongodb .core .aggregation .AggregationPipeline ;
34
35
import org .springframework .data .mongodb .core .aggregation .AggregationUpdate ;
35
36
import org .springframework .data .mongodb .core .aggregation .TypedAggregation ;
36
37
import org .springframework .data .mongodb .core .convert .MappingMongoConverter ;
@@ -243,7 +244,7 @@ <T> Mono<MongoCollection<Document>> createCollection(Class<T> entityClass,
243
244
Mono <MongoCollection <Document >> createCollection (String collectionName , CollectionOptions collectionOptions );
244
245
245
246
/**
246
- * Create a view with the the provided name whose contents are defined by the {@link AggregationOperation pipeline
247
+ * Create a view with the provided name. The view content is defined by the {@link AggregationOperation pipeline
247
248
* stages} on another collection or view identified by the given {@link #getCollectionName(Class) source type}.
248
249
*
249
250
* @param name the name of the view to create.
@@ -256,7 +257,7 @@ default Mono<MongoCollection<Document>> createView(String name, Class<?> source,
256
257
}
257
258
258
259
/**
259
- * Create a view with the the provided name whose contents are defined by the {@link AggregationPipeline pipeline} on
260
+ * Create a view with the provided name. The view content is defined by the {@link AggregationPipeline pipeline} on
260
261
* another collection or view identified by the given {@link #getCollectionName(Class) source type}.
261
262
*
262
263
* @param name the name of the view to create.
@@ -269,7 +270,7 @@ default Mono<MongoCollection<Document>> createView(String name, Class<?> source,
269
270
}
270
271
271
272
/**
272
- * Create a view with the the provided name whose contents are defined by the {@link AggregationPipeline pipeline} on
273
+ * Create a view with the provided name. The view content is defined by the {@link AggregationPipeline pipeline} on
273
274
* another collection or view identified by the given {@link #getCollectionName(Class) source type}.
274
275
*
275
276
* @param name the name of the view to create.
@@ -281,7 +282,7 @@ default Mono<MongoCollection<Document>> createView(String name, Class<?> source,
281
282
Mono <MongoCollection <Document >> createView (String name , Class <?> source , AggregationPipeline pipeline , @ Nullable ViewOptions options );
282
283
283
284
/**
284
- * Create a view with the the provided name whose contents are defined by the {@link AggregationPipeline pipeline} on
285
+ * Create a view with the provided name. The view content is defined by the {@link AggregationPipeline pipeline} on
285
286
* another collection or view identified by the given source.
286
287
*
287
288
* @param name the name of the view to create.
@@ -1445,7 +1446,7 @@ default Mono<Long> exactCount(Query query, String collectionName) {
1445
1446
Mono <DeleteResult > remove (Mono <? extends Object > objectToRemove , String collectionName );
1446
1447
1447
1448
/**
1448
- * Remove all documents that match the provided query document criteria from the the collection used to store the
1449
+ * Remove all documents that match the provided query document criteria from the collection used to store the
1449
1450
* entityClass. The Class parameter is also used to help convert the Id of the object if it is present in the query.
1450
1451
*
1451
1452
* @param query the query document that specifies the criteria used to remove a record.
@@ -1455,7 +1456,7 @@ default Mono<Long> exactCount(Query query, String collectionName) {
1455
1456
Mono <DeleteResult > remove (Query query , Class <?> entityClass );
1456
1457
1457
1458
/**
1458
- * Remove all documents that match the provided query document criteria from the the collection used to store the
1459
+ * Remove all documents that match the provided query document criteria from the collection used to store the
1459
1460
* entityClass. The Class parameter is also used to help convert the Id of the object if it is present in the query.
1460
1461
*
1461
1462
* @param query the query document that specifies the criteria used to remove a record.
@@ -1498,9 +1499,9 @@ default Mono<Long> exactCount(Query query, String collectionName) {
1498
1499
<T > Flux <T > findAllAndRemove (Query query , Class <T > entityClass );
1499
1500
1500
1501
/**
1501
- * Returns and removes all documents that match the provided query document criteria from the the collection used to
1502
- * store the entityClass. The Class parameter is also used to help convert the Id of the object if it is present in
1503
- * the query.
1502
+ * Returns and removes all documents that match the provided query document criteria from the collection used to store
1503
+ * the entityClass. The Class parameter is also used to help convert the Id of the object if it is present in the
1504
+ * query.
1504
1505
*
1505
1506
* @param query the query document that specifies the criteria used to find and remove documents.
1506
1507
* @param entityClass class of the pojo to be operated on.
0 commit comments