Package | Description |
---|---|
org.springframework.data.mongodb.core |
MongoDB core support.
|
org.springframework.data.mongodb.core.aggregation |
Support for the MongoDB aggregation framework.
|
org.springframework.data.mongodb.core.messaging |
MongoDB specific messaging support for listening to eg.
|
Modifier and Type | Method and Description |
---|---|
<O> AggregationResults<O> |
MongoTemplate.aggregate(Aggregation aggregation,
Class<?> inputType,
Class<O> outputType) |
<O> reactor.core.publisher.Flux<O> |
ReactiveMongoOperations.aggregate(Aggregation aggregation,
Class<?> inputType,
Class<O> outputType)
Execute an aggregation operation.
|
<O> reactor.core.publisher.Flux<O> |
ReactiveMongoTemplate.aggregate(Aggregation aggregation,
Class<?> inputType,
Class<O> outputType) |
<O> AggregationResults<O> |
MongoOperations.aggregate(Aggregation aggregation,
Class<?> inputType,
Class<O> outputType)
Execute an aggregation operation.
|
<O> AggregationResults<O> |
MongoTemplate.aggregate(Aggregation aggregation,
String collectionName,
Class<O> outputType) |
<O> reactor.core.publisher.Flux<O> |
ReactiveMongoOperations.aggregate(Aggregation aggregation,
String collectionName,
Class<O> outputType)
Execute an aggregation operation.
|
<O> reactor.core.publisher.Flux<O> |
ReactiveMongoTemplate.aggregate(Aggregation aggregation,
String collectionName,
Class<O> outputType) |
<O> AggregationResults<O> |
MongoOperations.aggregate(Aggregation aggregation,
String collectionName,
Class<O> outputType)
Execute an aggregation operation.
|
protected <O> AggregationResults<O> |
MongoTemplate.aggregate(Aggregation aggregation,
String collectionName,
Class<O> outputType,
AggregationOperationContext context) |
<O> CloseableIterator<O> |
MongoTemplate.aggregateStream(Aggregation aggregation,
Class<?> inputType,
Class<O> outputType) |
<O> CloseableIterator<O> |
MongoOperations.aggregateStream(Aggregation aggregation,
Class<?> inputType,
Class<O> outputType)
Execute an aggregation operation backed by a Mongo DB
AggregateIterable . |
<O> CloseableIterator<O> |
MongoTemplate.aggregateStream(Aggregation aggregation,
String collectionName,
Class<O> outputType) |
<O> CloseableIterator<O> |
MongoOperations.aggregateStream(Aggregation aggregation,
String collectionName,
Class<O> outputType)
Execute an aggregation operation backed by a Mongo DB
AggregateIterable . |
protected <O> CloseableIterator<O> |
MongoTemplate.aggregateStream(Aggregation aggregation,
String collectionName,
Class<O> outputType,
AggregationOperationContext context) |
ReactiveAggregationOperation.TerminatingAggregationOperation<T> |
ReactiveAggregationOperation.AggregationOperationWithAggregation.by(Aggregation aggregation)
Set the aggregation to be used.
|
ExecutableAggregationOperation.TerminatingAggregation<T> |
ExecutableAggregationOperation.AggregationWithAggregation.by(Aggregation aggregation)
Set the aggregation to be used.
|
protected <O> reactor.core.publisher.Flux<O> |
ReactiveMongoTemplate.doAggregate(Aggregation aggregation,
String collectionName,
Class<?> inputType,
Class<O> outputType) |
protected <O> AggregationResults<O> |
MongoTemplate.doAggregate(Aggregation aggregation,
String collectionName,
Class<O> outputType,
AggregationOperationContext context) |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.filter(Aggregation filter)
Set the filter to apply.
|
ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T> |
ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection.filter(Aggregation by)
Use an
Aggregation to filter matching events. |
Modifier and Type | Class and Description |
---|---|
class |
AggregationUpdate
Abstraction for
db.collection.update() using an aggregation pipeline. |
class |
TypedAggregation<I>
A
TypedAggregation is a special Aggregation that holds information of the input aggregation type. |
Modifier and Type | Method and Description |
---|---|
static Aggregation |
Aggregation.newAggregation(AggregationOperation... operations)
Creates a new
Aggregation from the given AggregationOperation s. |
static Aggregation |
Aggregation.newAggregation(List<? extends AggregationOperation> operations)
Creates a new
Aggregation from the given AggregationOperation s. |
Aggregation |
Aggregation.withOptions(AggregationOptions options)
Returns a copy of this
Aggregation with the given AggregationOptions set. |
Modifier and Type | Method and Description |
---|---|
static MergeOperation.WhenDocumentsMatch |
MergeOperation.WhenDocumentsMatch.updateWith(Aggregation aggregation)
Use an
Aggregation to update the document in the collection. |
MergeOperation.MergeOperationBuilder |
MergeOperation.MergeOperationBuilder.whenDocumentsMatchApply(Aggregation aggregation)
The
action to take place when documents already exist in the target collection. |
Modifier and Type | Method and Description |
---|---|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.filter(Aggregation aggregation)
Set the filter to apply.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.