git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Custom Unbounded Sources for 2.4.0 SDK


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é
jbonofre@xxxxxxxxxx
http://blog.nanthrax.net
Talend - http://www.talend.com