@startuml

skinparam componentArrowFontSize 12

title Stream Lookup: Join SQL Results

[Read Source Table A\n(SQL Query)] as TA #lightgrey
[Read Source Table B\n(SQL Query)] as TB #lightgrey
[Stream Lookup] as StreamLookup #lightblue
() "JSON / map[string]interface{}" as JSON

note bottom of TA : records must\nbe ordered
note right of TB : records must\nbe ordered
note right of StreamLookup : specify join keys\ninputs must be ordered
note right of JSON : consume records on a go channel

TA -> StreamLookup
TB --> StreamLookup
StreamLookup --> JSON : "Records are joined:\nTable-A  (1:n)  Table-B"


@enduml
