DoFn, I'd guess the relevant piece of code is ReadViaSDF.java
>> Best
>> -P.
>> [1] https://github.com/apache/beam/pull/11749/files
>>
>> On Mon, Jun 15, 2020 at 10:00 AM Pedro H S Teixeira
>> wrote:
>>
>>> Hi Boyuan,
>>>
>>>
Hi Boyuan,
Is the implementation (even if incomplete) open source / available at this
moment?
Trying to implement here an IO to a custom source here using SplittableDoFn,
and it would be helpful to see more examples :)
Thanks,
Pedro
On 2020/05/29 02:16:49, Boyuan Zhang wrote:
> Hi team,
>
