[This is preliminary documentation and is subject to change.]
Counts the number of occurrences of each record in stream.
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 Stream<Pair<TRecord, long>, TTime> Count<TRecord, TTime>( this Stream<TRecord, TTime> stream ) where TTime : Object, Time<TTime>
Parameters
- stream
- Type: Microsoft.Research.Naiad.Stream<TRecord, TTime>
The input stream.
Type Parameters
- TRecord
- The type of the input records.
- TTime
- The type of timestamp on each record.
Return Value
Type: Stream<Pair<TRecord, Int64>, TTime>The stream containing pairs of a record and its respective count for each input record.
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type Stream<TRecord, TTime>. When you use instance method syntax to call this method, omit the first parameter. For more information, see Extension Methods (Visual Basic) or Extension Methods (C# Programming Guide).See Also