MBrace.Core


PersistedSequence

Namespace: MBrace.Library

Persisted Sequence collection of APIs

Static members

Static memberDescription
New(values, path, serializer, compress)
Signature: (values:seq<'T> * path:string option * serializer:ISerializer option * compress:bool option) -> LocalCloud<PersistedSequence<'T>>
Type parameters: 'T

Creates a new persisted sequence by writing provided sequence to a cloud file in the underlying store.

NewPartitioned(...)
Signature: (values:seq<'T> * maxPartitionSize:int64 * directory:string option * serializer:ISerializer option) -> LocalCloud<PersistedSequence<'T> []>
Type parameters: 'T

Creates a collection of partitioned cloud sequences by persisting provided sequence as cloud files in the underlying store. A new partition will be appended to the collection as soon as the 'maxPartitionSize' is exceeded in bytes.

OfCloudFile(...)
Signature: (path:string * textDeserializer:(StreamReader -> seq<'T>) * ensureFileExists:bool option * encoding:Encoding option * forceEvaluation:bool option * resolveEtag:bool option) -> LocalCloud<PersistedSequence<'T>>
Type parameters: 'T

Defines a PersistedSequence from provided cloud file path with user-provided text deserialization function. This is a lazy operation unless the optional 'force' parameter is enabled.

OfCloudFile(...)
Signature: (path:string * serializer:ISerializer * ensureFileExists:bool option * forceEvaluation:bool option * resolveEtag:bool option) -> LocalCloud<PersistedSequence<'T>>
Type parameters: 'T

Defines a PersistedSequence from provided cloud file path with user-provided serializer implementation. This is a lazy operation unless the optional 'force' parameter is enabled.

OfCloudFile(...)
Signature: (path:string * deserializer:(Stream -> seq<'T>) option * ensureFileExists:bool option * forceEvaluation:bool option * resolveEtag:bool option) -> LocalCloud<PersistedSequence<'T>>
Type parameters: 'T

Defines a PersistedSequence from provided cloud file path with user-provided deserialization function. This is a lazy operation unless the optional 'force' parameter is enabled.

OfCloudFileByLine(...)
Signature: (path:string * encoding:Encoding option * ensureFileExists:bool option * forceEvaluation:bool option * resolveEtag:bool option) -> LocalCloud<PersistedSequence<string>>

Defines a PersistedSequence from provided cloud file path with user-provided text deserialization function. This is a lazy operation unless the optional 'force' parameter is enabled.

Fork me on GitHub