map转jsonobject报错（map转jsonstring）



最近准备用flink开发实时交易量统计功能，架构是由业务系统通过kafka发送交易日志，flink服务收集kafka数据统计后存储到es中。

原版
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)

版权声明：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若内容造成侵权、违法违规、事实不符，请将相关资料发送至xkadmin@xkablog.com进行投诉反馈，一经查实，立即处理！

转载请注明出处，原文链接：https://www.xkablog.com/qdvuejs/12305.html