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. |
com.allanbank.mongodb.client.message |
Low level messages to be sent to the MongoDB server.
|
Modifier and Type | Method and Description |
---|---|
MongoIterator<Document> |
MongoCollection.aggregate(Aggregate command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
Document |
MongoCollection.explain(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
Modifier and Type | Method and Description |
---|---|
Aggregate |
Aggregate.Builder.build()
Constructs a new
Aggregate object from the state of the
builder. |
Modifier and Type | Method and Description |
---|---|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.aggregate(Aggregate command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
void |
AbstractMongoOperations.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate command)
Constructs a
aggregate command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
Document |
SynchronousMongoCollectionImpl.explain(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractMongoOperations.explainAsync(Callback<Document> results,
Aggregate aggregation)
Constructs a
AggregateCommand and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AbstractMongoOperations.stream(StreamCallback<Document> results,
Aggregate aggregation)
Constructs a
aggregate command and sends it to the server via the
Client . |
protected AggregateCommand |
AbstractMongoOperations.toCommand(Aggregate command,
boolean explain)
Converts the
Aggregate object to an AggregateCommand . |
Constructor and Description |
---|
AggregateCommand(Aggregate aggregation,
String databaseName,
String collectionName,
Document commandDocument,
ReadPreference readPreference,
VersionRange requiredServerVersion)
Create a new AggregateCommand.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.