Package | Description |
---|---|
com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
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 |
---|---|
void |
AsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results)
Counts the set of documents in the collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(LambdaCallback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
void |
AsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate.Builder 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.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find query)
Explains the way that the query will be performed.
|
void |
AsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
void |
AsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
MongoCursorControl |
MongoClient.restart(LambdaCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command,
Version requiredServerVersion)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
AsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document)
Saves the
document to the collection. |
void |
AsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
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(LambdaCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(LambdaCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(LambdaCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
void |
AsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.writeAsync(LambdaCallback<Long> results,
BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AsyncMongoCollection.writeAsync(LambdaCallback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractAsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AbstractAsyncMongoCollection.aggregateAsync(LambdaCallback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results)
Counts the set of documents in the collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
Count count)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(LambdaCallback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(LambdaCallback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AbstractAsyncMongoCollection.distinctAsync(LambdaCallback<MongoIterator<Element>> results,
Distinct command)
Invokes a distinct command on the server.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AbstractAsyncMongoCollection.explainAsync(LambdaCallback<Document> results,
Find query)
Explains the way that the query will be performed.
|
void |
AbstractAsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AbstractAsyncMongoCollection.findAndModifyAsync(LambdaCallback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AbstractAsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AbstractAsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AbstractAsyncMongoCollection.findAsync(LambdaCallback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(LambdaCallback<Document> results,
Find query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AbstractAsyncMongoCollection.groupByAsync(LambdaCallback<MongoIterator<Element>> results,
GroupBy command)
Invokes a group command on the server.
|
void |
AbstractAsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.insertAsync(LambdaCallback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AbstractAsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
void |
AbstractAsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AbstractAsyncMongoCollection.parallelScanAsync(LambdaCallback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
MongoCursorControl |
MongoClientImpl.restart(LambdaCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
DocumentAssignable command,
Version requiredServerVersion)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(LambdaCallback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
AbstractAsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document)
Saves the
document to the collection. |
void |
AbstractAsyncMongoCollection.saveAsync(LambdaCallback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
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(LambdaCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Find.Builder aggregation)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(LambdaCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(LambdaCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
void |
AbstractAsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(LambdaCallback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.writeAsync(LambdaCallback<Long> results,
BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AbstractAsyncMongoCollection.writeAsync(LambdaCallback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
Constructor and Description |
---|
LambdaCallbackAdapter(LambdaCallback<V> lambda)
Creates a new LambdaCallbackAdapter.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.