MapReduceObservable (driver 1.0.0 API)

Type Parameters:

TResult - The type of the result.

All Superinterfaces:

MongoObservable<TResult>
```
public interface MapReduceObservable<TResult>
extends MongoObservable<TResult>
```
Observable for map reduce.

Since:

1.0

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`MapReduceObservable<TResult>`	`action(com.mongodb.client.model.MapReduceAction action)` Specify the `MapReduceAction` to be used when writing to a collection.
`MapReduceObservable<TResult>`	`collectionName(String collectionName)` Sets the collectionName for the output of the MapReduce
`MapReduceObservable<TResult>`	`databaseName(String databaseName)` Sets the name of the database to output into.
`MapReduceObservable<TResult>`	`filter(org.bson.conversions.Bson filter)` Sets the query filter to apply to the query.
`MapReduceObservable<TResult>`	`finalizeFunction(String finalizeFunction)` Sets the JavaScript function that follows the reduce method and modifies the output.
`MapReduceObservable<TResult>`	`jsMode(boolean jsMode)` Sets the flag that specifies whether to convert intermediate data into BSON format between the execution of the map and reduce functions.
`MapReduceObservable<TResult>`	`limit(int limit)` Sets the limit to apply.
`MapReduceObservable<TResult>`	`maxTime(long maxTime, TimeUnit timeUnit)` Sets the maximum execution time on the server for this operation.
`MapReduceObservable<TResult>`	`nonAtomic(boolean nonAtomic)` Sets if the post-processing step will prevent MongoDB from locking the database.
`MapReduceObservable<TResult>`	`scope(org.bson.conversions.Bson scope)` Sets the global variables that are accessible in the map, reduce and finalize functions.
`MapReduceObservable<TResult>`	`sharded(boolean sharded)` Sets if the output database is sharded
`MapReduceObservable<TResult>`	`sort(org.bson.conversions.Bson sort)` Sets the sort criteria to apply to the query.
`rx.Observable<Success>`	`toCollection()` Aggregates documents to a collection according to the specified map-reduce function with the given options, which must specify a non-inline result.
`MapReduceObservable<TResult>`	`verbose(boolean verbose)` Sets whether to include the timing information in the result information.

Methods inherited from interface com.mongodb.rx.client.MongoObservable
subscribe, toObservable

- Method Detail
  - collectionName
```
MapReduceObservable<TResult> collectionName(String collectionName)
```
    Sets the collectionName for the output of the MapReduce
    The default action is replace the collection if it exists, to change this use action(com.mongodb.client.model.MapReduceAction).
    
    Parameters:
    
    collectionName - the name of the collection that you want the map-reduce operation to write its output.
    
    Returns:
    
    this
  - finalizeFunction
```
MapReduceObservable<TResult> finalizeFunction(String finalizeFunction)
```
    Sets the JavaScript function that follows the reduce method and modifies the output.
    
    Parameters:
    
    finalizeFunction - the JavaScript function that follows the reduce method and modifies the output.
    
    Returns:
    
    this
    
    MongoDB documentation
    
    Requirements for the finalize Function
  - scope
```
MapReduceObservable<TResult> scope(org.bson.conversions.Bson scope)
```
    Sets the global variables that are accessible in the map, reduce and finalize functions.
    
    Parameters:
    
    scope - the global variables that are accessible in the map, reduce and finalize functions.
    
    Returns:
    
    this
    
    MongoDB documentation
    
    mapReduce
  - sort
```
MapReduceObservable<TResult> sort(org.bson.conversions.Bson sort)
```
    Sets the sort criteria to apply to the query.
    
    Parameters:
    
    sort - the sort criteria, which may be null.
    
    Returns:
    
    this
    
    MongoDB documentation
    
    Sort
  - filter
```
MapReduceObservable<TResult> filter(org.bson.conversions.Bson filter)
```
    Sets the query filter to apply to the query.
    
    Parameters:
    
    filter - the filter to apply to the query.
    
    Returns:
    
    this
    
    MongoDB documentation
    
    Filter
  - limit
```
MapReduceObservable<TResult> limit(int limit)
```
    Sets the limit to apply.
    
    Parameters:
    
    limit - the limit, which may be null
    
    Returns:
    
    this
    
    MongoDB documentation
    
    Limit
  - jsMode
```
MapReduceObservable<TResult> jsMode(boolean jsMode)
```
    Sets the flag that specifies whether to convert intermediate data into BSON format between the execution of the map and reduce functions. Defaults to false.
    
    Parameters:
    
    jsMode - the flag that specifies whether to convert intermediate data into BSON format between the execution of the map and reduce functions
    
    Returns:
    
    jsMode
    
    MongoDB documentation
    
    mapReduce
  - verbose
```
MapReduceObservable<TResult> verbose(boolean verbose)
```
    Sets whether to include the timing information in the result information.
    
    Parameters:
    
    verbose - whether to include the timing information in the result information.
    
    Returns:
    
    this
  - maxTime
```
MapReduceObservable<TResult> maxTime(long maxTime,
                                     TimeUnit timeUnit)
```
    Sets the maximum execution time on the server for this operation.
    
    Parameters:
    
    maxTime - the max time
    
    timeUnit - the time unit, which may not be null
    
    Returns:
    
    this
    
    MongoDB documentation
    
    Max Time
  - action
```
MapReduceObservable<TResult> action(com.mongodb.client.model.MapReduceAction action)
```
    Specify the MapReduceAction to be used when writing to a collection.
    
    Parameters:
    
    action - an MapReduceAction to perform on the collection
    
    Returns:
    
    this
  - databaseName
```
MapReduceObservable<TResult> databaseName(String databaseName)
```
    Sets the name of the database to output into.
    
    Parameters:
    
    databaseName - the name of the database to output into.
    
    Returns:
    
    this
    
    MongoDB documentation
    
    output with an action
  - sharded
```
MapReduceObservable<TResult> sharded(boolean sharded)
```
    Sets if the output database is sharded
    
    Parameters:
    
    sharded - if the output database is sharded
    
    Returns:
    
    this
    
    MongoDB documentation
    
    output with an action
  - nonAtomic
```
MapReduceObservable<TResult> nonAtomic(boolean nonAtomic)
```
    Sets if the post-processing step will prevent MongoDB from locking the database. Valid only with the MapReduceAction.MERGE or MapReduceAction.REDUCE actions.
    
    Parameters:
    
    nonAtomic - if the post-processing step will prevent MongoDB from locking the database.
    
    Returns:
    
    this
    
    MongoDB documentation
    
    output with an action
  - toCollection
```
rx.Observable<Success> toCollection()
```
    Aggregates documents to a collection according to the specified map-reduce function with the given options, which must specify a non-inline result.
    
    Returns:
    
    an Observable with a single element indicating when the operation has completed
    
    MongoDB documentation
    
    Aggregation

Interface MapReduceObservable<TResult>

Method Summary

Methods inherited from interface com.mongodb.rx.client.MongoObservable

Method Detail

collectionName

finalizeFunction

scope

sort

filter

limit

jsMode

verbose

maxTime

action

databaseName

sharded

nonAtomic

toCollection