<svg xmlns="http://www.w3.org/2000/svg" style="display: none;"> <path stroke-linecap="round" d="M5,0 0,2.5 5,5z" id="raphael-marker-block" style="-webkit-tap-highlight-color: rgba(0, 0, 0, 0);"></path> </svg> <p>最近准备用flink开发实时交易量统计功能,架构是由业务系统通过kafka发送交易日志,flink服务收集kafka数据统计后存储到es中。</p>
讯享网

原版
var OBJECT_MAPPER = new ObjectMapper();
var codeMap = new mutable.HashMap[String, Long];
elements.foreach(it => {
codeMap.put(it.getRtnCode, codeMap.getOrElse(it.getRtnCode, 0L).+(1L));
})
OBJECT_MAPPER.writeValueAsString(codeMap)
修改后版本
var OBJECT_MAPPER = new ObjectMapper();
var codeMap: util.Map[String, Long] = new util.HashMap();
elements.foreach(it => {
if (codeMap.containsKey(it.getRtnCode)) {
codeMap.put(it.getRtnCode, codeMap.get(it.getRtnCode).+(1L));
} else {
codeMap.put(it.getRtnCode, 1L);
}
})
OBJECT_MAPPER.writeValueAsString(codeMap)

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容,请联系我们,一经查实,本站将立刻删除。
如需转载请保留出处:https://51itzy.com/kjqy/184046.html