scalaz.stream.mongodb

aggregate

package aggregate

Visibility
  1. Public
  2. All

Type Members

  1. trait AggregationStringOps extends Ops[String]

    Snytax to be used on string for pipeline commands

  2. trait AggregationSyntax extends AnyRef

    syntax applied for aggregation commands

  3. case class CombinedPipeline(operators: Seq[PipelineOperator]) extends PipelineOperator with Product with Serializable

    User: pach Date: 9/27/13 Time: 7:01 AM (c) 2011-2013 Spinoco Czech Republic, a.

  4. case class ComputedField(name: String, value: String, operation: String) extends ProjectPipelineAction with Product with Serializable

    Represents field that has to be computed *

  5. case class GroupId(id: DBObject) extends Product with Serializable

  6. case class GroupPipeline(id: DBObject, computed: Seq[ComputedField]) extends PipelineOperator with Product with Serializable

    wraps http://docs.mongodb.org/manual/reference/aggregation/group/#pipe._S_group

  7. case class LimitPipeline(count: Int) extends PipelineOperator with Product with Serializable

    limits returned results from pipeline *

  8. case class MapReduce(mapF: String, reduceF: String, finalizeF: Option[String] = scala.None, limit: Option[Int] = scala.None, scope: Option[String] = scala.None, jsMode: Boolean = false, verboseFlag: Boolean = false) extends MapReduceDefinition with Product with Serializable

  9. trait MapReduceDefinition extends AnyRef

  10. case class MapReducePersistent(mr: MapReduce, persistCollection: String, persistDb: Option[String] = scala.None, current: MapReducePersistOption.Value = MapReducePersistOption.Override, sh: Boolean = false, na: Boolean = false) extends MapReduceDefinition with Product with Serializable

  11. case class MatchPipeline(q: BasicQuery) extends PipelineOperator with Product with Serializable

    User: pach Date: 9/27/13 Time: 6:52 AM (c) 2011-2013 Spinoco Czech Republic, a.

  12. trait PipelineOperator extends AnyRef

    User: pach Date: 9/26/13 Time: 5:57 AM (c) 2011-2013 Spinoco Czech Republic, a.

  13. case class ProjectPipeline(action: Seq[ProjectPipelineAction]) extends PipelineOperator with Product with Serializable

    Wraps http://docs.mongodb.org/manual/reference/aggregation/project/#pipe._S_project

  14. trait ProjectPipelineAction extends AnyRef

  15. case class SetField(key: String, value: String) extends ProjectPipelineAction with Product with Serializable

    Sets given field to proposed value of another field

  16. case class SkipPipeline(count: Int) extends PipelineOperator with Product with Serializable

    skip command in pipeline *

  17. case class SortPipeline(op: Seq[OrderPair]) extends PipelineOperator with Product with Serializable

    User: pach Date: 9/26/13 Time: 7:39 AM (c) 2011-2013 Spinoco Czech Republic, a.

  18. case class UnWindPipeline(field: String) extends PipelineOperator with Product with Serializable

    User: pach Date: 9/26/13 Time: 7:36 AM (c) 2011-2013 Spinoco Czech Republic, a.

Value Members

  1. object GroupId extends Serializable

  2. object MapReducePersistOption extends Enumeration

  3. object PipelineOperator

Ungrouped