Hey Pavel, I was looking for something similar a while back and the best thing I came up with was using the DataStream API to do all the shuffling and THEN converting the stream to a table using fromDataStream/fromChangelogStream.
On Wed, Oct 5, 2022 at 4:54 AM Pavel Penkov <ebonfortr...@gmail.com> wrote: > I have a table that reads a Kafka topic and effective parallelism is equal > to the number of Kafka partitions. Is there a way to reshuffle the data > like with DataStream API to increase effective parallelism? >
