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

public static void MakeStage(
	Stream<TOutput, TTime> stream,
	Func<int, Stage<TTime>, SinkVertex<TOutput, TTime>> factory,
	Expression<Func<TOutput, int>> partitionedBy,
	string name
)

Parameters

stream

Type: Microsoft.Research.NaiadStreamTOutput, TTime
source stream

factory

Type: SystemFuncInt32, StageTTime, SinkVertexTOutput, TTime
vertex factory

partitionedBy

Type: System.Linq.ExpressionsExpressionFuncTOutput, Int32
partitioning requirement

name

Type: SystemString
stage name

Reference