在window内做stream join

# robinhood问到的，有些难度

Window: 5 seconds

ts   S1 (left)     S2 (right)      Joined

1    k1, v1        k2, v11

2

3    k1, v2         

4    k2, v5                        k2, (v5, v11)

5                  k1, v12         k1, (v1, v12); k1, (v2, v12)

6   

7

8    k2, v7

........

6                  k2, v4          k2, (v5, v4); k2, (v7, v4)

Joined iff keys are the same and ts in [join_event - w, join_event + w]

combined: Iterator[is_left: bool, ts: int, key: str, value: str]

output: Iterator[key: str, v_left: str, v_right: str]

'''

def join_streams(combined: Iterator, window: int) -> Iterator:

    return joined