【发布时间】:2018-05-22 11:44:10
【问题描述】:
代码正在生成IllegalStateException: Duplicate key,如果有
是列表中的重复值,而我们正在尝试提取地图
从使用 java 流的列表中。如果我们在collect中定义合并函数
方法,然后问题就解决了。
List<Employee> empList = new ArrayList<Employee>();
Employee e1 = new Employee(1,"aaaa","mgr",100666.99);
Employee e2 = new Employee(2,"bbbb","lead",90675.99);
Employee e3 = new Employee(3,"cccc","dev",77555.99);
Employee e4 = new Employee(4,"dddd","qe",63546.99);
Employee e5 = new Employee(5,"eeee","lead",90675.99);
Employee e6 = new Employee(6,"ffff","lead",90675.99);
Employee e7 = new Employee(7,"gggg","dev",90675.99);
Employee e8 = new Employee(8,"hhhh","qe",90675.99);
empList.add(e1);
empList.add(e2);
empList.add(e3);
empList.add(e4);
empList.add(e5);
empList.add(e6);
empList.add(e7);
empList.add(e8);
List<Department> deptList = new ArrayList<Department>();
Department d1 = new Department(1, "IT", 10);
Department d2 = new Department(2, "Sales", 20);
Department d3 = new Department(3, "HR", 30);
Department d4 = new Department(4, "Support", 40);
deptList.add(d1);
deptList.add(d2);
deptList.add(d3);
deptList.add(d4);
System.out.println("\n\n List of Leads Names :");
List<String> empNames = empList.stream().filter(emp -> "lead".equals(emp.job)).map(Employee::getName).collect(Collectors.toList());
empNames.forEach(System.out::println);
Map<String,Double> jobSalMap = empList.stream().filter(emp -> "lead".equals(emp.job)).collect(Collectors.toMap(emp->emp.job,emp->emp.sal));
jobSalMap.forEach(new BiConsumer<String,Double>(){
@Override
public void accept(String arg0, Double arg1) {
System.out.println(arg0 + " " + arg1);
}
});
double sumOfLeadSal = empList.stream().filter(emp -> "lead".equals(emp.job)).mapToDouble(Employee::getSal).sum();
System.out.println(sumOfLeadSal);
输出:
List of Leads Names :
bbbb
eeee
ffff
Exception in thread "main" java.lang.IllegalStateException: Duplicate key 90675.99
at java.util.stream.Collectors.lambda$throwingMerger$0(Unknown Source)
at java.util.HashMap.merge(Unknown Source)
at java.util.stream.Collectors.lambda$toMap$58(Unknown Source)
at java.util.stream.ReduceOps$3ReducingSink.accept(Unknown Source)
at java.util.stream.ReferencePipeline$2$1.accept(Unknown Source)
at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(Unknown Source)
at java.util.stream.AbstractPipeline.copyInto(Unknown Source)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(Unknown Source)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(Unknown Source)
at java.util.stream.AbstractPipeline.evaluate(Unknown Source)
at java.util.stream.ReferencePipeline.collect(Unknown Source)
at com.zzar.practice.TestEmployee.main(TestEmployee.java:59)
【问题讨论】:
-
这个问题的格式不正确。我们需要对问题的描述、最少的代码、好的标题和好的标签。请阅读stackoverflow.com/help/how-to-ask 以改进您的问题。
-
您确定您所提供的确切代码会出现此异常吗?
-
确定我以后会发布正确的格式@Opsse
-
抱歉,@mks,它已修复。感谢您纠正我。
-
所以你得到的正是what the documentation specifies:“如果映射的键包含重复项……,则在执行收集操作时会抛出
IllegalStateException。如果映射的键可能有重复,请改用toMap(Function, Function, BinaryOperator)”...
标签: java filter java-stream