- {
- medoids2 = computeClusters2(
- getSeries(indices_medoids), K2, getSeries, nb_series_per_chunk)
- binarize(medoids2, synchrones_file, nb_series_per_chunk, sep, nbytes, endian)
- return (vector("integer",0))
- }
- indices_medoids
- }) )
-# parallel::stopCluster(cl)
+ message = paste(message," + stage 2", sep="")
+ cat(paste(message,"\n", sep=""))
+ }
+ if (WER=="mix")
+ {synchrones_file = paste(bin_dir,"synchrones",sep="") ; unlink(synchrones_file)}
+ if (parll && ntasks>1)
+ {
+ cl = parallel::makeCluster(ncores_tasks)
+ varlist = c("getSeries","getContribs","K1","K2","verbose","parll",
+ "nb_series_per_chunk","ntasks","ncores_clust","sep","nbytes","endian")
+ if (WER=="mix")
+ varlist = c(varlist, "synchrones_file")
+ parallel::clusterExport(cl, varlist=varlist, envir = environment())
+ }
+
+ # 1000*K1 indices [if WER=="end"], or empty vector [if WER=="mix"] --> series on file
+ if (parll && ntasks>1)
+ indices = unlist( parallel::parLapply(cl, indices_tasks, runTwoStepClustering) )
+ else
+ indices = unlist( lapply(indices_tasks, runTwoStepClustering) )
+ if (parll && ntasks>1)
+ parallel::stopCluster(cl)