我试图在flink中添加一个计数器，正如这里提到的，但问题是counter.inc（）返回的是void而不是integer。我的指标代码如下

private  static class myMetric extends RichMapFunction<String,Integer> {
       private Counter counter ;

        @Override
        public void open(Configuration parameters) throws Exception {
            super.open(parameters);
            this.getRuntimeContext().
                    getMetricGroup().
                    counter("countit");
        }

        @Override
        public Integer map(String s) throws Exception {

            return this.counter.inc();

        }
    }