Package | Description |
---|---|
org.mongodb.morphia | |
org.mongodb.morphia.aggregation |
Modifier and Type | Method and Description |
---|---|
AggregationPipeline |
Datastore.createAggregation(Class source)
Returns a new query bound to the kind (a specific
DBCollection ) |
AggregationPipeline |
DatastoreImpl.createAggregation(Class source)
Returns a new query bound to the kind (a specific
DBCollection ) |
Modifier and Type | Class and Description |
---|---|
class |
AggregationPipelineImpl |
Modifier and Type | Method and Description |
---|---|
AggregationPipeline |
AggregationPipeline.geoNear(GeoNear geoNear)
Returns an ordered stream of documents based on the proximity to a geospatial point.
|
AggregationPipeline |
AggregationPipelineImpl.geoNear(GeoNear geoNear) |
AggregationPipeline |
AggregationPipeline.group(List<Group> id,
Group... groupings) |
AggregationPipeline |
AggregationPipelineImpl.group(List<Group> id,
Group... groupings) |
AggregationPipeline |
AggregationPipeline.group(String id,
Group... groupings)
Groups input documents by a specified identifier expression and applies the accumulator expression(s), if specified, to each group .
|
AggregationPipeline |
AggregationPipelineImpl.group(String id,
Group... groupings) |
AggregationPipeline |
AggregationPipeline.limit(int count)
Passes the first n documents unmodified to the pipeline where n is the specified limit.
|
AggregationPipeline |
AggregationPipelineImpl.limit(int count) |
AggregationPipeline |
AggregationPipeline.match(Query query)
Filters the document stream to allow only matching documents to pass unmodified into the next pipeline stage.
|
AggregationPipeline |
AggregationPipelineImpl.match(Query query) |
AggregationPipeline |
AggregationPipeline.project(Projection... projections)
Reshapes each document in the stream, such as by adding new fields or removing existing fields.
|
AggregationPipeline |
AggregationPipelineImpl.project(Projection... projections) |
AggregationPipeline |
AggregationPipeline.skip(int count)
Skips the first n documents where n is the specified skip number and passes the remaining documents unmodified to the pipeline.
|
AggregationPipeline |
AggregationPipelineImpl.skip(int count) |
AggregationPipeline |
AggregationPipeline.sort(Sort... sorts)
Reorders the document stream by a specified sort key.
|
AggregationPipeline |
AggregationPipelineImpl.sort(Sort... sorts) |
AggregationPipeline |
AggregationPipeline.unwind(String field)
Deconstructs an array field from the input documents to output a document for each element.
|
AggregationPipeline |
AggregationPipelineImpl.unwind(String field) |
Copyright © 2016. All rights reserved.