update.SlidingWindow:

In faustogc/streamChaos: Analysis of Non Linear Data Streams

Usage

update.SlidingWindow(window, new.data)

Arguments

window
new.data

Examples

##---- Should be DIRECTLY executable !! ----
##-- ==>  Define data, use random,
##--	or do  help(data=index)  for the standard data sets.

## The function is currently defined as
function (window, new.data) 
{
    num.itens <- length(new.data)
    if (num.itens > window$max.length) 
        stop("Updated more points than the size of the window")
    excess.data <- window$count + num.itens - window$max.length
    if (excess.data > 0) {
        window$data <- window$data[-1:-excess.data]
    }
    window$data <- c(window$data, new.data)
    window$count <- length(window$data)
    if (window$compute.embedded.data) {
        if (is.null(window$embedded.data)) {
            if (window$count >= (window$m - 1) * window$d + 1) {
                window$embedded.data <- embedd(window$data, window$m, 
                  window$d)
                if (window$compute.distances) {
                  window$distances <- as.matrix(dist(window$embedded.data))
                }
            }
        }
        else {
            if (excess.data > 0) {
                window$embedded.data <- window$embedded.data[-1:-excess.data, 
                  ]
            }
            range.embbed.data <- c((window$count - num.itens - 
                ((window$m - 1) * window$d) + 1), window$count)
            if (range.embbed.data[1] < 1) {
                range.embbed.data[1] <- 1
            }
            data.to.embedd <- window$data[range.embbed.data[1]:range.embbed.data[2]]
            new.embedded.data <- embedd(data.to.embedd, window$m, 
                window$d)
            if (window$compute.distances) {
                distance.between.points <- proxy::dist(window$embedded.dat, 
                  new.embedded.data)
            }
            window$embedded.data <- rbind(window$embedded.data, 
                new.embedded.data)
            if (window$compute.distances) {
                if (excess.data > 0) {
                  old.distances <- window$distances[-1:-excess.data, 
                    -1:-excess.data]
                }
                else {
                  old.distances <- window$distances
                }
                new.distances <- as.matrix(dist(new.embedded.data))
                window$distances <- rbind(cbind(old.distances, 
                  distance.between.points), cbind(t(distance.between.points), 
                  new.distances))
            }
        }
    }
    window
  }

faustogc/streamChaos documentation built on May 8, 2019, 9:22 a.m.