Yes, the new TableSource API allows to emit retractions. However, it
does not give you direct access to DataStream API.
FLIP-136 [1] might help you in the near future. We hope it can be part
of 1.12.
Regards,
Timo
[1]
https://lists.apache.org/thread.html/r62b47ec6812ddbafed65ac79e31ca030509
Thanks for your replies Matthias and Timo.
Converting the Table to DataStream, assigning a new Watermark & Rowtime
attribute, and converting back to Table makes sense. One challenge with
that approach is that Table to DataStream conversion could emit retractable
data stream, however, I think, that
Hello,
I use Flink for continuous evaluation of SQL queries on streaming data. One
of the use cases requires us to run recursive SQL queries. I am unable to
find a way to edit rowtime time attribute of the intermediate result table.
For example, let's assume that there is a table T0 with schema -
