MBrace.Flow


CloudFlow<'T>

Namespace: MBrace.Flow

Represents a distributed Stream of values.

Instance members

Instance memberDescription
DegreeOfParallelism
Signature: int option
Modifiers: abstract

Declared degree of parallelism by the workflow.

CompiledName: get_DegreeOfParallelism

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.

Fork me on GitHub