Hi everyone,

Suppose I have to compute a filter condition

Integer threshold = compute threshold();

If I:

temperatureStream.filter(new FilterFunction<temperature>() {
@Override
public boolean filter(Integer temperature) throws Exception {
Integer threshold = compute threshold();
return temperature > threshold
}

would this mean I have computed threshold over and over again, for every
new element in the stream?

my threshold does not changes once it computed. I don't want to recompute
it every time for new elements? is there way I can pass it as a parameter
to the filter function?

Reply via email to