public interface ReactiveMapReduceOperation
ReactiveMapReduceOperation
allows creation and execution of MongoDB mapReduce operations in a fluent API
style. The starting domainType is used for mapping an optional Query
provided via matching
into the MongoDB specific representation. By default, the originating domainType is also used for mapping
back the results from the Document
. However, it is possible to define an different
returnType via as
to mapping the result.Document
. Using inCollection
allows to override the
collection name for the execution.
mapReduce(Human.class)
.map("function() { emit(this.id, this.firstname) }")
.reduce("function(id, name) { return sum(id, name); }")
.inCollection("star-wars")
.as(Jedi.class)
.matching(query(where("lastname").is("skywalker")))
.all();
Modifier and Type | Interface and Description |
---|---|
static interface |
ReactiveMapReduceOperation.MapReduceWithCollection<T>
Collection override (Optional).
|
static interface |
ReactiveMapReduceOperation.MapReduceWithMapFunction<T>
Provide the Javascript
function() used to map matching documents. |
static interface |
ReactiveMapReduceOperation.MapReduceWithOptions<T>
Additional mapReduce options (Optional).
|
static interface |
ReactiveMapReduceOperation.MapReduceWithProjection<T>
Result type override (Optional).
|
static interface |
ReactiveMapReduceOperation.MapReduceWithQuery<T>
Input document filter query (Optional).
|
static interface |
ReactiveMapReduceOperation.MapReduceWithReduceFunction<T>
Provide the Javascript
function() used to reduce matching documents. |
static interface |
ReactiveMapReduceOperation.ReactiveMapReduce<T>
ReactiveMapReduceOperation.ReactiveMapReduce provides methods for constructing reactive mapReduce operations in a fluent way. |
static interface |
ReactiveMapReduceOperation.TerminatingMapReduce<T>
Trigger mapReduce execution by calling one of the terminating methods.
|
Modifier and Type | Method and Description |
---|---|
<T> ReactiveMapReduceOperation.MapReduceWithMapFunction<T> |
mapReduce(Class<T> domainType)
Start creating a mapReduce operation for the given domainType.
|
<T> ReactiveMapReduceOperation.MapReduceWithMapFunction<T> mapReduce(Class<T> domainType)
domainType
- must not be null.ExecutableFindOperation.ExecutableFind
.IllegalArgumentException
- if domainType is null.Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.