CloudCollection
Namespace: MBrace.Library
Parent Module: CloudCollectionUtils
Static members
| Static member | Description |
Concat(partitions)
Signature: partitions:seq<'?7486> -> IPartitionedCollection<'T>
Type parameters: '?7486, 'T |
Concatenates a collection of CloudCollections into a single, partitioned entity. |
ExtractPartitions(collection)
Signature: collection:ICloudCollection<'T> -> Async<ICloudCollection<'T> []>
Type parameters: 'T |
Traverses provided cloud collection for partitions, returning its irreducible components while preserving ordering. |
ExtractPartitions(collections)
Signature: collections:seq<'?7489> -> Async<ICloudCollection<'T> []>
Type parameters: '?7489, 'T |
Traverses provided cloud collections for partitions, returning their irreducible components while preserving ordering. |
ExtractTargetedCollections(collections)
Signature: collections:seq<'?7496> -> Async<(IWorkerRef * ICloudCollection<'T> []) []>
Type parameters: '?7496, 'T |
Recursively extracts scheduling information from a set of targeted partition collections. |
OfHttpFile(...)
Signature: (url:string * encoding:Encoding option * ensureThatFileExists:bool option) -> Async<HTTPTextCollection>
|
Creates a partitionable CloudCollection instance based on given http url. |
OfSeq(sequence)
Signature: sequence:seq<'T> -> ICloudCollection<'T>
Type parameters: 'T |
Creates a single-partition CloudCollection instance based on a given sequence. |
PartitionBySize(...)
Signature: (collections:ICloudCollection<'T> [] * workers:IWorkerRef [] * isTargetedWorkerEnabled:bool option * weight:(IWorkerRef -> int) option) -> Async<(IWorkerRef * ICloudCollection<'T> []) []>
Type parameters: 'T |
Performs partitioning of provided irreducible CloudCollections to supplied workers. This partitioning scheme takes collection sizes as well as worker capacities into account in order to achieve uniformity. It also takes IPartitionableCollection (i.e. dynamically partitionable collections) into account when traversing. |
