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.mapReduce(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
Modifier and Type | Method and Description |
---|---|
static MapReduce.Builder |
MapReduce.builder()
Creates a new builder for a
MapReduce . |
MapReduce.Builder |
MapReduce.Builder.finalize(String finalize)
Sets the finalize function to apply to the final results of the
reduce function.
|
MapReduce.Builder |
MapReduce.Builder.jsMode()
Sets to true to limit the translation of the documents to an from
BSON/JavaScript.
|
MapReduce.Builder |
MapReduce.Builder.jsMode(boolean jsMode)
Sets to true to limit the translation of the documents to an from
BSON/JavaScript.
|
MapReduce.Builder |
MapReduce.Builder.keepTemp()
Sets to true to drop the temporary collections created during the
map/reduce.
|
MapReduce.Builder |
MapReduce.Builder.keepTemp(boolean keepTemp)
Sets to true to drop the temporary collections created during the
map/reduce.
|
MapReduce.Builder |
MapReduce.Builder.limit(int limit)
Sets the limit for the number of objects to be used as input to the
map/reduce.
|
MapReduce.Builder |
MapReduce.Builder.map(String map)
Sets the map functions to apply to each selected document.
|
MapReduce.Builder |
MapReduce.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.
|
MapReduce.Builder |
MapReduce.Builder.outputDatabase(String outputDatabase)
Sets the name of the output database if the output type is One of
MapReduce.OutputType.REPLACE , MapReduce.OutputType.MERGE , or
MapReduce.OutputType.REDUCE . |
MapReduce.Builder |
MapReduce.Builder.outputName(String outputName)
Sets the name of the output collection if the output type is One of
MapReduce.OutputType.REPLACE , MapReduce.OutputType.MERGE , or
MapReduce.OutputType.REDUCE . |
MapReduce.Builder |
MapReduce.Builder.outputType(MapReduce.OutputType outputType)
Sets the handling for the output of the map/reduce.
|
MapReduce.Builder |
MapReduce.Builder.query(DocumentAssignable query)
Sets the query to select the documents to run the map/reduce against.
|
MapReduce.Builder |
MapReduce.Builder.readPreference(ReadPreference readPreference)
Sets the
ReadPreference specifying which servers may be used
to execute the MapReduce command. |
MapReduce.Builder |
MapReduce.Builder.reduce(String reduce)
Sets the reduce function to apply to the emitted output of the map
function.
|
MapReduce.Builder |
MapReduce.Builder.reset()
Resets the builder back to its initial state.
|
MapReduce.Builder |
MapReduce.Builder.scope(DocumentAssignable scope)
Sets the scoped values to expose to the map/reduce/finalize
functions.
|
MapReduce.Builder |
MapReduce.Builder.setFinalizeFunction(String finalize)
Sets the finalize function to apply to the final results of the
reduce function.
|
MapReduce.Builder |
MapReduce.Builder.setJsMode(boolean jsMode)
Sets to true to limit the translation of the documents to an from
BSON/JavaScript.
|
MapReduce.Builder |
MapReduce.Builder.setKeepTemp(boolean keepTemp)
Sets to true to drop the temporary collections created during the
map/reduce.
|
MapReduce.Builder |
MapReduce.Builder.setLimit(int limit)
Sets the limit for the number of objects to be used as input to the
map/reduce.
|
MapReduce.Builder |
MapReduce.Builder.setMapFunction(String map)
Sets the map functions to apply to each selected document.
|
MapReduce.Builder |
MapReduce.Builder.setMaximumTimeMilliseconds(long maximumTimeMilliseconds)
Sets the maximum number of milliseconds to allow the command to run
before aborting the request on the server.
|
MapReduce.Builder |
MapReduce.Builder.setOutputDatabase(String outputDatabase)
Sets the name of the output database if the output type is One of
MapReduce.OutputType.REPLACE , MapReduce.OutputType.MERGE , or
MapReduce.OutputType.REDUCE . |
MapReduce.Builder |
MapReduce.Builder.setOutputName(String outputName)
Sets the name of the output collection if the output type is One of
MapReduce.OutputType.REPLACE , MapReduce.OutputType.MERGE , or
MapReduce.OutputType.REDUCE . |
MapReduce.Builder |
MapReduce.Builder.setOutputType(MapReduce.OutputType outputType)
Sets the handling for the output of the map/reduce.
|
MapReduce.Builder |
MapReduce.Builder.setQuery(DocumentAssignable query)
Sets the query to select the documents to run the map/reduce against.
|
MapReduce.Builder |
MapReduce.Builder.setReadPreference(ReadPreference readPreference)
Sets the
ReadPreference specifying which servers may be used
to execute the MapReduce command. |
MapReduce.Builder |
MapReduce.Builder.setReduceFunction(String reduce)
Sets the reduce function to apply to the emitted output of the map
function.
|
MapReduce.Builder |
MapReduce.Builder.setScope(DocumentAssignable scope)
Sets the scoped values to expose to the map/reduce/finalize
functions.
|
MapReduce.Builder |
MapReduce.Builder.setSort(DocumentAssignable sort)
Sets the sort to apply to the input objects.
|
MapReduce.Builder |
MapReduce.Builder.setSort(IntegerElement... sortFields)
Sets the sort to apply to the input objects.
|
MapReduce.Builder |
MapReduce.Builder.setVerbose(boolean verbose)
Sets to true to emit progress messages in the server logs.
|
MapReduce.Builder |
MapReduce.Builder.sort(DocumentAssignable sort)
Sets the sort to apply to the input objects.
|
MapReduce.Builder |
MapReduce.Builder.sort(IntegerElement... sortFields)
Sets the sort to apply to the input objects.
|
MapReduce.Builder |
MapReduce.Builder.verbose()
Sets to true to emit progress messages in the server logs.
|
MapReduce.Builder |
MapReduce.Builder.verbose(boolean verbose)
Sets to true to emit progress messages in the server logs.
|
Constructor and Description |
---|
MapReduce(MapReduce.Builder builder)
Create a new MapReduce.
|
Modifier and Type | Method and Description |
---|---|
MongoIterator<Document> |
SynchronousMongoCollectionImpl.mapReduce(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AbstractAsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AbstractAsyncMongoCollection.mapReduceAsync(LambdaCallback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.