+ # Right before the final stage, two situations are possible:
+ # a. data to be processed now sit in a binary format in medoids_file (if WER=="mix")
+ # b. data still is the initial set of curves, referenced by the ntasks*K1 indices
+ # So, the function getSeries() will potentially change. However, computeSynchrones()
+ # requires a function retrieving the initial series. Thus, the next line saves future
+ # conditional instructions.
+ getRefSeries = getSeries
+
+ if (WER=="mix" && ntasks>1)
+ {
+ indices = seq_len(ntasks*K2)
+ # Now series (synchrones) must be retrieved from medoids_file
+ getSeries = function(inds) getDataInFile(inds, medoids_file, nbytes, endian)
+ # Contributions must be re-computed
+ unlink(contribs_file)
+ index = 1
+ if (verbose)
+ cat("...Serialize contributions computed on synchrones\n")
+ ignored = binarizeTransform(getSeries,
+ function(series) curvesToContribs(series, wav_filt, contrib_type),
+ contribs_file, nb_series_per_chunk, nbytes, endian)
+ }
+
+ # Run step2 on resulting indices or series (from file)
+ if (verbose)
+ cat("...Run final // stage 1 + stage 2\n")
+ indices_medoids = clusteringTask1(indices, getContribs, K1, algoClust1,
+ nb_series_per_chunk, ncores_tasks*ncores_clust, verbose, parll)
+ medoids1 = bigmemory::as.big.matrix( getSeries(indices_medoids) )
+ medoids2 = clusteringTask2(medoids1, K2, algoClust2, getRefSeries, nb_curves,
+ nb_series_per_chunk, nvoice, nbytes, endian, ncores_tasks*ncores_clust, verbose, parll)
+
+ # Cleanup: remove temporary binary files
+ tryCatch(
+ {unlink(series_file); unlink(contribs_file); unlink(medoids_file)},
+ error = function(e) {})
+
+ # Return medoids as a standard matrix, since K2 series have to fit in RAM
+ # (clustering algorithm 1 takes K1 > K2 of them as input)
+ medoids2[,]
+}
+
+#' curvesToContribs
+#'
+#' Compute the discrete wavelet coefficients for each series, and aggregate them in
+#' energy contribution across scales as described in https://arxiv.org/abs/1101.4744v2
+#'
+#' @param series [big.]matrix of series (in columns), of size L x n
+#' @inheritParams claws
+#'
+#' @return A [big.]matrix of size log(L) x n containing contributions in columns
+#'
+#' @export
+curvesToContribs = function(series, wav_filt, contrib_type, coin=FALSE)
+{
+ series = as.matrix(series) #1D serie could occur
+ L = nrow(series)
+ D = ceiling( log2(L) )
+ # Series are interpolated to all have length 2^D
+ nb_sample_points = 2^D
+ apply(series, 2, function(x) {
+ interpolated_curve = spline(1:L, x, n=nb_sample_points)$y
+ W = wavelets::dwt(interpolated_curve, filter=wav_filt, D)@W
+ # Compute the sum of squared discrete wavelet coefficients, for each scale
+ nrj = rev( sapply( W, function(v) ( sqrt( sum(v^2) ) ) ) )
+ if (contrib_type!="absolute")
+ nrj = nrj / sum(nrj)
+ if (contrib_type=="logit")
+ nrj = - log(1 - nrj)
+ nrj
+ })
+}
+
+# Check integer arguments with functional conditions
+.toInteger <- function(x, condition)
+{
+ errWarn <- function(ignored)
+ paste("Cannot convert argument' ",substitute(x),"' to integer", sep="")
+ if (!is.integer(x))
+ tryCatch({x = as.integer(x)[1]; if (is.na(x)) stop()},
+ warning = errWarn, error = errWarn)
+ if (!condition(x))
+ {
+ stop(paste("Argument '",substitute(x),
+ "' does not verify condition ",body(condition), sep=""))
+ }
+ x
+}
+
+# Check logical arguments
+.toLogical <- function(x)
+{
+ errWarn <- function(ignored)
+ paste("Cannot convert argument' ",substitute(x),"' to logical", sep="")
+ if (!is.logical(x))
+ tryCatch({x = as.logical(x)[1]; if (is.na(x)) stop()},
+ warning = errWarn, error = errWarn)
+ x