Re: Can't use nested attributes as watermarks in Table

2022-12-17 Thread Theodor Wübker
Hi Martijn, thanks for your reply :) I thought of looking into contributing this too. I am not super deep into the source code of Flink yet and it might be a little out of scope for the bachelor thesis I am doing, so I have to see if I can find the time at the moment. But generally, I would be

Re: Can't use nested attributes as watermarks in Table

2022-12-16 Thread Martijn Visser
Hi Theo, The most logical reason is that nested attributes were added later than watermarks were :) I agree that it's something that would be worthwhile to improve. If you can and want to make a contribution on this, that would be great. Best regards, Martijn On Wed, Dec 14, 2022 at 9:24 AM The

Re: Can't use nested attributes as watermarks in Table

2022-12-14 Thread Theodor Wübker
Actually, this behaviour is documented (See the Watermarks section, where it is stated that the column must be a “top-level” column). So I suppose, there is a reason. Nevertheless it is quite a limiti

Can't use nested attributes as watermarks in Table

2022-12-13 Thread Theodor Wübker
Hey everyone, I have encountered a problem with my Table API Program. I am trying to use a nested attribute as a watermark. The structure of my schema is a row, which itself has 3 rows as attributes and they again have some attributes, especially the Timestamp that I want to use as a watermark.