Flink: Stateful stream processing by key

Viewed 403

I have stream of data such as JSON records with an ID.

I would like to process the data such that all records with the same key are processed by the same stateful task.

How can I do that?

1 Answers
Related