Stage(TVertex, TTime).NewOutput(R) Method (Func(TVertex, VertexOutput(R, TTime)), Expression(Func(R, Int32)))

StageTVertex, TTimeNewOutputR Method (FuncTVertex, VertexOutputR, TTime, ExpressionFuncR, Int32)

Naiad Help

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

Creates a new output with a partitioning guarantee

Namespace: Microsoft.Research.Naiad.Dataflow
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)

Syntax

public Stream<R, TTime> NewOutput<R>(
	Func<TVertex, VertexOutput<R, TTime>> vertexOutput,
	Expression<Func<R, int>> partitionedBy
)

vertexOutput: Type: SystemFuncTVertex, VertexOutputR, TTime
Given a vertex in this stage, returns the corresponding vertex-level output.
partitionedBy: Type: System.Linq.ExpressionsExpressionFuncR, Int32
A partitioning guarantee, or null if there is no known partitioning guarantee.

Type: StreamR, TTime
A handle to the output stream.