Hi Mans, There are currently no public APIs for doing so, though if you're willing to deal with some breaking changes there are some experimental config options for late events in the Table API and SQL, seen in the WIndowEmitStrategy class[1].
Best, Austin [1]: https://github.com/apache/flink/blob/607919c6ea6983ae5ad3f82d63b7d6455c73d225/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala#L173-L211 On Wed, May 12, 2021 at 5:12 PM M Singh <mans2si...@yahoo.com> wrote: > Thanks Austin for your helpful references. > > I did take a look at [2]/[3] - but did not find anything relevant on > searching for string 'late' (for allowed lateness etc) or side output. So > from my understanding the late events will be dropped if I am using Table > API or SQL and the only option is to use datastream interface. Please let > me know if I missed anything. > > Thanks again. > > > On Wednesday, May 12, 2021, 04:36:06 PM EDT, Austin Cawley-Edwards < > austin.caw...@gmail.com> wrote: > > > Hi Mans, > > I don't believe there are explicit triggers/evictors/timers in the Table > API/ SQL, as that is abstracted away from the lower-level DataStream API. > If you need to get into the fine-grained details, Flink 1.13 has made some > good improvements in going from the Table API to the DataStream API, and > back again. [1] > > For working with time and lateness with Table API and SQL, some good > places to look are the GroupBy Window Aggregation section of the Table API > docs[2], as well as the SQL cookbook[3] and Ververica's SQL training > wiki[4]. > > Hope that helps, > Austin > > [1]: > https://flink.apache.org/news/2021/05/03/release-1.13.0.html#improved-interoperability-between-datastream-api-and-table-apisql > [2]: > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/tableapi/#groupby-window-aggregation > [3]: > https://github.com/ververica/flink-sql-cookbook#aggregations-and-analytics > [4]: https://github.com/ververica/sql-training/wiki/Queries-and-Time > > On Wed, May 12, 2021 at 1:30 PM M Singh <mans2si...@yahoo.com> wrote: > > Hey Folks: > > I have the following questions regarding Table API/SQL in streaming mode: > > 1. Is there is a notion triggers/evictors/timers when using Table API or > SQL interfaces ? > 2. Is there anything like side outputs and ability to define allowed > lateness when dealing with the Table API or SQL interfaces ? > > If there are any alternate ways for the above when using Table API or SQL, > please let me know where I can find the relevant documentation/examples. > > Thanks for your help. > > Mans > > > > >
