我们最近正在使用ApacheFlink流媒体框架，这非常好。然而，在文档中，我们偶然发现了一些我以前从未见过的java东西，这个类
public class MyMapper extends RichMapFunction<String, Integer> {
private Counter counter;
@Override
public void open(Configuration config) {
this.counter = getRuntimeContext()
.getMetricGroup()
.counter("myCounter");
}
@public Integer map(String value) throws Exception {
this.counter.inc();
}
}@public在map方法中是什么意思？更有趣的是，尽管返回类型被定义为integer，为什么方法中没有声明return？
或者这只是他们文档中的一些问题？
这是作为参考Flinkdocu页
1条答案
按热度按时间zzoitvuj1#
这似乎是文档中的一个问题。
这个
@在@public不正确，应该删除，也就是说，这应该是java关键字public. 这个@Public另一个答案中提到的注解不应该用在用户代码中，而应该用在flink的公共接口中。文档页面是关于如何使用度量的，因此作者可能只关注于更新度量的调用，而忘记了度量的返回值
map()方法。如果你能打开一个jira问题来报告错误的文档，那就太好了。谢谢！