首先,你应该重新初始化min field为Double。最大值
input.foreach(x-> System.out.println(x));
pt_min=getMin(input);
System.out.println("********** "+pt_min);
input= input.filter(x->! x.equals(pt_min));
// reset min
min= Double.MAX_VALUE;
input.foreach(x-> System.out.println(x));
pt_min=getMin(input);
System.out.println("********** "+pt_min);
你应该在方法中使用缓存
getMin(input)
因为输入未保存,您应该使用缓存。
input.cache().foreach(x->{
if(min>Double.parseDouble(x)) {
min = Double.parseDouble(x);
pt_min=x;
}
});