Re: [python] ReadFromPubSub broken in Flink

2019-07-13 Thread Chad Dombrova
Hi Chamikara, >>- why not make this part of the pipeline options? does it really >> need to vary from transform to transform? >> >> It's possible for the same pipeline to connect to multiple expansion > services, to use transforms from more than one SDK language and/or version. >

Re: [python] ReadFromPubSub broken in Flink

2019-07-13 Thread Maximilian Michels
Hi Chad, This stub will only be replaced by the Dataflow service. It's an artifact of the pre-portability era. That said, we now have the option to replace ReadFromPubSub with an external transform which would utilize Java's PubSubIO via the new cross-language feature. Thanks, Max On