would using a hybrid source work for you if it's the same type between the sources? https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/hybridsource/
On Wed, Oct 26, 2022 at 8:05 AM Noel OConnor <noel.ocon...@gmail.com> wrote: > Hi, > I have a need to create a new stream from a bounded and unbounded > stream i.e. create a stream populated with messages from the bounded > stream and at the end of the bounded stream add messages from the > unbounded stream to the new stream continuously. > I know there's stream unions but the key here is that the order of > messages is important. > > I was looking at using a source function as per this > https://stackoverflow.com/a/48711260 but it seems that source > functions are being deprecated. > > Is there an alternative method to do this ? > > cheers > Noel >
