|
| Name | Description |
|---|
  | IterateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, Int32, String) |
Iteratively applies function to the given stream.
|
| IterateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, ExpressionFuncTRecord, Int32, Int32, String) |
Iteratively applies function to the given stream.
|
| IterateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, FuncTRecord, Int32, ExpressionFuncTRecord, Int32, Int32, String) |
Iteratively applies function to the given stream.
|
| IterateAndAccumulateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, Int32, String) |
Iteratively applies function to the given stream and accumulates all of the iterates.
|
| IterateAndAccumulateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, ExpressionFuncTRecord, Int32, Int32, String) |
Iteratively applies function to the given stream and accumulates all of the iterates.
|
| IterateAndAccumulateTRecord, TTime(StreamTRecord, TTime, FuncLoopContextTTime, StreamTRecord, IterationInTTime, StreamTRecord, IterationInTTime, FuncTRecord, Int32, ExpressionFuncTRecord, Int32, Int32, String) |
Iteratively applies function to the given stream and accumulates all of the iterates.
|
| SelectByVertexTInput, TOutput, TTime |
Transforms each record in the input stream using the given selector function.
|
| SelectManyArraySegmentTInput, TOutput, TTime |
Transforms each record in the collection using the given selector function and flattens the result.
|
| SynchronizeTRecord, TTime |
For each timestamp, buffers the given stream until all workers have all input for that time, and then releases the buffer.
|
| WriteToFilesTInput |
Writes the records in the given stream to files.
|
