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. |
com.allanbank.mongodb.client.callback |
Provides implementation for various transformations, implemented in the form of
Callback s, that are used by the driver. |
Modifier and Type | Interface and Description |
---|---|
interface |
MongoIterator<T>
MongoIterator provides an interface for an iterator that can be closed.
|
Modifier and Type | Method and Description |
---|---|
MongoCursorControl |
MongoClient.restart(LambdaCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
MongoClient.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
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.stream(StreamCallback<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 aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<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(StreamCallback<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(Callback<Document> results,
DocumentAssignable query)
Deprecated.
Use the
AsyncMongoCollection.streamingFind(StreamCallback, DocumentAssignable)
method instead. This method will be removed after the 1.3.0
release. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find) method instead.
This method will be removed after the 1.3.0 release. |
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.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<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.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find.Builder) method
instead. This method will be removed after the 1.4.0 release. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find) method instead.
This method will be removed after the 1.4.0 release. |
Modifier and Type | Class and Description |
---|---|
class |
MongoIteratorImpl
Iterator over the results of the MongoDB cursor.
|
class |
SimpleMongoIteratorImpl<T>
Iterator over the results of fixed collection.
|
Modifier and Type | Method and Description |
---|---|
MongoCursorControl |
MongoClientImpl.restart(LambdaCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
SerialClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
MongoClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
ClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
Client.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
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.stream(StreamCallback<Document> results,
Aggregate.Builder 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 . |
MongoCursorControl |
AbstractAsyncMongoCollection.stream(StreamCallback<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 |
AbstractMongoOperations.stream(StreamCallback<Document> results,
Find query)
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(Callback<Document> results,
DocumentAssignable query)
Deprecated.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
|
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.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<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.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Deprecated.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
CursorStreamingCallback
Callback to convert a
CursorableMessage Reply into a series
of callback for each document received. |
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.