Beam-Flink-Runner example using Protocol Buffer

[kaniska Mandal]

Hi Max,

It would be great if any example can be provided - how we can encode and
decode streaming messages using Google Protocol Buffer in a Pipeline using
Flink-Runner.


Thanks,
Kaniska