counter - 无法在 Flink 1.3.2 中添加计数器

Question

我正在尝试在 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();

        }
    }

Answer 1

如果您为计数器分配一个值，它应该会更好地工作：

    this.counter = getRuntimeContext()
      .getMetricGroup()
      .counter("countit");

您可能会发现文档很有帮助。