[This is preliminary documentation and is subject to change.]
The StageTVertex, TTime generic type exposes the following members.
Methods
| Name | Description | |
|---|---|---|
 | NewInputTRecord(StreamTRecord, TTime, ActionMessageTRecord, TTime, TVertex, ExpressionFuncTRecord, Int32) |
Creates a new input that consumes records from the given stream, partitioned by the given partitioning function,
and delivers them to a vertex through the given onReceive callback.
|
| NewInputTRecord(StreamTRecord, TTime, ActionMessageTRecord, TTime, TVertex, ExpressionFuncTRecord, Int32, ActionTRecord, Int32, Int32) |
Creates a new input that consumes records from the given stream, partitioned by the given partitioning function,
and delivers them to a vertex through the given onReceive callback.
|
| NewInputTRecord, TTime(StreamTRecord, TTime, ExpressionFuncTRecord, Int32) |
Creates a new input for this stage, with the given partitioning requirement.
(Inherited from Stage.) |
| NewInputTRecord, TTime(StreamTRecord, TTime, ExpressionFuncTRecord, Int32, ActionTRecord, Int32, Int32) |
Creates a new input for this stage, with the given partitioning requirement.
(Inherited from Stage.) |
| NewOutputR(FuncTVertex, VertexOutputR, TTime) |
Creates a new output with no partitioning guarantee.
|
| NewOutputR(FuncTVertex, VertexOutputR, TTime, ExpressionFuncR, Int32) |
Creates a new output with a partitioning guarantee
|
| ToString |
Returns the stage name decorated with the stage ID.
(Inherited from Stage.) |
See Also