+ runTwoStepClustering = function(inds)
+ {
+ if (parll && ntasks>1)
+ require("epclust", quietly=TRUE)
+ indices_medoids = clusteringTask1(
+ inds, getContribs, K1, nb_series_per_chunk, ncores_clust, verbose, parll)
+ if (WER=="mix")
+ {
+ medoids1 = bigmemory::as.big.matrix( getSeries(indices_medoids) )
+ medoids2 = clusteringTask2(medoids1,
+ K2, getSeries, nb_curves, nb_series_per_chunk, ncores_clust, verbose, parll)
+ binarize(medoids2, synchrones_file, nb_series_per_chunk, sep, nbytes, endian)
+ return (vector("integer",0))
+ }
+ indices_medoids
+ }
+
+ # Cluster contributions in parallel (by nb_series_per_chunk)