Page History

...

As a result, the mapping of a key to a KeyGroup could be established inside the Source Operator, but the problem is that we have to pass down the key group of a record to the downstream operators with the record itself together. One solution is that we can create a new class called KeyedStreamRecord, which wrap wraps the StreamRecord with a new field, KeyGroup.

...