...
ts | LHS-Stream (K, extracted-FK) | RHS-Stream State (FK,V) | Inner-Join Output | Left-Join OutputExecute Join Logic? | |
---|---|---|---|---|---|
1 | Publish event to LHS | (k,1) | (1,foo) | (k,1,foo) | (k,1,foo)Inner/Left |
2 | Change LHS fk | (k,2) | (1,foo) | (k,null) | (k,2,null)LEFT |
3 | Change LHS fk | (k,3) | (1,foo) | (k,null) | (k,3,null)LEFT |
4 | Publish RHS entity | - | (1,foo) | (k,3,bar) | (k,3,bar)Inner/Left |
5 | Delete k | (k,null) | (1,foo) | (k,null) | (k,null,null)LEFT |
6 | Publish original event again | (k,1) | (1,foo) | (k,1,foo) | (k,1,foo)Inner/Left |
7 | Publish event to LHS | (q,10) | (1,foo) | - | (q,null,10)LEFT |
8 | Publish RHS entity | - | (1,foo) | (q,10,baz) | (q,10,baz)Inner/Left |
Anchor | ||||
---|---|---|---|---|
|
...