[This is preliminary documentation and is subject to change.]
Overload List
| Name | Description | |
|---|---|---|
 | 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.) |
| 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.
|
See Also