X-Git-Url: https://git.auder.net/?p=epclust.git;a=blobdiff_plain;f=epclust%2FR%2Fclustering.R;h=42e894c805eab138e80b038eaa836d78cfa74103;hp=077becf0add865d3bec19d0584d7590257cf867d;hb=74f571a72fd63ae92466d944a9ab4a111d177121;hpb=7b13d0c28da62d91684a29ced50c740120e2b7a9 diff --git a/epclust/R/clustering.R b/epclust/R/clustering.R index 077becf..42e894c 100644 --- a/epclust/R/clustering.R +++ b/epclust/R/clustering.R @@ -15,6 +15,7 @@ clusteringTask = function(K1, K2, WER, nb_series_per_chunk, indices_tasks, ncore indices_workers[[i]] = indices_clust[(nb_series_per_chunk*(i-1)+1):upper_bound] } indices_clust = parallel::parLapply(cl, indices_workers, clusterChunk, K1, K2*(WER=="mix")) + # TODO: soft condition between K2 and K1, before applying final WER step if ((WER=="end" && length(indices_clust)==K1) || (WER=="mix" && length(indices_clust)==K2)) break }