Hi Krzysztof, It is great to hear that you have implemented your source with the unified Source interface. To integrate you source in the Table API you can use the SourceProvider. You can take a look at how our FileSource does is[1]
Btw I think you forgot to add your references ;) Best, Fabian [1] https://github.com/apache/flink/blob/1b4490654e0438332c2a4cac679c05a321d3f34c/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java#L151
