Pump
task4

Queue5

Pump
task9

Queue10

External
source
(ex: MQTT,
TCP, UDS)

External
source

Source
stream

Source
stream

Stream

Stream

Stream

Stream

Sink
stream

Sink
stream

External
sink
(ex: MQTT,
TCP, UDS,
host-app)

External
sink

Pump3

Pump8

Pump2

Pump7

Pump9

Pump4

Source
reader1

Source
reader6

Sink
writer5

Sink
writer10

Pipeline

External
source

External
source

Source
task1

Source
task6

Pump
task2

Pump
task7

Pump
task8

Pump
task3

Sink
task5

Sink
task10

External
sink

External
sink

Task Graph

Queue2

Queue3.1

Queue4

Queue7

Queue8

Queue9

Queue3.2