Module erdos::dataflow::connect

Functions

connect_one_in_one_out

Adds a OneInOneOut operator that has one input read stream and one output write stream.

connect_one_in_two_out

Adds a OneInTwoOut operator that has one input read stream and two output write streams.

connect_parallel_one_in_one_out

Adds a ParallelOneInOneOut operator that has one input read stream and one output write stream.

connect_parallel_one_in_two_out

Adds a ParallelOneInTwoOut operator that has one input read stream and two output write streams.

connect_parallel_sink

Adds a ParallelSink operator, which receives data on input read streams and directly interacts with external systems.

connect_parallel_two_in_one_out

Adds a ParallelTwoInOneOut operator that has two input read streams and one output write stream.

connect_sink

Adds a Sink operator, which receives data on input read streams and directly interacts with external systems.

connect_source

Adds a Source operator, which has no read streams, but introduces data into the dataflow graph by interacting with external data sources (e.g., other systems, sensor data).

connect_two_in_one_out

Adds a TwoInOneOut operator that has two input read streams and one output write stream.