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

public StageInput<TRecord, TTime> NewInput<TRecord>(
	Stream<TRecord, TTime> stream,
	Action<Message<TRecord, TTime>, TVertex> onReceive,
	Expression<Func<TRecord, int>> partitionedBy,
	Action<TRecord[], int[], int> vectoredPartitionedBy
)

Parameters

stream

Type: Microsoft.Research.NaiadStreamTRecord, TTime
The stream from which records will be consumed.

onReceive

Type: SystemActionMessageTRecord, TTime, TVertex
A callback that will be invoked on a message and vertex when that message is to be delivered to that vertex.

partitionedBy

Type: System.Linq.ExpressionsExpressionFuncTRecord, Int32
A partitioning expression, or null if the records need not be repartitioned.

vectoredPartitionedBy

Type: SystemActionTRecord, Int32, Int32
Action that maps an array of records to an array of integers, or none, 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

Record type

Return Value

Reference