watermark and barrier

[Enric Ott]

Hello,Community:
  Are watermark and checkpoint barrier just generated by source and 
coordinated by OperatorCoordinator/CheckpointCoordinator ?
  Any clues appreciated!




------------------ ???????? ------------------
??????:                                                                         
                                               "Enric Ott"                      
                                                              
<243816...@qq.com&gt;;
????????:&nbsp;2024??1??25??(??????) ????2:54
??????:&nbsp;"user"<user@flink.apache.org&gt;;

????:&nbsp;how to get flink accumulated sink record count



Hi??Team??
I was wondering how to get flink accumulated sink record count(just like the 
flink UI displays),any help would be appreciated.