[This is preliminary documentation and is subject to change.]

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,
	Func<TRecord, int> iterationSelector,
	Expression<Func<TRecord, int>> partitionedBy,
	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.

iterationSelector

Type: System.Func<TRecord, Int32>
Function that maps an input record to the iteration at which that record should be introduced.

partitionedBy

Type: System.Linq.Expressions.Expression<Func<TRecord, Int32>>
Partitioning function for the input stream.

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

Usage Note

Reference