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 |
---|---|
Collection<MongoIterator<Document>> |
MongoCollection.parallelScan(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(Callback<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.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AsyncMongoCollection.parallelScanAsync(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
Modifier and Type | Method and Description |
---|---|
ParallelScan.Builder |
ParallelScan.Builder.batchSize(int batchSize)
Sets the value of the number of documents to be returned in each
batch.
|
static ParallelScan.Builder |
ParallelScan.builder()
Creates a new builder for a
ParallelScan . |
ParallelScan.Builder |
ParallelScan.Builder.readPreference(ReadPreference readPreference)
Sets the preference for the set of servers to retrieve the results
from.
|
ParallelScan.Builder |
ParallelScan.Builder.requestedIteratorCount(int numberOfIterators)
Sets the requested number of iterators/cursors to create to the new
value.
|
ParallelScan.Builder |
ParallelScan.Builder.reset()
Resets the builder back to its initial state for reuse.
|
ParallelScan.Builder |
ParallelScan.Builder.setBatchSize(int batchSize)
Sets the value of the number of documents to be returned in each
batch.
|
ParallelScan.Builder |
ParallelScan.Builder.setReadPreference(ReadPreference readPreference)
Sets the preference for the set of servers to retrieve the results
from.
|
ParallelScan.Builder |
ParallelScan.Builder.setRequestedIteratorCount(int numberOfIterators)
Sets the requested number of iterators/cursors to create to the new
value.
|
Constructor and Description |
---|
ParallelScan(ParallelScan.Builder builder)
Creates a new ParallelScan.
|
Modifier and Type | Method and Description |
---|---|
Collection<MongoIterator<Document>> |
SynchronousMongoCollectionImpl.parallelScan(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(Callback<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.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AbstractAsyncMongoCollection.parallelScanAsync(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.