CloudFlow<'T>
Namespace: MBrace.Flow
Represents a distributed Stream of values.
Instance members
Instance member | Description |
DegreeOfParallelism
Signature: int option
Modifiers: abstract |
Declared degree of parallelism by the workflow. CompiledName: |
WithEvaluators(...)
Signature: collectorFactory:LocalCloud<Collector<'T,'S>> -> (projection:('S -> LocalCloud<'R>)) -> (combiner:('R [] -> LocalCloud<'R>)) -> Cloud<'R>
Modifiers: abstract Type parameters: 'R |
Creates a cloud computation that applies CloudFlow to provided evaluation functions. |