[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,
	Action<TRecord[], int[], int> vectoredPartitioning
)
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.

vectoredPartitioning

Type: SystemActionTRecord, Int32, Int32
Action that maps an array of records to an array of integers, implying the requirement that all records mapping to the same integer must be processed by the same Vertex. The third argument is the number of valid records in the input array

Type Parameters

TRecord

The record type.

TTime

The time type.

Return Value

Reference