Package | Description |
---|---|
com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
com.allanbank.mongodb.builder |
Provides domain classes and builders for queries and the common MongoDB commands.
|
com.allanbank.mongodb.client |
Provides implementations of the main client interfaces and classes to translate the
Reply (s) from the server. |
Modifier and Type | Method and Description |
---|---|
List<Document> |
MongoCollection.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Future<List<Document>> |
MongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
MongoCollection.aggregateAsync(Callback<List<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Modifier and Type | Method and Description |
---|---|
static Aggregate.Builder |
Aggregate.builder()
Creates a new builder for a
Aggregate . |
Aggregate.Builder |
Aggregate.Builder.geoNear(AggregationGeoNear.Builder geoNear)
Adds a $geoNear operation to the pipeline to select
documents for the aggregation pipeline based on their relative
location to a set point.
|
Aggregate.Builder |
Aggregate.Builder.geoNear(AggregationGeoNear geoNear)
Adds a $geoNear operation to the pipeline to select
documents for the aggregation pipeline based on their relative
location to a set point.
|
Aggregate.Builder |
Aggregate.Builder.group(AggregationGroupId.Builder id,
AggregationGroupField... aggregations)
Adds a $group operation to the pipeline to aggregate
documents passing this point in the pipeline into a group of
documents.
|
Aggregate.Builder |
Aggregate.Builder.group(AggregationGroupId id,
AggregationGroupField... aggregations)
Adds a $group operation to the pipeline to aggregate
documents passing this point in the pipeline into a group of
documents.
|
Aggregate.Builder |
Aggregate.Builder.group(DocumentAssignable aggregations)
Adds a $group operation to the pipeline to aggregate
documents passing this point in the pipeline into a group of
documents.
|
Aggregate.Builder |
Aggregate.Builder.group(DocumentAssignable id,
AggregationGroupField... aggregations)
Adds a $group operation to the pipeline to aggregate
documents passing this point in the pipeline into a group of
documents.
|
Aggregate.Builder |
Aggregate.Builder.limit(int numberOfDocuments)
Adds a $limit operation to the pipeline to stop producing
documents passing this point in the pipeline once the limit of
documents is reached.
|
Aggregate.Builder |
Aggregate.Builder.limit(long numberOfDocuments)
Adds a $limit operation to the pipeline to stop producing
documents passing this point in the pipeline once the limit of
documents is reached.
|
Aggregate.Builder |
Aggregate.Builder.match(DocumentAssignable query)
Adds a $match operation to the pipeline to filter documents
passing this point in the pipeline.
|
Aggregate.Builder |
Aggregate.Builder.project(AggregationProjectFields fields,
Element... elements)
Adds a $project operation to the pipeline to create a
projection of the documents passing this point in the pipeline.
|
Aggregate.Builder |
Aggregate.Builder.project(DocumentAssignable projection)
Adds a $project operation to the pipeline to create a
projection of the documents passing this point in the pipeline.
|
Aggregate.Builder |
Aggregate.Builder.reset()
Resets the builder back to an empty pipeline.
|
Aggregate.Builder |
Aggregate.Builder.setReadPreference(ReadPreference readPreference)
Sets the
ReadPreference specifying which servers may be used
to execute the aggregation. |
Aggregate.Builder |
Aggregate.Builder.skip(int numberOfDocuments)
Adds a $skip operation to the pipeline to skip the specified
number of documents before allowing any document past this point in
the pipeline.
|
Aggregate.Builder |
Aggregate.Builder.skip(long numberOfDocuments)
Adds a $skip operation to the pipeline to skip the specified
number of documents before allowing any document past this point in
the pipeline.
|
Aggregate.Builder |
Aggregate.Builder.sort(IntegerElement... sortFields)
Adds a $sort operation to sort the documents passing this
point based on the sort specification provided.
|
Aggregate.Builder |
Aggregate.Builder.sort(String... sortFields)
Adds a $sort operation to sort the documents passing this
point based on the sort fields provides in ascending order.
|
Aggregate.Builder |
Aggregate.Builder.step(String operator,
DocumentAssignable stepDocument)
Adds a generic step to the builder's pipeline.
|
Aggregate.Builder |
Aggregate.Builder.step(String operator,
double value)
Adds a generic step to the builder's pipeline.
|
Aggregate.Builder |
Aggregate.Builder.step(String operator,
Element... elements)
Adds a generic step to the builder's pipeline.
|
Aggregate.Builder |
Aggregate.Builder.step(String operator,
int value)
Adds a generic step to the builder's pipeline.
|
Aggregate.Builder |
Aggregate.Builder.step(String operator,
List<Element> elements)
Adds a generic step to the builder's pipeline.
|
Aggregate.Builder |
Aggregate.Builder.step(String operator,
long value)
Adds a generic step to the builder's pipeline.
|
Aggregate.Builder |
Aggregate.Builder.step(String operator,
String value)
Adds a generic step to the builder's pipeline.
|
Aggregate.Builder |
Aggregate.Builder.unwind(String fieldName)
Adds a $unwind operation generate a document for each
element of the specified array field with the array replaced with the
value of the element.
|
Constructor and Description |
---|
Aggregate(Aggregate.Builder builder)
Creates a new Aggregate.
|
Modifier and Type | Method and Description |
---|---|
List<Document> |
AbstractMongoCollection.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Future<List<Document>> |
AbstractMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AbstractMongoCollection.aggregateAsync(Callback<List<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Copyright © 2011-2013 Allanbank Consulting, Inc.. All Rights Reserved.