[This is preliminary documentation and is subject to change.]
The Dataflow.StandardVertices namespace provides base implementations of commonly-used dataflow vertex types, such as UnaryVertexTInput, TOutput, TTime and BinaryVertexTInput1, TInput2, TOutput, TTime.
Classes
Class | Description | |
---|---|---|
BinaryBufferingVertexTInput1, TInput2, TOutput, TTime |
Vertex with two inputs, one output, which accumulates inputs and schedules itself for each time seen.
| |
BinaryVertexTInput1, TInput2, TOutput, TTime |
Vertex with two inputs, one output, which calls OnRecv1/OnRecv2 for each input, and OnNotify(time) if ScheduleAt(time) is ever called.
| |
ExtensionMethods |
Methods to create and apply LINQ expressions on a time-by-time basis.
| |
Foundry |
Methods to instantiate stages based on factories.
| |
SinkBufferingVertexTOutput, TTime |
Vertex with one input, which accumulates inputs and schedules itself for each time seen.
| |
SinkVertexTOutput, TTime |
Vertex with one input, no outputs, which accumulates inputs and schedules itself for each time seen.
| |
UnaryBufferingVertexTInput, TOutput, TTime |
Vertex with one input, one output, which accumulates inputs and schedules itself for each time seen.
| |
UnaryVertexTInput, TOutput, TTime |
Vertex with one input, one output, which calls OnRecv for each record, and OnNotify(time) if it invokes ScheduleAt(time).
|