Hi Krzystof, instead of SourceFunctionProvider you need to use SourceProvider. If you look at the filesystem connector you can see an example for that, too (FileSystemTableSource#createSourceProvider).
Best Ingo On Thu, Nov 4, 2021 at 3:48 PM Krzysztof Chmielewski < krzysiek.chmielew...@gmail.com> wrote: > Hi, > I was wondering if it is possible to implement a Source Table connector > like it is described in [1][2] with custom source that implements a new > Source interface [3] and not a SourceFunction. > > I already have my custom source but when I'm trying to implement a Table > Source from LookupTableSource or ScanTableSource like it is presented in > [1][2] It seems I need to have a SourceFunction object to To be able to use > ScanRuntimeProvider or LookupRuntimeProvider. > > In other words how can I use Source interface implementation in > TableSource? > > Regards, > Krzysztof Chmielewski >
