< Back

Packages

package root

Definition Classes
root
package quasar

Definition Classes
root
package physical

Definition Classes
quasar
package mongodb

Definition Classes
physical
package workflow
A Workflow is a graph of atomic operations, with WorkflowOps for the vertices.
A Workflow is a graph of atomic operations, with WorkflowOps for the vertices. We crush them down into a WorkflowTask. This crush gives us a location to optimize our workflow decisions. EG, A sequence of simple ops may be combined into a single pipeline request, but if one of those operations contains JS, we have to execute that outside of a pipeline, possibly reordering the other operations to avoid having two pipelines with a JS operation in the middle.
We also implement the optimizations atomic http://docs.mongodb.org/manual/core/aggregation-pipeline-optimization/ so that we can build others potentially on top of them (including reordering non-pipelines around pipelines, etc.).

Definition Classes
mongodb
$AddFieldsF
$FlatMapF
$FoldLeftF
$GeoNearF
$GroupF
$LimitF
$LookupF
$MapF
$MatchF
$OutF
$ProjectF
$PureF
$ReadF
$RedactF
$ReduceF
$SampleF
$SimpleMapF
$SkipF
$SortF
$UnwindF
$addFields
$flatMap
$foldLeft
$geoNear
$group
$limit
$lookup
$map
$match
$out
$project
$pure
$read
$redact
$reduce
$sample
$simpleMap
$skip
$sort
$unwind
CardinalExpr
Classify
Coalesce
Crush
Crystallize
Crystallized
ExcludeId
FlatExpr
IdHandling
IgnoreId
IncludeId
IsPipeline
IsShapePreserving
IsSingleSource
IsSource
MapExpr
MapReduceF
PipelineF
PipelineOp
PipelineOpCore
Refs
RewriteRefs
ShapePreservingF
SingleSourceF
SourceF
SubExpr
WorkflowOp3_4F
WorkflowOpCoreF
needsMapBeforeSort

c

quasar.physical.mongodb.workflow

$SortF

Companion object $SortF

final case class $SortF[A](src: A, value: NonEmptyList[(BsonField, SortDir)]) extends WorkflowOpCoreF[A] with Product with Serializable

Self Type: $SortF[A]

Linear Supertypes

WorkflowOpCoreF[A], Serializable, Serializable, Product, Equals, AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

$SortF
WorkflowOpCoreF
Serializable
Serializable
Product
Equals
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Instance Constructors

new $SortF(src: A, value: NonEmptyList[(BsonField, SortDir)])

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] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@native()
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
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()
def shapePreserving: ShapePreservingF[WorkflowOpCoreF, A]

Annotations
@SuppressWarnings()
val src: A
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val value: NonEmptyList[(BsonField, SortDir)]
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( ... )

Inherited from WorkflowOpCoreF[A]

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped