points.add(value.get().getCenter());
}
}
// Increment number of observations for this cluster
clusterTemplate.observe(obs);
if (lastIteration) {
if (clusterTemplate.getNum() < minObservations) {
context.getCounter(COUNTER, COUNTER_REJECTED_CANOPY).increment(1L);
return;