获取每个Operator输入输出的数据条数

[王佩]

有如下Pipeline:
      
        Kafka Source=>Map=>Filter=>StreamingFileSink.forBulkFormat

希望实现:

       每次写入文件时，拿到这个Pipeline当前批次每个Operator输入、输出的数据条数并写到Mysql。
      
      请教一下，可以实现吗。感谢。