[This is preliminary documentation and is subject to change.]
Extension methods for Differential Dataflow CollectionTRecord, TTime objects
and related types.
Inheritance Hierarchy
Microsoft.Research.Naiad.Frameworks.DifferentialDataflowExtensionMethods
Namespace: Microsoft.Research.Naiad.Frameworks.DifferentialDataflow
Assembly: Microsoft.Research.Naiad.DifferentialDataflow (in Microsoft.Research.Naiad.DifferentialDataflow.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public static class ExtensionMethods
The ExtensionMethods type exposes the following members.
Methods
| Name | Description | |
|---|---|---|
  | AdjustTimeTRecord, TTime |
EXPERIMENTAL: Adjusts the timestamp on each record, under the requirement that the timestamp may only advance.
|
| AsCollectionTRecord, TTime |
Converts a stream of weighted records to a differential dataflow CollectionTRecord, TTime.
|
| AssumeImmutableTRecord, TTime |
Indicates that the input collection is immutable.
|
| AssumePartitionedByTRecord, TTime, TKey |
Instructs downstream operators to assume that the input collection is
partitioned according to the given key selector.
|
| OnCompletedTRecord(InputCollectionTRecord, WeightedTRecord) |
Adds a single record with an integer weight and signals that the InputCollectionTRecord is complete.
|
| OnCompletedTRecord(InputCollectionTRecord, IEnumerableTRecord) |
Adds several records and signals that the InputCollectionTRecord is complete.
|
| OnCompletedTRecord(InputCollectionTRecord, TRecord) |
Adds a single record and signals that the InputCollectionTRecord is complete.
|
| OnNextTRecord(InputCollectionTRecord) |
Introduces no records to a InputCollectionTRecord.
|
| OnNextTRecord(InputCollectionTRecord, IEnumerableTRecord) |
Adds records to an InputCollectionTRecord.
|
| OnNextTRecord(InputCollectionTRecord, TRecord) |
Adds a record to an InputCollectionTRecord.
|
| OnNextTRecord(InputCollectionTRecord, IEnumerableTRecord, Int32) |
Introduces several records to an InputCollectionTRecord with the same integer weight.
|
| OnNextTRecord(InputCollectionTRecord, TRecord, Int32) |
Introduces a record to an InputCollectionTRecord with an integer weight.
|
| SlidingWindowTRecord(CollectionTRecord, Epoch, Int32) | |
| SlidingWindowTRecord(StreamTRecord, Epoch, Int32) | |
| SubscribeTRecord |
Registers a callback that will be invoked each time the collection changes with a list of weighted records.
|
| ToWeightedTRecord |
Converts a record to a weighted record with the given weight.
|
See Also