[This is preliminary documentation and is subject to change.]
The Lindi operators are implemented as extension methods on Naiad StreamTRecord, TTime objects.
Inheritance Hierarchy
Microsoft.Research.Naiad.Frameworks.LindiExtensionMethods
Namespace: Microsoft.Research.Naiad.Frameworks.Lindi
Assembly: Microsoft.Research.Naiad.Lindi (in Microsoft.Research.Naiad.Lindi.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 | |
|---|---|---|
  | AggregateTKey, TState, TTime(StreamPairTKey, TState, TTime, FuncTState, TState, TState) |
Groups records using the supplied key selector, and applies the given aggregation function.
|
| AggregateTKey, TState, TTime(StreamPairTKey, TState, TTime, FuncTState, TState, TState, Boolean) |
Groups records using the supplied key selector, and applies the given aggregation function.
|
| AggregateTInput, TKey, TState, TOutput, TTime(StreamTInput, TTime, FuncTInput, TKey, FuncTInput, TState, FuncTState, TState, TState, FuncTKey, TState, TOutput) |
Groups records using the supplied key selector, and applies the given aggregation function.
|
| AggregateTInput, TKey, TState, TOutput, TTime(StreamTInput, TTime, FuncTInput, TKey, FuncTInput, TState, FuncTState, TState, TState, FuncTKey, TState, TOutput, Boolean) |
Groups records using the supplied key selector, and applies the given aggregation function.
|
| CoGroupByTInput1, TInput2, TKey, TOutput, TTime |
Groups records from both input streams using the respective key selector, and applies the given reduction function.
|
| ConcatTRecord, TTime |
Computes the concatention of stream1 and stream2.
|
| CountTRecord, TTime |
Counts the number of occurrences of each record in stream.
|
| DistinctTRecord, TTime |
Computes the set of distinct records in stream.
|
| ExceptTRecord, TTime |
Computes the difference of records in stream1 but not in stream2.
|
| GroupByTInput, TKey, TOutput, TTime |
Groups records using the supplied key selector, and applies the given reduction function.
|
| IntersectTRecord, TTime |
Computes the set intersection of records in stream1 and stream2.
|
| JoinTInput1, TInput2, TKey, TOutput, TTime |
Joins the records in stream1 with the records in stream2, using the respective key selectors.
|
| MaxTInput, TKey, TValue, TTime |
Groups records using the supplied key selector, and computes the maximum value in each group.
|
| MinTInput, TKey, TValue, TTime |
Groups records using the supplied key selector, and computes the minimum value in each group.
|
| SelectTInput, TOutput, TTime |
Transforms each record in the input stream using the given selector function.
|
| SelectManyTInput, TOutput, TTime |
Transforms each record in the collection using the given selector function and flattens the result.
|
| UnionTRecord, TTime |
Computes the set union of records in stream1 and stream2.
|
| WhereTRecord, TTime |
Filters the input stream to contain only record that match the given predicate.
|
See Also