[This is preliminary documentation and is subject to change.]
Iteratively applies function to the given 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<TRecord, TTime> Iterate<TRecord, TTime>( this Stream<TRecord, TTime> stream, Func<LoopContext<TTime>, Stream<TRecord, IterationIn<TTime>>, Stream<TRecord, IterationIn<TTime>>> function, int iterations, string name ) where TTime : Object, Time<TTime>
Parameters
- stream
- Type: Microsoft.Research.Naiad.Stream<TRecord, TTime>
The input stream. - function
- Type: System.Func<LoopContext<TTime>, Stream<TRecord, IterationIn<TTime>>, Stream<TRecord, IterationIn<TTime>>>
The Naiad computation to apply iteratively. - iterations
- Type: System.Int32
The number of iterations to perform. - name
- Type: System.String
Descriptive name for the loop.
Type Parameters
- TRecord
- The type of the input records.
- TTime
- The type of timestamp on each record.
Return Value
Type: Stream<TRecord, TTime>The stream corresponding to applying function to the input iterations times.
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