Hi Kaniska, hi Frances, The Flink Runner uses the Beam type information alongside with its coders. So using the ProtoCoder should work fine. If you're using Kafka for receiving/sending records, you can proceed similarly as in the AvroKafka example, replacing the AvroCoder with the ProtoCoder.
Cheers, Max On Sat, May 14, 2016 at 12:33 AM, Frances Perry <[email protected]> wrote: > The Beam CoderRegistry registers ProtoCoder 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 > >
