Hi, Not sure I understand your question.
You can use any source with Flink runner, all in Beam 2.4.0 (IOs/SDK/runner). You can see usage of different IOs (sources) with different runner in the beam-samples: https://github.com/jbonofre/beam-samples Regards JB On 09/06/2018 09:31, Abdul Qadeer wrote: > Hi! > > I would like to know if there is any way I can use 2.4.0 Beam's Source > API for Flink 1.4.0 runner? I have a custom unbounded source implemented > for Flink runner but I can not find the documentation to use it for 2.x > Beam SDK. Looks like it was only supported in 0.x SDK? Any help appreciated. -- Jean-Baptiste Onofré jbono...@apache.org http://blog.nanthrax.net Talend - http://www.talend.com
