- cl = parallel::makeCluster(ncores_tasks)
- # 1000*K1 indices [if WER=="end"], or empty vector [if WER=="mix"] --> series on file
- indices = unlist( parallel::parLapply(cl, indices_tasks, function(inds) {
- require("epclust", quietly=TRUE)
- indices_medoids = clusteringTask(inds,getCoefs,K1,nb_series_per_chunk,ncores_clust)
+ if (verbose)
+ cat(paste("...Run ",ntasks," x stage 1 in parallel\n",sep=""))
+ if (parll)
+ {
+ cl = parallel::makeCluster(ncores_tasks)
+ parallel::clusterExport(cl, varlist=c("getSeries","getContribs","K1","K2","verbose","parll",
+ "nb_series_per_chunk","ncores_clust","synchrones_file","sep","nbytes","endian"),
+ envir = environment())
+ }
+
+ runTwoStepClustering = function(inds)
+ {
+ if (parll)
+ require("epclust", quietly=TRUE)
+ indices_medoids = clusteringTask1(
+ inds, getContribs, K1, nb_series_per_chunk, ncores_clust, verbose, parll)