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

public StageInput<TRecord, TTime> NewInput<TRecord, TTime>(
	Stream<TRecord, TTime> stream,
	Expression<Func<TRecord, int>> partitioning
)
where TTime : Object, Time<TTime>

Parameters

stream

Type: Microsoft.Research.NaiadStreamTRecord, TTime
The stream from which this input will receive records.

partitioning

Type: System.Linq.ExpressionsExpressionFuncTRecord, Int32
Function that maps records to integers, implying the requirement that all records mapping to the same integer must be processed by the same Vertex.

Type Parameters

TRecord

The record type.

TTime

The time type.

Return Value

Reference