final case class MapReduce(map: Expr, reduce: Expr, selection: slamdata.Predef.Option[Selector] = None, inputSort: slamdata.Predef.Option[NonEmptyList[(BsonField, SortDir)]] = None, limit: slamdata.Predef.Option[slamdata.Predef.Long] = None, finalizer: slamdata.Predef.Option[Expr] = None, scope: Scope = ListMap(), jsMode: slamdata.Predef.Option[slamdata.Predef.Boolean] = None, verbose: slamdata.Predef.Option[slamdata.Predef.Boolean] = None) extends Product with Serializable
Configuration parameters for MapReduce operations
- map
The mapping function
- reduce
The reducing function
- selection
Query selector to apply to input documents
- inputSort
Criteria to use to sort the input documents.
- limit
Limit the number of input documents to
map- finalizer
JavaScript function applied to the output after the
reducefunction.- scope
Global variables made available to the
map,reduceandfinalizerfunctions.- jsMode
Whether to avoid converting intermediate values to BSON, leaving them as JavaScript objects instead. Setting this to
truehas implications on the size of the input, see the MongoDBmapReducedocumentation for details.- verbose
Whether to include additional information, such as timing, in the results.
- Annotations
- @SuppressWarnings()
- Alphabetic
- By Inheritance
- MapReduce
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
MapReduce(map: Expr, reduce: Expr, selection: slamdata.Predef.Option[Selector] = None, inputSort: slamdata.Predef.Option[NonEmptyList[(BsonField, SortDir)]] = None, limit: slamdata.Predef.Option[slamdata.Predef.Long] = None, finalizer: slamdata.Predef.Option[Expr] = None, scope: Scope = ListMap(), jsMode: slamdata.Predef.Option[slamdata.Predef.Boolean] = None, verbose: slamdata.Predef.Option[slamdata.Predef.Boolean] = None)
- map
The mapping function
- reduce
The reducing function
- selection
Query selector to apply to input documents
- inputSort
Criteria to use to sort the input documents.
- limit
Limit the number of input documents to
map- finalizer
JavaScript function applied to the output after the
reducefunction.- scope
Global variables made available to the
map,reduceandfinalizerfunctions.- jsMode
Whether to avoid converting intermediate values to BSON, leaving them as JavaScript objects instead. Setting this to
truehas implications on the size of the input, see the MongoDBmapReducedocumentation for details.- verbose
Whether to include additional information, such as timing, in the results.
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- val finalizer: slamdata.Predef.Option[Expr]
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def inlineBson: Doc
- val inputSort: slamdata.Predef.Option[NonEmptyList[(BsonField, SortDir)]]
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val jsMode: slamdata.Predef.Option[slamdata.Predef.Boolean]
- val limit: slamdata.Predef.Option[slamdata.Predef.Long]
- val map: Expr
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val reduce: Expr
- val scope: Scope
- val selection: slamdata.Predef.Option[Selector]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- def toCollBson(dst: OutputCollection): Doc
- val verbose: slamdata.Predef.Option[slamdata.Predef.Boolean]
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )