What about using an accumulator? Does it work for you needs? Il Sab 18 Gen 2020, 10:03 Soheil Pourbafrani <[email protected]> ha scritto:
> Hi, > > I'm using Flink to insert some processed records into the database. I need > to have some aggregated information about records inserted into the > database so far. For example, for a specific column value, I need to know > how many records have been inserted. Can I use the Flink Matrics to provide > this information? > > Thanks >
