[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.NaiadStreamTRecord, TTime
The input stream.

function

Type: SystemFuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime
The Naiad computation to apply iteratively.

iterationSelector

Type: SystemFuncTRecord, Int32
Function that maps an input record to the iteration at which that record should be introduced.

partitionedBy

Type: System.Linq.ExpressionsExpressionFuncTRecord, Int32
Partitioning function for the input stream.

iterations

Type: SystemInt32
The number of iterations to perform.

name

Type: SystemString
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