beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Abdul Qadeer <>
Subject Custom Unbounded Sources for 2.4.0 SDK
Date Sat, 09 Jun 2018 07:31:23 GMT

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.

View raw message