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 |
---|---|
MongoIterator<Document> |
MongoCollection.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Document |
MongoCollection.explain(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
Modifier and Type | Method and Description |
---|---|
Aggregate.Builder |
Aggregate.Builder.allowDiskUsage()
Allows the aggregation command can spill to disk.
|
Aggregate.Builder |
Aggregate.Builder.allowDiskUsage(boolean allowDiskUsage)
Sets to true if the aggregation command can spill to disk.
|
Aggregate.Builder |
Aggregate.Builder.batchSize(int batchSize)
Sets the value of the number of documents to be returned in each
batch.
|
static Aggregate.Builder |
Aggregate.builder()
Creates a new builder for a
Aggregate . |
Aggregate.Builder |
Aggregate.Builder.cursorLimit(int limit)
Sets the value of the total number of documents to be returned.
|
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.maximumTime(long timeLimit,
TimeUnit timeLimitUnits)
Sets the maximum number of milliseconds to allow the command to run
before aborting the request on the server.
|
Aggregate.Builder |
Aggregate.Builder.out(String collectionName)
Adds a $out operation to the pipeline to write all of the
output documents to the specified collection.
|
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.redact(DocumentAssignable ifExpression,
RedactOption thenOption,
RedactOption elseOption)
Adds a $redact operation to potentially prune sub-documents
from the results.
|
Aggregate.Builder |
Aggregate.Builder.redact(Expression ifExpression,
RedactOption thenOption,
RedactOption elseOption)
Adds a $redact operation to potentially prune sub-documents
from the results.
|
Aggregate.Builder |
Aggregate.Builder.reset()
Resets the builder back to an empty pipeline.
|
Aggregate.Builder |
Aggregate.Builder.setAllowDiskUsage(boolean allowDiskUsage)
Sets to true if the aggregation command can spill to disk.
|
Aggregate.Builder |
Aggregate.Builder.setBatchSize(int batchSize)
Sets the value of the number of documents to be returned in each
batch.
|
Aggregate.Builder |
Aggregate.Builder.setCusorLimit(int limit)
Sets the value of the total number of documents to be returned.
|
Aggregate.Builder |
Aggregate.Builder.setMaximumTimeMilliseconds(long maximumTimeMilliseconds)
Sets the maximum number of milliseconds to allow the command to run
before aborting the request on the server.
|
Aggregate.Builder |
Aggregate.Builder.setReadPreference(ReadPreference readPreference)
Sets the
ReadPreference specifying which servers may be used
to execute the aggregation. |
Aggregate.Builder |
Aggregate.Builder.setUseCursor(boolean useCursor)
Sets to true if the aggregation results should be returned as a
cursor.
|
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.
|
Aggregate.Builder |
Aggregate.Builder.useCursor()
Sets that the results should be returned using a cursor.
|
Aggregate.Builder |
Aggregate.Builder.useCursor(boolean useCursor)
Sets to true if the aggregation results should be returned as a
cursor.
|
Constructor and Description |
---|
Aggregate(Aggregate.Builder builder)
Creates a new Aggregation.
|
Modifier and Type | Method and Description |
---|---|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AbstractAsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AbstractAsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Document |
SynchronousMongoCollectionImpl.explain(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.