The Beam CoderRegistry registers ProtoCoder <https://github.com/apache/incubator-beam/blob/96765f19b1bd8149240cd77eb7cf7fb636e477e4/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/protobuf/ProtoCoder.java> for encoding PCollection<Message>. So the goal would be that the type inference should correctly figure out how to encode things at the Beam level and then work in all runners. (But I don't know the details on the FlinkRunner.)
On Fri, May 13, 2016 at 3:00 PM, kaniska Mandal <[email protected]> wrote: > 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 >
