Thanks Fabian and Ingo, yes I forgot to add the refrence links, so here they are:
[1] https://flink.apache.org/2021/09/07/connector-table-sql-api-part1.html [2] https://flink.apache.org/2021/09/07/connector-table-sql-api-part2 [3] https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/sources/ In my case I would really need a LookupTableSource and not ScanTableSource since by use-case and source will get data for given parameters and I don't need to scan the entire resource. Cheers, czw., 4 lis 2021 o 15:48 Krzysztof Chmielewski < krzysiek.chmielew...@gmail.com> napisał(a): > 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 >
