...
| 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 | ||||
|---|---|---|---|---|
|
...