Hi,all:
I need to embed the iceberg table, which is regarded as real-time table, into our workflow. That is to say, Flink writes data into Iceberg table in real-time, I need something to indicate the data completeness on the ingestion path so that downstream batch consumer jobs can be triggered when data is complete for a window (like hourly). Like https://github.com/apache/iceberg/pull/2109. I see that netflix has done related work on this, Is there any doc or patch for implementation? Thx | | liubo07199 | | |
