[This is preliminary documentation and is subject to change.]
The Utils type exposes the following members.
Methods
| Name | Description | |
|---|---|---|
  | DefaultPartFormat(Uri, Int32, Int32, Int32) |
default filename generator for a collection partitioned by key, but concatenated across times
|
| DefaultPartFormatTTime(Uri, Int32, Int32, TTime, Int32) |
default filename generator for a collection partitioned by key and time
|
| GetNaiadReaderBatchEnumerableTRecord |
Enumerates batches of records from a stream in the Naiad serialization format.
|
| GetNaiadReaderEnumerableTRecord |
Enumerates records from a stream in the Naiad serialization format.
|
| GetNaiadWriterObserverTRecord |
Returns an record observer that writes records to the given stream in the Naiad message format.
|
| ReadLines |
Enumerates lines of text from a stream
|
| WriteBySubscriptionTOutput, TWriter |
serialize a sequence of records to a collection of files partitioned by process and thread. For each
process/thread this writes a sequence of files; each time a file reaches a threshold number of bytes,
it is closed and another is opened. This keeps individual files of bounded length, allowing for more
parallelism when reading them later
|
| WriteByTimeTOutput, TClient, TWriter, TTime |
serialize a sequence of records to a collection of files partitioned by process, thread and time. For each
process/thread/time this writes a sequence of files; each time a file reaches a threshold number of bytes,
it is closed and another is opened. This keeps individual files of bounded length, allowing for more
parallelism when reading them later
|
See Also