Does Flink Metrics provide information about each records inserted into the database

[Soheil Pourbafrani]

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

[Flavio Pompermaier]

What about using an accumulator? Does it work for you needs? 

Il Sab 18 Gen 2020, 10:03 Soheil Pourbafrani <[hidden email]> 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