title: Is there any reference of Misra-Gries Implementation in apache-flink?
body: <p>I want to implement Misra-Gries algorithm in apache flink. But unable think of distributed MapState usage. Any reference would help. </p>