我已经学习了几个教程,但是我不能掌握我的想法(在我的例子中不能应用地图分割过滤器的原理),假设我有一个字符串“customer1,buy:order5”我想计算不同字符串中购买单词的数量以及我的流中客户购买的商品数量
JavaDStream<String> words = lines.flatMap(x -> Arrays.asList(x.split(",")).iterator()).filter(x -> Arrays.asList(conteneur).contains(x));
// compte le