[Feature] Expose Flink Source in FlinkSourceBuilder API

[bube]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

As a user of the FlinkSourceBuilder I'd like to be able to get a org.apache.flink.api.connector.source.Source instance returned instead of only having access to the DataStream via build() and buildForRow().

In my particular case I want to bootstrap my pipeline with historical data from a bounded source using Flink's HybridSource, and have the streaming data from a Paimon table. In order to do so, I need to provide the HybridSource with a Source instance which currently isn't possible using the FlinkSourceBuilder.

Solution

No response

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!