hi 👋 one question regarding uid() setup. We want to set up ids for all operators in our job. We have started adding to the sources and sinks and the process functions, filters and mappers. This has worked well. There are few operations like table API transfromations and datastream unions where does not seem possible to set a uid. If I do something like:

sepaCTDataStreamProvider.get().union(sepaICTDataStreamProvider.get())

I would expect to be able to set a uid after the union but does not seem to be the case. Also for this bit of code:

val joinedStream = tableEnv.sqlQuery(
    """
    SELECT *
    FROM payments AS p
    JOIN devices AS d ON p.userId = d.userId
    """.trimIndent(),
)
return tableEnv.toDataStream(joinedStream)

I would want to set a uid for this datastream based on the sql query but I dont seem to find a way for that either. Thanks for the help!