package workflowtask
- Alphabetic
- By Inheritance
- workflowtask
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- type Pipeline = List[PipelineOp]
- type WorkflowTask = Fix[WorkflowTaskF]
-
sealed abstract
class
WorkflowTaskF[A] extends AnyRef
A WorkflowTask approximately represents one request to MongoDB.
Value Members
-
def
finish(base: DocVar, task: WorkflowTask): (DocVar, WorkflowTask)
Run once a task is known to be completely built.
- def normalize: ~>[WorkflowTaskF, WorkflowTaskF]
- val simplifyProject: (WorkflowOpCoreF[slamdata.Predef.Unit]) ⇒ slamdata.Predef.Option[PipelineF[WorkflowOpCoreF, slamdata.Predef.Unit]]
- object FoldLeftTask
- object FoldLeftTaskF
- object MapReduceTask
- object MapReduceTaskF
- object PipelineTask
- object PipelineTaskF
- object PureTask
- object PureTaskF
- object QueryTask
- object QueryTaskF
- object ReadTask
- object ReadTaskF
- object WorkflowTaskF